Class AssignorConfiguration


  • public final class AssignorConfiguration
    extends java.lang.Object
    • Constructor Detail

      • AssignorConfiguration

        public AssignorConfiguration​(java.util.Map<java.lang.String,​?> configs)
    • Method Detail

      • assignmentErrorCode

        public java.util.concurrent.atomic.AtomicInteger assignmentErrorCode()
      • nextScheduledRebalanceMs

        public java.util.concurrent.atomic.AtomicLong nextScheduledRebalanceMs()
      • time

        public org.apache.kafka.common.utils.Time time()
      • rebalanceProtocol

        public org.apache.kafka.clients.consumer.ConsumerPartitionAssignor.RebalanceProtocol rebalanceProtocol()
      • logPrefix

        public java.lang.String logPrefix()
      • configuredMetadataVersion

        public int configuredMetadataVersion​(int priorVersion)
      • userEndPoint

        public java.lang.String userEndPoint()
      • adminClient

        public org.apache.kafka.clients.admin.Admin adminClient()