AbstractFetcherManager
server
AbstractFetcherThread
server
Acl
auth
AclChangedNotificationHandler
SimpleAclAuthorizer
AclChangedPrefix
SimpleAclAuthorizer
AclChangedZkPath
SimpleAclAuthorizer
AclCommand
admin
AclCommandOptions
AclCommand
AclZkPath
SimpleAclAuthorizer
AclsKey
Acl
AddPartitionsListener
PartitionStateMachine
AdminClient
admin
AdminClientId
AdminUtils
AdminClientIdSequence
AdminClient
AdminCommandFailedException
common
AdminConfig
AdminClient
AdminConfigDef
AdminClient
AdminOperationException
admin
AdminUtils
admin
AdvertisedHostNameDoc
KafkaConfig
AdvertisedHostNameProp
KafkaConfig
AdvertisedListenersDoc
KafkaConfig
AdvertisedListenersProp
KafkaConfig
AdvertisedPortDoc
KafkaConfig
AdvertisedPortProp
KafkaConfig
All
auth
AllDone
RequestChannel
Allow
auth
AllowAllAcl
Acl
AllowEveryoneIfNoAclIsFoundProp
SimpleAclAuthorizer
Alter
auth
ApiUtils
api
ApiVersion
api
AppInfo
common
AssignmentContext
consumer
AsyncProducerConfig
async
AttributesLength
Message
AttributesOffset
Message
AuthorizationException
common
Authorizer
auth
AuthorizerClassName
Defaults
AuthorizerClassNameDoc
KafkaConfig
AuthorizerClassNameProp
KafkaConfig
AutoCommit
ConsumerConfig
AutoCommitInterval
ConsumerConfig
AutoCreateTopicsEnable
Defaults
AutoCreateTopicsEnableDoc
KafkaConfig
AutoCreateTopicsEnableProp
KafkaConfig
AutoLeaderRebalanceEnable
Defaults
AutoLeaderRebalanceEnableDoc
KafkaConfig
AutoLeaderRebalanceEnableProp
KafkaConfig
AutoOffsetReset
ConsumerConfig
abortAndPauseCleaning
LogCleaner
abortCleaning
LogCleaner
ackTimeoutMs
ProducerRequest
acksPending
ProducePartitionStatus
activeSegment
Log
add
Timer
addAcls
Authorizer SimpleAclAuthorizer
addBroker
ControllerChannelManager
addConfig
ConfigCommandOptions
addFetch
FetchRequestBuilder
addFetcherForPartitions
AbstractFetcherManager
addGroup
GroupMetadataManager
addLeaderAndIsrRequestForBrokers
ControllerBrokerRequestBatch
addOpt
AclCommandOptions
addPartitionOwnership
GroupMetadataManager
addPartitions
AdminUtils AbstractFetcherThread
addPartitionsWithError
ConsumerFetcherManager
addReplicaIfNotExists
Partition
addResponseListener
RequestChannel
addSegment
Log
addShutdownHook
ConsoleConsumer
addStopReplicaRequestForBrokers
ControllerBrokerRequestBatch
addUpdateMetadataRequestForBrokers
ControllerBrokerRequestBatch
admin
kafka
advanceClock
Timer
advertisedHostName
KafkaConfig
advertisedListeners
KafkaConfig
advertisedPort
KafkaConfig
aggregateIdleMeter
KafkaRequestHandler
aliveBrokers
UpdateMetadataRequest
allConsumerGroupLevelOpts
ConsumerGroupCommandOptions
allDone
ProducerThread IteratorTemplate
allLiveReplicas
ControllerContext
allLogs
LogManager
allOpts
ConfigCommandOptions
allReplicas
PartitionStateInfo
allTopicLevelOpts
TopicCommandOptions
allTopics
ControllerContext
allowHostsOpt
AclCommandOptions
allowPrincipalsOpt
AclCommandOptions
alterOpt
ConfigCommandOptions TopicCommandOptions
alterTopic
TopicCommand
amILeader
LeaderElector ZookeeperLeaderElector
api
kafka
apiKey
QueueItem
apiLocalCompleteTimeMs
Request
apiRemoteCompleteTimeMs
Request
apiVersion
QueueItem
apis
KafkaRequestHandlerPool KafkaServer
append
FileMessageSet Log LogSegment OffsetIndex
appendMessages
ReplicaManager
appendMessagesToLeader
Partition
apply
ApiVersion OffsetAndMetadata OffsetMetadataAndError LogConfig CompressionFactory KafkaConfig ZkUtils
areAllReplicasForTopicDeleted
ReplicaStateMachine
asTuple
TopicAndPartition
askToProceed
TopicCommand
assign
PartitionAssignor RangeAssignor RoundRobinAssignor
assignReplicasToBrokers
AdminUtils
assignedReplicas
Partition
assignment
ConsumerSummary MemberSummary
async
producer
attributes
Message
auth
security
authorize
Authorizer SimpleAclAuthorizer
authorizeClusterAction
KafkaApis
authorizer
KafkaApis KafkaServer
authorizerClassName
KafkaConfig
authorizerOpt
AclCommandOptions
authorizerPropertiesOpt
AclCommandOptions
autoCommitEnable
ConsumerConfig
autoCommitIntervalMs
ConsumerConfig
autoCreateTopicsEnable
KafkaConfig
autoLeaderRebalanceEnable
KafkaConfig
autoOffsetReset
ConsumerConfig
awaitCleaned
LogCleaner
awaitShutdown
KafkaServer KafkaServerStartable MirrorMakerThread ShutdownableThread