callback
StopReplicaRequestInfo
CallbackBuilder
Callbacks
Callbacks
controller
canEqual
ReassignmentCompleted ReassignmentFailed ReassignmentInProgress ConsumerMetadataRequest ConsumerMetadataResponse ControlledShutdownRequest ControlledShutdownResponse FetchRequest FetchResponse FetchResponsePartitionData HeartbeatRequestAndHeader HeartbeatResponseAndHeader JoinGroupRequestAndHeader JoinGroupResponseAndHeader LeaderAndIsr LeaderAndIsrRequest LeaderAndIsrResponse OffsetCommitRequest OffsetCommitResponse OffsetFetchRequest OffsetFetchResponse OffsetRequest OffsetResponse PartitionFetchInfo PartitionMetadata PartitionOffsetRequestInfo PartitionOffsetsResponse PartitionStateInfo ProducerRequest ProducerResponse ProducerResponseStatus StopReplicaRequest StopReplicaResponse TopicData TopicMetadata TopicMetadataRequest TopicMetadataResponse UpdateMetadataRequest UpdateMetadataResponse Broker ClientIdAllBrokers ClientIdAllTopics ClientIdAndBroker ClientIdAndTopic OffsetAndMetadata OffsetMetadataAndError TopicAndPartition Blacklist ConsumerThreadId FetchedDataChunk Whitelist ControllerBrokerStateInfo StateChangeLogger LeaderIsrAndControllerEpoch NewPartition NewReplica NonExistentPartition NonExistentReplica OfflinePartition OfflineReplica OnlinePartition OnlineReplica PartitionAndReplica ReassignedPartitionsContext ReplicaDeletionIneligible ReplicaDeletionStarted ReplicaDeletionSuccessful StopReplicaRequestInfo ConsumerMetadataResponse FetchRequest FetchResponse OffsetCommitRequest OffsetFetchRequest OffsetRequest OffsetResponse TopicMetadataResponse CleanerConfig LogAppendInfo LogConfig OffsetPosition DefaultCompressionCodec GZIPCompressionCodec LZ4CompressionCodec MessageAndMetadata MessageAndOffset NoCompressionCodec SnappyCompressionCodec CloseConnectionAction NoOpAction Request Response SendAction KeyedMessage PartitionAndLeader BrokerAndFetcherId BrokerAndInitialOffset BrokerShuttingDown BrokerState ClientIdTopicPartition DelayedProduceResponseStatus FetchDataInfo GroupTopicPartition ProduceResult LogOffsetMetadata NotRunning OffsetManagerConfig PartitionDataAndOffset PendingControlledShutdown RecoveringFromUncleanShutdown RunningAsBroker RunningAsController Starting TestRecord
changeFileSuffixes
LogSegment
changeInvalidTimeToCurrentTime
OffsetCommitRequest
changeTopicConfig
AdminUtils
channel
ControllerBrokerStateInfo RequestSendThread
channelToAnyBroker
ClientUtils
channelToOffsetManager
ClientUtils
checkAndMaybeWatch
RequestPurgatory
checkArgs
TopicCommandOptions
checkEnoughReplicasReachOffset
Partition
checkIfPartitionReassignmentSucceeded
ReassignPartitionsCommand
checkIntervalMs
Throttler
checkInvalidArgs
CommandLineUtils
checkLeaderAndIsrZkData
ReplicationUtils
checkpointHighWatermarks
ReplicaManager
checkpointRecoveryPointOffsets
LogManager
checkRequiredArgs
CommandLineUtils
checkSatisfied
FetchRequestPurgatory ProducerRequestPurgatory RequestPurgatory
checksum
Message
ChecksumMessageFormatter
tools
checkZkPathExists
ConsoleConsumer
circularIterator
Utils
CleanedFileSuffix
Log
cleaner
LogManager
CleanerConfig
log LogManager
cleanShutdown
MirrorMaker
CleanShutdownFile
Log
cleanupLogs
LogManager
CleanupPolicyProp
LogConfig
clear
KafkaStream OffsetMap SkimpyOffsetMap Pool
clearCurrentChunk
ConsumerIterator
clearOffsetsInPartition
OffsetManager
client
kafka
clientId
ConsumerMetadataRequest FetchRequest FetchRequestBuilder HeartbeatRequestAndHeader JoinGroupRequestAndHeader LeaderAndIsrRequest OffsetCommitRequest OffsetFetchRequest OffsetRequest ProducerRequest StopReplicaRequest TopicMetadataRequest UpdateMetadataRequest ClientIdAllBrokers ClientIdAllTopics ClientIdAndBroker ClientIdAndTopic ConsumerConfig ConsumerIterator KafkaStream SimpleConsumer ControllerBrokerRequestBatch KafkaController SimpleConsumer TopicMetadataRequest ProducerSendThread SyncProducerConfigShared ClientIdTopicPartition ReplicaVerificationTool ConsumerPerfConfig
ClientIdAllBrokers
common
ClientIdAllTopics
common
ClientIdAndBroker
common
ClientIdAndTopic
common
ClientIdBroker
common
clientIdOpt
ConsumerPerfConfig
ClientIdTopic
common
ClientIdTopicPartition
server
ClientUtils
client
close
SimpleConsumer SimpleConsumer Producer FileMessageSet Log LogSegment OffsetIndex DefaultEventHandler EventHandler BaseProducer KafkaLog4jAppender NewShinyProducer OldProducer Producer ProducerPool SyncProducer KafkaApis LeaderElector ZookeeperLeaderElector MessageReader MessageFormatter
closeAllFetchers
AbstractFetcherManager
closeConnection
RequestChannel
CloseConnectionAction
RequestChannel
cluster
kafka
cmdLineProps
ProducerConfig
codec
LogAppendInfo CompressionCodec DefaultCompressionCodec GZIPCompressionCodec LZ4CompressionCodec NoCompressionCodec SnappyCompressionCodec
codeFor
ErrorMapping
collisionRate
SkimpyOffsetMap
CommandLineUtils
utils
commitOffsets
ConsumerConnector SimpleConsumer ConsumerConnector SimpleConsumer
commitStatus
OffsetCommitResponse
commitStatusGroupedByTopic
OffsetCommitResponse
common
kafka
Compact
Defaults LogConfig
compare
ConsumerThreadId OffsetOrdering dateBasedOrdering
compareTo
DelayedItem
complete
FetchResponseSend PartitionDataSend TopicDataSend MultiSend
compressedTopics
ProducerConfig
CompressionCodec
message Message ProducerConfig ProducerConfig ProducerPerfConfig
compressionCodecOpt
ProducerConfig PerfConfig
compressionCodecOptionValue
ProducerConfig
CompressionCodeMask
Message
CompressionFactory
message
compressionType
KafkaLog4jAppender
computeChecksum
Message
conditionalUpdatePersistentPath
ZkUtils
conditionalUpdatePersistentPathIfExists
ZkUtils
Config
common ConsumerFetcherThread KafkaController Log LogCleaner Producer ProducerPool SyncProducer KafkaApis KafkaServer OffsetManager ReplicaManager ProducerThread ReplayLogProducer
ConfigChangeListener
TopicConfigManager
ConfigNames
LogConfig
configOpt
TopicCommandOptions
connect
BlockingChannel
ConnectionConfig
network
ConnectionQuotas
network
connectionsMaxIdleMs
SocketServer KafkaConfig
connectionString
Broker
ConsoleConsumer
tools
ConsoleProducer
tools
consumeMessages
TestLogCleaning
Consumer
kafka consumer ConsumerThreadId javaapi
ConsumerConfig
consumer ConsumerPerfConfig
ConsumerConnector
consumer consumer
ConsumerCoordinatorNotAvailableCode
ErrorMapping
ConsumerCoordinatorNotAvailableException
common
consumerDir
ZKGroupDirs
ConsumerFetcherManager
consumer ConsumerFetcherThread
ConsumerFetcherThread
consumer
consumerFetchMetricName
RequestMetrics
consumerGroupDir
ZKGroupDirs
consumerId
OffsetCommitRequest AssignmentContext ConsumerConfig
ConsumerIterator
consumer
ConsumerMetadataKey
RequestKeys
ConsumerMetadataRequest
api
ConsumerMetadataResponse
api javaapi
ConsumerOffsetChecker
tools
consumerOffsetDir
ZKGroupTopicDirs
consumerOwnerDir
ZKGroupTopicDirs
ConsumerPerfConfig
ConsumerPerformance SimpleConsumerPerformance
ConsumerPerformance
tools
ConsumerPerfThread
ConsumerPerformance
ConsumerRebalanceFailedException
common
consumerRegistryDir
ZKGroupDirs
consumers
AssignmentContext
consumersForTopic
AssignmentContext
ConsumersPath
ZkUtils
ConsumerThread
MirrorMaker
ConsumerThreadId
consumer
ConsumerTimeoutException
consumer
consumerTimeoutMs
ConsumerConfig
ConsumerTopicMetrics
consumer
ConsumerTopicStats
consumer
ConsumerTopicStatsRegistry
consumer
contains
Pool
containsKey
VerifiableProperties
controlledShutdownEnable
KafkaConfig
ControlledShutdownKey
RequestKeys
ControlledShutdownLeaderSelector
controller
controlledShutdownMaxRetries
KafkaConfig
ControlledShutdownRequest
api
ControlledShutdownResponse
api
controlledShutdownRetryBackoffMs
KafkaConfig
controller
kafka KafkaApis
ControllerBrokerRequestBatch
controller
ControllerBrokerStateInfo
controller
ControllerChannelManager
controller ControllerContext
controllerContext
ControllerBrokerRequestBatch controller KafkaController PartitionsReassignedListener PreferredReplicaElectionListener ReassignedPartitionsIsrChangeListener RequestSendThread TopicDeletionManager
controllerEpoch
LeaderAndIsrRequest StopReplicaRequest UpdateMetadataRequest LeaderIsrAndControllerEpoch ReplicaManager
ControllerEpochPath
ZkUtils
controllerId
LeaderAndIsrRequest StopReplicaRequest UpdateMetadataRequest ControllerBrokerRequestBatch RequestSendThread
controllerLock
ControllerContext
controllerMessageQueueSize
KafkaConfig
ControllerMovedException
common
ControllerPath
ZkUtils
controllerSocketTimeoutMs
KafkaConfig
ControllerStats
controller
convertHWToLocalOffsetMetadata
Replica
convertToOffsetMetadata
Log
coordinator
ConsumerMetadataResponse
coordinatorOpt
ConsumerMetadataResponse
correlationId
ConsumerMetadataRequest ConsumerMetadataResponse ControlledShutdownRequest ControlledShutdownResponse FetchRequest FetchResponse HeartbeatRequestAndHeader HeartbeatResponseAndHeader JoinGroupRequestAndHeader JoinGroupResponseAndHeader LeaderAndIsrRequest LeaderAndIsrResponse OffsetCommitRequest OffsetCommitResponse OffsetFetchRequest OffsetFetchResponse OffsetRequest OffsetResponse ProducerRequest ProducerResponse StopReplicaRequest StopReplicaResponse TopicMetadataRequest TopicMetadataResponse UpdateMetadataRequest UpdateMetadataResponse ControllerContext TopicMetadataRequest DefaultEventHandler KafkaServer
count
TooManyConnectionsException
Crc32
utils Utils
CrcLength
Message
CrcOffset
Message
create
Consumer
createBroker
Broker
created
LogSegment
createdMs
DelayedItem
createEphemeralPathExpectConflict
ZkUtils
createEphemeralPathExpectConflictHandleZKBug
ZkUtils
createFetcherThread
ConsumerFetcherManager AbstractFetcherManager ReplicaFetcherManager
createFile
Utils
createInstance
PartitionAssignor
createJavaConsumerConnector
Consumer
createLog
LogManager
createMessageStreams
ConsumerConnector ConsumerConnector
createMessageStreamsByFilter
ConsumerConnector ConsumerConnector
createObject
Utils
createOpt
TopicCommandOptions
createOrUpdateTopicPartitionAssignmentPathInZK
AdminUtils
createPersistentPath
ZkUtils
createSequentialPersistentPath
ZkUtils
createSyncProducer
ProducerPool
createTopic
AdminUtils TopicCommand
croak
Utils
csvMetricsReporterEnabled
ProducerPerfConfig
csvMetricsReporterEnabledOpt
ProducerPerfConfig
CurrentMagicValue
Message
currentState
BrokerState
CurrentVersion
ConsumerMetadataRequest ConsumerMetadataResponse ControlledShutdownRequest FetchRequest LeaderAndIsrRequest OffsetCommitRequest OffsetCommitResponse OffsetFetchRequest OffsetFetchResponse OffsetRequest ProducerRequest StopReplicaRequest TopicMetadataRequest UpdateMetadataRequest