PD
ConsumerFetcherThread AbstractFetcherThread ReplicaFetcherThread
Partition
cluster
PartitionAndLeader
producer
PartitionAndReplica
controller
PartitionAssignor
consumer
PartitionData
ConsumerFetcherThread AbstractFetcherThread
PartitionDataSend
api
PartitionFetchInfo
api
PartitionFetchState
server
PartitionLeaderSelector
controller
PartitionMetadata
api javaapi
PartitionOffsetRequestInfo
api
PartitionOffsetsResponse
api
PartitionState
controller
PartitionStateInfo
api
PartitionStateMachine
controller
PartitionTopicInfo
consumer
Partitioner
producer
PartitionsReassignedListener
controller
PendingControlledShutdown
server
PerfConfig
tools
PermissionType
auth
PermissionTypeKey
Acl
Pool
utils
Port
Defaults
PortDoc
KafkaConfig
PortProp
KafkaConfig
PreAllocateEnable
Defaults
PreAllocateEnableDoc
LogConfig
PreAllocateEnableProp
LogConfig
PreferredReplicaElectionListener
controller
PreferredReplicaLeaderElectionCommand
admin
PreferredReplicaLeaderElectionPath
ZkUtils
PreferredReplicaPartitionLeaderSelector
controller
PrincipalBuilderClass
Defaults
PrincipalBuilderClassDoc
KafkaConfig
PrincipalBuilderClassProp
KafkaConfig
PrincipalKey
Acl
ProduceKey
RequestKeys
ProduceMetadata
server
ProducePartitionStatus
server
Producer
producer producer
ProducerClosedException
producer
ProducerCompressionCodec
message
ProducerConfig
producer ConsoleProducer
ProducerOverride
ClientConfigOverride
ProducerPerfConfig
ProducerPerformance
ProducerPerformance
tools
ProducerPool
producer
ProducerPurgatoryPurgeIntervalRequests
Defaults
ProducerPurgatoryPurgeIntervalRequestsDoc
KafkaConfig
ProducerPurgatoryPurgeIntervalRequestsProp
KafkaConfig
ProducerQuotaBytesPerSecondDefault
Defaults
ProducerQuotaBytesPerSecondDefaultDoc
KafkaConfig
ProducerQuotaBytesPerSecondDefaultProp
KafkaConfig
ProducerRequest
api
ProducerRequestMetrics
producer
ProducerRequestStats
producer
ProducerRequestStatsRegistry
producer
ProducerResponse
api
ProducerResponseStatus
api
ProducerSendThread
async
ProducerStats
producer
ProducerStatsRegistry
producer
ProducerThread
ProducerPerformance
ProducerTopicMetrics
producer
ProducerTopicStats
producer
ProducerTopicStatsRegistry
producer
ProtocolEncoding
ApiUtils
parseBrokerList
ClientUtils
parseControllerId
KafkaController
parseCsvList
CoreUtils
parseCsvMap
CoreUtils
parseFull
Json
parseHostPort
BrokerEndPoint
parseKey
LineMessageReader
parseKeyValueArgs
CommandLineUtils
parsePartitionReassignmentData
ZkUtils
parsePartitionReassignmentDataWithoutDedup
ZkUtils
parsePreferredReplicaElectionData
PreferredReplicaLeaderElectionCommand
parseReplicaAssignment
TopicCommand
parseTopicConfigsToBeAdded
TopicCommand
parseTopicConfigsToBeDeleted
TopicCommand
parseTopicPartitionName
Log
parseTopicsData
ZkUtils
parser
AclCommandOptions ConfigCommandOptions ConsumerGroupCommandOptions ReassignPartitionsCommandOptions TopicCommandOptions ConsumerConfig ProducerConfig PerfConfig Config
partKey
KeyedMessage
partition
Replica TopicAndPartition BaseConsumerRecord PartitionAndReplica MessageAndMetadata ByteArrayPartitioner DefaultPartitioner Partitioner TopicPartitionOperationKey ConsumerPerfConfig
partitionAndCollate
DefaultEventHandler
partitionAssignmentStrategy
ConsumerConfig
partitionCount
AbstractFetcherThread ReplicaManager
partitionData
PartitionDataSend TopicData
partitionErrorAndOffsets
OffsetResponse
partitionFor
GroupCoordinator GroupMetadataManager
partitionId
PartitionDataSend PartitionMetadata Partition Replica PartitionTopicInfo PartitionMetadata PartitionAndLeader ClientIdTopicPartition
partitionKey
KeyedMessage
partitionLeadershipInfo
ControllerContext
partitionOpt
ConsumerPerfConfig
partitionReplicaAssignment
ControllerContext
partitionStateInfos
LeaderAndIsrRequest UpdateMetadataRequest
partitionStateMachine
KafkaController TopicDeletionManager
partitionerClass
ProducerConfig
partitions
StopReplicaRequest StateChangeLogMerger
partitionsAssignedToBroker
ReplicaStateMachine
partitionsBeingReassigned
ControllerContext
partitionsForTopic
AssignmentContext ControllerContext
partitionsInState
PartitionStateMachine
partitionsMetadata
TopicMetadata TopicMetadata
partitionsOnBroker
ControllerContext
partitionsOpt
TopicCommandOptions
partitionsRemaining
ControlledShutdownResponse
partitionsToBeDeleted
TopicDeletionManager
partitionsUndergoingPreferredReplicaElection
ControllerContext
pathExists
ZkUtils
payload
Message
payloadSize
Message
peek
DoublyLinkedList IteratorTemplate
permissionType
Acl
persistentZkPaths
ZkUtils
poll
ByteBoundedBlockingQueue
pollingIntervalSecs
KafkaMetricsConfig
port
BrokerEndPoint EndPoint SimpleConsumer SimpleConsumer BlockingChannel ConnectionConfig SyncProducerConfig KafkaConfig
position
OffsetPosition
positionDiff
LogOffsetMetadata
preallocate
LogConfig
precedes
LogOffsetMetadata
prepareStoreGroup
GroupMetadataManager
prepareStoreOffsets
GroupMetadataManager
prev
DoublyLinkedListNode
principal
Session Acl
principalBuilderClass
KafkaConfig
printDescribeHeader
ConsumerGroupService
printKey
DefaultMessageFormatter
printProgressMessage
ConsumerPerformance
printUsageAndDie
CommandLineUtils
process
ConsoleConsumer
processAllNotifications
ZkNodeChangeNotificationListener
processConfigChanges
ClientIdConfigHandler ConfigHandler TopicConfigHandler
processNotification
NotificationHandler AclChangedNotificaitonHandler DynamicConfigManager
processPartitionData
ConsumerFetcherThread AbstractFetcherThread ReplicaFetcherThread
processor
Request Response
produceRequiredAcks
ProduceMetadata
produceStatus
ProduceMetadata
producer
javaapi kafka NewShinyProducer OldProducer ProducerThread ZKConsumerThread
producerConfigOpt
ProducerConfig ProducerPerfConfig
producerNumRetries
ProducerPerfConfig
producerNumRetriesOpt
ProducerPerfConfig
producerOpt
AclCommandOptions
producerPropertyOpt
ProducerConfig
producerProps
ProducerPerfConfig Config
producerPurgatoryPurgeIntervalRequests
KafkaConfig
producerQuotaBytesPerSecondDefault
KafkaConfig
producerRequestRequiredAcks
ProducerPerfConfig
producerRequestRequiredAcksOpt
ProducerPerfConfig
producerRequestStats
SyncProducer
producerRequestTimeoutMs
ProducerPerfConfig
producerRequestTimeoutMsOpt
ProducerPerfConfig
producerRetryBackOffMsOpt
ProducerPerfConfig
producerRetryBackoffMs
ProducerPerfConfig
producerType
ProducerConfig
propagateIsrChanges
ReplicationUtils
propertyOpt
ProducerConfig Config
props
ConsumerConfig LogConfig ProducerConfig SyncProducerConfig SyncProducerConfigShared AsyncProducerConfig KafkaConfig ConsumerPerfConfig ProducerThread VerifiableProperties
protocol
GroupSummary
protocolType
EndPoint GroupOverview GroupSummary
put
OffsetMap SkimpyOffsetMap ByteBoundedBlockingQueue Pool
putIfNotExists
Pool