Partition
cluster
PartitionAndLeader
producer
PartitionAndReplica
controller
PartitionAssignor
consumer
PartitionDataAndOffset
server
PartitionDataSend
api
PartitionFetchInfo
api
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
Pool
utils
PreferredReplicaElectionListener
controller
PreferredReplicaLeaderElectionCommand
admin
PreferredReplicaLeaderElectionPath
ZkUtils
PreferredReplicaPartitionLeaderSelector
controller
ProduceKey
RequestKeys
ProduceResult
KafkaApis
Producer
producer producer
ProducerClosedException
producer
ProducerConfig
producer ConsoleProducer
ProducerPerfConfig
ProducerPerformance
ProducerPerformance
tools
ProducerPool
producer
ProducerRequest
api
ProducerRequestMetrics
producer
ProducerRequestPurgatory
server
ProducerRequestStats
producer
ProducerRequestStatsRegistry
producer
ProducerResponse
api
ProducerResponseStatus
api
ProducerSendThread
async
ProducerStats
producer
ProducerStatsRegistry
producer
ProducerThread
MirrorMaker ProducerPerformance
ProducerTopicMetrics
producer
ProducerTopicStats
producer
ProducerTopicStatsRegistry
producer
ProtocolEncoding
ApiUtils
parseBrokerList
ClientUtils
parseControllerId
KafkaController
parseCsvList
Utils
parseCsvMap
Utils
parseFull
Json
parseKey
LineMessageReader
parseKeyValueArgs
CommandLineUtils
parsePartitionReassignmentData
ZkUtils
parsePartitionReassignmentDataWithoutDedup
ZkUtils
parsePreferredReplicaElectionData
PreferredReplicaLeaderElectionCommand
parseReplicaAssignment
TopicCommand
parseTopicConfigsToBeAdded
TopicCommand
parseTopicConfigsToBeDeleted
TopicCommand
parseTopicPartitionName
Log
parseTopicsData
ZkUtils
parser
ReassignPartitionsCommandOptions TopicCommandOptions ProducerConfig PerfConfig Config
partKey
KeyedMessage
partition
Replica TopicAndPartition PartitionAndReplica MessageAndMetadata ByteArrayPartitioner DefaultPartitioner Partitioner ConsumerPerfConfig
partitionAndCollate
DefaultEventHandler
partitionAssignmentStrategy
ConsumerConfig
partitionCount
AbstractFetcherThread
partitionData
PartitionDataSend TopicData
partitionErrorAndOffsets
OffsetResponse
partitionFor
OffsetManager
partitionId
PartitionDataSend PartitionMetadata Partition Replica PartitionTopicInfo PartitionMetadata PartitionAndLeader ClientIdTopicPartition
partitionKey
KeyedMessage
partitionLeadershipInfo
ControllerContext
partitionOpt
ConsumerPerfConfig
partitionReplicaAssignment
ControllerContext
partitionStateInfos
LeaderAndIsrRequest UpdateMetadataRequest
partitionStateMachine
KafkaController TopicDeletionManager
partitionStatus
DelayedProduce
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
IteratorTemplate
peekLine
TestLogCleaning
pollingIntervalSecs
KafkaMetricsConfig
port
Broker SimpleConsumer SimpleConsumer BlockingChannel ConnectionConfig SocketServer SyncProducerConfig KafkaConfig
position
OffsetPosition
positionDiff
LogOffsetMetadata
precedes
LogOffsetMetadata
printKey
DefaultMessageFormatter
printUsageAndDie
CommandLineUtils
processPartitionData
ConsumerFetcherThread AbstractFetcherThread ReplicaFetcherThread
processor
Request Response
produce
DelayedProduce
produceMessages
TestLogCleaning
producer
javaapi kafka NewShinyProducer OldProducer ProducerThread ProducerThread ZKConsumerThread
producerNumRetries
ProducerPerfConfig
producerNumRetriesOpt
ProducerPerfConfig
producerProps
Config
producerPurgatoryPurgeIntervalRequests
KafkaConfig
producerRequestPurgatory
KafkaApis ReplicaManager
producerRequestRequiredAcks
ProducerPerfConfig
producerRequestRequiredAcksOpt
ProducerPerfConfig
producerRequestStats
SyncProducer
producerRequestTimeoutMs
ProducerPerfConfig
producerRequestTimeoutMsOpt
ProducerPerfConfig
producerRetryBackOffMsOpt
ProducerPerfConfig
producerRetryBackoffMs
ProducerPerfConfig
producerType
ProducerConfig
propertyOpt
ProducerConfig Config
props
ConsumerConfig ProducerConfig SyncProducerConfig SyncProducerConfigShared AsyncProducerConfig KafkaConfig ConsumerPerfConfig ProducerThread VerifiableProperties
put
OffsetMap SkimpyOffsetMap DataChannel Pool
putIfNotExists
Pool
putOffsets
OffsetManager