GZIPCompressionCodec
message
GenerateBrokerIdException
common
GetOffsetShell
tools
Group
auth
GroupAuthorizationCode
ErrorMapping
GroupAuthorizationException
common
GroupConfig
coordinator
GroupCoordinator
coordinator
GroupCoordinatorKey
RequestKeys
GroupCoordinatorNotAvailable
OffsetMetadataAndError
GroupCoordinatorRequest
api
GroupCoordinatorResponse
api javaapi
GroupDoc
ConsumerGroupCommandOptions
GroupKey
server
GroupLoading
OffsetMetadataAndError
GroupMaxSessionTimeoutMsProp
KafkaConfig
GroupMetadataKey
coordinator
GroupMetadataManager
coordinator
GroupMetadataMessageFormatter
GroupMetadataManager
GroupMetadataTopicName
GroupCoordinator
GroupMinSessionTimeoutMsProp
KafkaConfig
GroupOverview
coordinator
GroupSummary
coordinator
GroupTopicPartition
coordinator
generateAssignment
ReassignPartitionsCommand
generateOpt
ReassignPartitionsCommandOptions
generationId
JoinGroupResult
get
OffsetMap SkimpyOffsetMap ConnectionQuotas Pool
getAcls
AclCommand Authorizer SimpleAclAuthorizer
getAllBrokerEndPointsForChannel
ZkUtils
getAllBrokersInCluster
ZkUtils
getAllConsumerGroupsForTopic
ZkUtils
getAllEntitiesWithConfig
ZkUtils
getAllPartitions
ZkUtils
getAllTopics
ZkUtils
getAndMaybePut
Pool
getBoolean
VerifiableProperties
getBrokerAllTopicsStats
BrokerTopicStats
getBrokerEndPoint
Broker
getBrokerInfo
ZkUtils
getBrokerPartitionInfo
BrokerPartitionInfo
getBrokerSequenceId
ZkUtils
getBrokerTopicStats
BrokerTopicStats
getBuffer
ByteBufferMessageSet ByteBufferMessageSet
getChildren
ZkUtils
getChildrenParentMayNotExist
ZkUtils
getCluster
ZkUtils
getCompressionCodec
BrokerCompressionCodec CompressionCodec VerifiableProperties
getConfigChangeZnodeData
AdminUtils
getConsumeOffset
PartitionTopicInfo
getConsumerAllTopicStats
ConsumerTopicStats
getConsumerGroups
ZkUtils
getConsumerPartitionOwnerPath
ZkUtils
getConsumerTopicStat
ConsumerTopicStatsRegistry
getConsumerTopicStats
ConsumerTopicStats
getConsumersInGroup
ZkUtils
getConsumersPerTopic
ZkUtils
getController
ZkUtils
getCurrentTimeString
ReplicaVerificationTool
getDelay
DelayedItem
getDeleteTopicPath
ZkUtils
getDouble
VerifiableProperties
getEntityConfigPath
ZkUtils
getEntityConfigRootPath
ZkUtils
getEpochForPartition
ZkUtils
getFetchOffset
PartitionTopicInfo
getFetchRequestAndResponseAllBrokersStats
FetchRequestAndResponseStats
getFetchRequestAndResponseStats
FetchRequestAndResponseStats FetchRequestAndResponseStatsRegistry
getFetcherLagStats
FetcherLagStats
getGroup
GroupMetadataManager
getInSyncReplicasForPartition
ZkUtils
getInt
VerifiableProperties
getIntInRange
VerifiableProperties
getLeaderAndIsrForPartition
ZkUtils
getLeaderEpoch
Partition
getLeaderForPartition
ZkUtils
getLeaderIsrAndEpochForPartition
ReplicationUtils
getLeaderReplicaIfLocal
ReplicaManager
getLog
LogManager
getLogEndOffset
ConsumerGroupService KafkaConsumerGroupService ZkConsumerGroupService
getLogManager
KafkaServer
getLong
VerifiableProperties
getLongInRange
VerifiableProperties
getMBeanName
KafkaMetricsReporterMBean
getManualReplicaAssignment
AdminUtils
getMap
VerifiableProperties
getNewConsumerProps
ConsoleConsumer
getNewProducerProps
ConsoleProducer
getNextLine
StateChangeLogMerger
getOffsets
GroupMetadataManager
getOffsetsBefore
SimpleConsumer SimpleConsumer
getOldConsumerProps
ConsoleConsumer
getOldProducerProps
ConsoleProducer
getOrCreatePartition
ReplicaManager
getOrCreateReplica
Partition
getOutOfSyncReplicas
Partition
getPartition
ReplicaManager
getPartitionAssignmentForTopics
ZkUtils
getPartitionLeaderAndIsrForTopics
ZkUtils
getPartitionReassignmentZkData
ZkUtils
getPartitionsBeingReassigned
ZkUtils
getPartitionsForTopics
ZkUtils
getPartitionsUndergoingPreferredReplicaElection
ZkUtils
getProducer
ProducerPool
getProducerAllTopicsStats
ProducerTopicStats
getProducerRequestAllBrokersStats
ProducerRequestStats
getProducerRequestStats
ProducerRequestStats ProducerRequestStatsRegistry
getProducerStats
ProducerStatsRegistry
getProducerTopicStats
ProducerTopicStats ProducerTopicStatsRegistry
getProperty
VerifiableProperties
getPropsFromArgs
Kafka
getReaderProps
ConsoleProducer
getReplica
Partition ReplicaManager
getReplicaAssignmentForTopics
ZkUtils
getReplicaOrException
ReplicaManager
getReplicasForPartition
ZkUtils
getSequenceId
ZkUtils
getShort
VerifiableProperties
getShortInRange
VerifiableProperties
getShutdownReceive
RequestChannel
getSortedBrokerList
ZkUtils
getString
VerifiableProperties
getTargetCompressionCodec
BrokerCompressionCodec
getTopicPartitionLeaderAndIsrPath
ZkUtils
getTopicPartitionPath
ZkUtils
getTopicPartitionsPath
ZkUtils
getTopicPath
ZkUtils
getTopicsByConsumerGroup
ZkUtils
globalLabel
DelayedOperationKey
group
GroupCoordinatorRequest GroupTopicPartition ZKGroupDirs
groupConfig
GroupCoordinator
groupGenerationId
OffsetCommitRequest
groupId
OffsetCommitRequest OffsetFetchRequest ConsumerConfig GroupOverview GroupKey MemberKey
groupIdOpt
ConsumerPerfConfig
groupIdPassed
ConsumerConfig
groupManager
GroupCoordinator
groupMaxSessionTimeoutMs
GroupConfig KafkaConfig
groupMinSessionTimeoutMs
GroupConfig KafkaConfig
groupOpt
AclCommandOptions ConsumerGroupCommandOptions