CallbackBuilder
Callbacks
Callbacks
controller
ChecksumMessageFormatter
tools
CleanShutdownFile
Log
CleanedFileSuffix
Log
CleanerConfig
log
CleanupPolicyProp
LogConfig
ClientIdAllBrokers
common
ClientIdAllTopics
common
ClientIdAndBroker
common
ClientIdAndTopic
common
ClientIdBroker
common
ClientIdTopic
common
ClientIdTopicPartition
server
ClientUtils
client
CloseConnectionAction
RequestChannel
CommandLineUtils
utils
Compact
Defaults
CompressionCodeMask
Message
CompressionCodec
message
CompressionFactory
message
Config
common ReplayLogProducer
ConfigChangeListener
TopicConfigManager
ConfigNames
LogConfig
ConnectionConfig
network
ConnectionQuotas
network
ConsoleConsumer
tools
ConsoleProducer
tools
Consumer
consumer
ConsumerConfig
consumer
ConsumerConnector
consumer consumer
ConsumerCoordinatorNotAvailableCode
ErrorMapping
ConsumerCoordinatorNotAvailableException
common
ConsumerFetcherManager
consumer
ConsumerFetcherThread
consumer
ConsumerIterator
consumer
ConsumerMetadataKey
RequestKeys
ConsumerMetadataRequest
api
ConsumerMetadataResponse
api javaapi
ConsumerOffsetChecker
tools
ConsumerPerfConfig
ConsumerPerformance SimpleConsumerPerformance
ConsumerPerfThread
ConsumerPerformance
ConsumerPerformance
tools
ConsumerRebalanceFailedException
common
ConsumerThread
MirrorMaker
ConsumerThreadId
consumer
ConsumerTimeoutException
consumer
ConsumerTimeoutMs
ConsumerConfig
ConsumerTopicMetrics
consumer
ConsumerTopicStats
consumer
ConsumerTopicStatsRegistry
consumer
ConsumersPath
ZkUtils
ControlledShutdownKey
RequestKeys
ControlledShutdownLeaderSelector
controller
ControlledShutdownRequest
api
ControlledShutdownResponse
api
ControllerBrokerRequestBatch
controller
ControllerBrokerStateInfo
controller
ControllerChannelManager
controller
ControllerContext
controller
ControllerEpochPath
ZkUtils
ControllerMovedException
common
ControllerPath
ZkUtils
ControllerStats
controller
Crc32
utils
CrcLength
Message
CrcOffset
Message
CurrentMagicValue
Message
CurrentVersion
ConsumerMetadataRequest ConsumerMetadataResponse ControlledShutdownRequest FetchRequest LeaderAndIsrRequest OffsetCommitRequest OffsetCommitResponse OffsetFetchRequest OffsetFetchResponse OffsetRequest ProducerRequest StopReplicaRequest TopicMetadataRequest UpdateMetadataRequest
callback
StopReplicaRequestInfo
canEqual
ConsumerMetadataResponse FetchRequest FetchResponse OffsetCommitRequest OffsetFetchRequest OffsetRequest OffsetResponse TopicMetadataResponse
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
checkRequiredArgs
CommandLineUtils
checkSatisfied
FetchRequestPurgatory ProducerRequestPurgatory RequestPurgatory
checkZkPathExists
ConsoleConsumer
checkpointHighWatermarks
ReplicaManager
checkpointRecoveryPointOffsets
LogManager
checksum
Message
circularIterator
Utils
cleanShutdown
MirrorMaker
cleaner
LogManager
cleanerConfig
LogManager
cleanupLogs
LogManager
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 TopicMetadataRequest SimpleConsumer SyncProducerConfigShared ProducerSendThread ClientIdTopicPartition ReplicaVerificationTool ConsumerPerfConfig
clientIdOpt
ConsumerPerfConfig
close
SimpleConsumer SimpleConsumer Producer FileMessageSet Log LogSegment OffsetIndex BaseProducer KafkaLog4jAppender NewShinyProducer OldProducer Producer ProducerPool SyncProducer DefaultEventHandler EventHandler KafkaApis LeaderElector ZookeeperLeaderElector MessageReader MessageFormatter
closeAllFetchers
AbstractFetcherManager
closeConnection
RequestChannel
cluster
kafka
cmdLineProps
ProducerConfig
codeFor
ErrorMapping
codec
LogAppendInfo CompressionCodec DefaultCompressionCodec GZIPCompressionCodec LZ4CompressionCodec NoCompressionCodec SnappyCompressionCodec
collisionRate
SkimpyOffsetMap
commitOffsets
ConsumerConnector SimpleConsumer ConsumerConnector SimpleConsumer
commitStatus
OffsetCommitResponse
commitStatusGroupedByTopic
OffsetCommitResponse
common
kafka
compact
LogConfig
compare
ConsumerThreadId OffsetOrdering dateBasedOrdering
compareTo
DelayedItem
complete
FetchResponseSend PartitionDataSend TopicDataSend MultiSend
compressedTopics
ProducerConfig
compressionCodec
Message ProducerConfig ProducerConfig ProducerPerfConfig
compressionCodecOpt
ProducerConfig PerfConfig
compressionCodecOptionValue
ProducerConfig
compressionType
KafkaLog4jAppender
computeChecksum
Message
conditionalUpdatePersistentPath
ZkUtils
conditionalUpdatePersistentPathIfExists
ZkUtils
config
ConsumerFetcherThread KafkaController Log LogCleaner Producer ProducerPool SyncProducer KafkaApis KafkaServer OffsetManager ReplicaManager ProducerThread
configOpt
TopicCommandOptions
connect
BlockingChannel
connectionString
Broker
connectionsMaxIdleMs
SocketServer KafkaConfig
consumeMessages
TestLogCleaning
consumer
kafka ConsumerThreadId javaapi
consumerConfig
ConsumerPerfConfig
consumerDir
ZKGroupDirs
consumerFetchMetricName
RequestMetrics
consumerFetcherManager
ConsumerFetcherThread
consumerGroupDir
ZKGroupDirs
consumerId
OffsetCommitRequest AssignmentContext ConsumerConfig
consumerOffsetDir
ZKGroupTopicDirs
consumerOwnerDir
ZKGroupTopicDirs
consumerRegistryDir
ZKGroupDirs
consumerTimeoutMs
ConsumerConfig
consumers
AssignmentContext
consumersForTopic
AssignmentContext
contains
Pool
containsKey
VerifiableProperties
controlledShutdownEnable
KafkaConfig
controlledShutdownMaxRetries
KafkaConfig
controlledShutdownRetryBackoffMs
KafkaConfig
controller
kafka KafkaApis
controllerChannelManager
ControllerContext
controllerContext
ControllerBrokerRequestBatch KafkaController PartitionsReassignedListener PreferredReplicaElectionListener ReassignedPartitionsIsrChangeListener RequestSendThread TopicDeletionManager
controllerEpoch
LeaderAndIsrRequest StopReplicaRequest UpdateMetadataRequest LeaderIsrAndControllerEpoch ReplicaManager
controllerId
LeaderAndIsrRequest StopReplicaRequest UpdateMetadataRequest ControllerBrokerRequestBatch RequestSendThread
controllerLock
ControllerContext
controllerMessageQueueSize
KafkaConfig
controllerSocketTimeoutMs
KafkaConfig
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
create
Consumer
createBroker
Broker
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
created
LogSegment
createdMs
DelayedItem
croak
Utils
csvMetricsReporterEnabled
ProducerPerfConfig
csvMetricsReporterEnabledOpt
ProducerPerfConfig
currentState
BrokerState