CallbackBuilder
Callbacks
Callbacks
controller
ChecksumMessageFormatter
tools
CleanShutdownFile
Log
CleanedFileSuffix
Log
CleanerConfig
log
CleanupPolicyProp
LogConfig
Client
ConfigType
ClientConfigOverride
server
ClientIdAllBrokers
common
ClientIdAllTopics
common
ClientIdAndBroker
common
ClientIdAndTopic
common
ClientIdBroker
common
ClientIdConfigHandler
server
ClientIdTopic
common
ClientIdTopicPartition
server
ClientQuotaManager
server
ClientQuotaManagerConfig
server
ClientUtils
client
CloseConnectionAction
RequestChannel
Cluster
auth
ClusterAction
auth
ClusterAuthorizationCode
ErrorMapping
ClusterAuthorizationException
common
ClusterResource
Resource
ClusterResourceName
Resource
CommandConfigDoc
ConsumerGroupCommandOptions
CommandLineUtils
utils
Compact
Defaults LogConfig Defaults
CompactDoc
LogConfig
CompressionCodeMask
Message
CompressionCodec
message
CompressionFactory
message
CompressionType
Defaults Defaults
CompressionTypeDoc
LogConfig KafkaConfig
CompressionTypeProp
LogConfig KafkaConfig
Config
common ReplayLogProducer
ConfigChangeListener
DynamicConfigManager
ConfigCommand
admin
ConfigCommandOptions
ConfigCommand
ConfigHandler
server
ConfigType
server
ConnectionConfig
network
ConnectionQuotas
network
ConnectionsMaxIdleMs
Defaults
ConnectionsMaxIdleMsDoc
KafkaConfig
ConnectionsMaxIdleMsProp
KafkaConfig
ConsoleConsumer
tools
ConsoleProducer
tools
Consumer
consumer
ConsumerConfig
consumer ConsoleConsumer
ConsumerConnector
consumer consumer
ConsumerCoordinatorNotAvailableCode
ErrorMapping
ConsumerCoordinatorNotAvailableException
common
ConsumerFetcherManager
consumer
ConsumerFetcherThread
consumer
ConsumerGroupCommand
admin
ConsumerGroupCommandOptions
ConsumerGroupCommand
ConsumerGroupService
ConsumerGroupCommand
ConsumerIterator
consumer
ConsumerMaxSessionTimeoutMs
Defaults
ConsumerMaxSessionTimeoutMsDoc
KafkaConfig
ConsumerMinSessionTimeoutMs
Defaults
ConsumerMinSessionTimeoutMsDoc
KafkaConfig
ConsumerOffsetChecker
tools
ConsumerOverride
ClientConfigOverride
ConsumerPerfConfig
ConsumerPerformance SimpleConsumerPerformance
ConsumerPerfThread
ConsumerPerformance
ConsumerPerformance
tools
ConsumerQuotaBytesPerSecondDefault
Defaults
ConsumerQuotaBytesPerSecondDefaultDoc
KafkaConfig
ConsumerQuotaBytesPerSecondDefaultProp
KafkaConfig
ConsumerRebalanceFailedException
common
ConsumerRebalanceListener
consumer
ConsumerSummary
AdminClient
ConsumerThreadId
consumer
ConsumerTimeoutException
consumer
ConsumerTimeoutMs
ConsumerConfig
ConsumerTopicMetrics
consumer
ConsumerTopicStats
consumer
ConsumerTopicStatsRegistry
consumer
ConsumersPath
ZkUtils
ControlledShutdownEnable
Defaults
ControlledShutdownEnableDoc
KafkaConfig
ControlledShutdownEnableProp
KafkaConfig
ControlledShutdownKey
RequestKeys
ControlledShutdownLeaderSelector
controller
ControlledShutdownMaxRetries
Defaults
ControlledShutdownMaxRetriesDoc
KafkaConfig
ControlledShutdownMaxRetriesProp
KafkaConfig
ControlledShutdownRequest
api
ControlledShutdownResponse
api
ControlledShutdownRetryBackoffMs
Defaults
ControlledShutdownRetryBackoffMsDoc
KafkaConfig
ControlledShutdownRetryBackoffMsProp
KafkaConfig
ControllerBrokerRequestBatch
controller
ControllerBrokerStateInfo
controller
ControllerChannelManager
controller
ControllerContext
controller
ControllerEpochPath
ZkUtils
ControllerMessageQueueSize
Defaults
ControllerMessageQueueSizeDoc
KafkaConfig
ControllerMovedException
common
ControllerPath
ZkUtils
ControllerSocketTimeoutMs
Defaults
ControllerSocketTimeoutMsDoc
KafkaConfig
ControllerSocketTimeoutMsProp
KafkaConfig
ControllerStats
controller
CoreUtils
utils
CrcLength
Message
CrcOffset
Message
Create
auth
CurrentMagicValue
Message
CurrentVersion
ControlledShutdownRequest FetchRequest GroupCoordinatorRequest GroupCoordinatorResponse LeaderAndIsrRequest OffsetCommitRequest OffsetCommitResponse OffsetFetchRequest OffsetFetchResponse OffsetRequest ProducerRequest StopReplicaRequest TopicMetadataRequest UpdateMetadataRequest Acl
callback
QueueItem StopReplicaRequestInfo DelayedStore
canEqual
FetchRequest FetchResponse GroupCoordinatorResponse OffsetCommitRequest OffsetFetchRequest OffsetRequest OffsetResponse TopicMetadataResponse
cancel
TimerTask
changeClientIdConfig
AdminUtils
changeFileSuffixes
LogSegment
changeTopicConfig
AdminUtils
channelToAnyBroker
ClientUtils
channelToOffsetManager
ClientUtils
checkAndComplete
DelayedOperationPurgatory
checkArgs
AclCommandOptions ConfigCommandOptions ConsumerGroupCommandOptions TopicCommandOptions
checkEnoughReplicasReachOffset
Partition
checkErr
ConsoleConsumer
checkIfPartitionReassignmentSucceeded
ReassignPartitionsCommand
checkIntervalMs
Throttler
checkInvalidArgs
CommandLineUtils
checkLeaderAndIsrZkData
ReplicationUtils
checkNamespace
ZkPath
checkRequiredArgs
CommandLineUtils
checkZk
ConsoleConsumer
checkZkPathExists
ConsoleConsumer
checkpointHighWatermarks
ReplicaManager
checkpointRecoveryPointOffsets
LogManager
checksum
Message
circularIterator
CoreUtils
cleanShutdown
MirrorMaker
cleaner
LogManager
cleanerConfig
LogManager
cleanup
BaseConsumer NewShinyConsumer OldConsumer
cleanupLogs
LogManager
clear
KafkaStream ControllerBrokerRequestBatch OffsetMap SkimpyOffsetMap ByteBoundedBlockingQueue Pool
clearCurrentChunk
ConsumerIterator
client
AdminClient kafka NetworkClientBlockingOps
clientAddress
Session
clientHost
ConsumerSummary MemberSummary
clientId
ConsumerSummary ControlledShutdownRequest FetchRequest FetchRequestBuilder GroupCoordinatorRequest LeaderAndIsrRequest OffsetCommitRequest OffsetFetchRequest OffsetRequest ProducerRequest StopReplicaRequest TopicMetadataRequest UpdateMetadataRequest ClientIdAllBrokers ClientIdAllTopics ClientIdAndBroker ClientIdAndTopic ConsumerConfig ConsumerIterator KafkaStream SimpleConsumer KafkaController MemberSummary TopicMetadataRequest SimpleConsumer SyncProducerConfigShared ProducerSendThread ClientIdTopicPartition ReplicaVerificationTool ConsumerPerfConfig
clientIdOpt
ConsumerPerfConfig
close
AdminClient ConsumerGroupService KafkaConsumerGroupService ZkConsumerGroupService SimpleConsumer SimpleConsumer Producer FileMessageSet Log LogSegment OffsetIndex BaseProducer NewShinyProducer OldProducer Producer ProducerPool SyncProducer DefaultEventHandler EventHandler Authorizer SimpleAclAuthorizer KafkaApis LeaderElector ZookeeperLeaderElector MessageReader MessageFormatter ZkUtils
closeAllFetchers
AbstractFetcherManager
closeConnection
RequestChannel
cluster
kafka
clusterOpt
AclCommandOptions
cmdLineProps
ProducerConfig
codeFor
ErrorMapping
codec
CompressionCodec DefaultCompressionCodec GZIPCompressionCodec LZ4CompressionCodec NoCompressionCodec SnappyCompressionCodec
collisionRate
SkimpyOffsetMap
commandConfigOpt
ConsumerGroupCommandOptions
commit
BaseConsumer NewShinyConsumer OldConsumer
commitOffsets
ConsumerConnector SimpleConsumer ConsumerConnector SimpleConsumer MirrorMaker
commitStatus
OffsetCommitResponse
commitStatusGroupedByTopic
OffsetCommitResponse
commitTimestamp
OffsetAndMetadata
common
kafka
compact
LogConfig
compare
ApiVersion ConsumerThreadId OffsetOrdering dateBasedOrdering
compareTo
DelayedItem
completed
FetchResponseSend PartitionDataSend TopicDataSend
compressedTopics
ProducerConfig
compressionCodec
Message ProducerConfig ProducerConfig ProducerPerfConfig
compressionCodecOpt
ProducerConfig PerfConfig
compressionCodecOptionValue
ProducerConfig
compressionType
LogConfig KafkaConfig
computeChecksum
Message
conditionalUpdatePersistentPath
ZkUtils
conditionalUpdatePersistentPathIfExists
ZkUtils
config
ConsumerFetcherThread KafkaController RequestSendThread GroupMetadataManager Log LogCleaner SocketServer Producer ProducerPool SyncProducer KafkaApis KafkaServer ReplicaManager ProducerThread
configNames
LogConfig KafkaConfig
configOpt
TopicCommandOptions
configure
SimpleAclAuthorizer
connect
BlockingChannel
connectionId
Request
connectionString
BrokerEndPoint EndPoint
connectionsMaxIdleMs
KafkaConfig
consume
ConsumerPerformance
consumer
kafka ConsumerThreadId NewShinyConsumer javaapi
consumerConfigOpt
ConsumerConfig ConsumerPerfConfig
consumerConnector
OldConsumer
consumerCoordinator
KafkaServer
consumerDir
ZKGroupDirs
consumerExpiredRequestMeter
DelayedFetchMetrics
consumerFetchMetricName
RequestMetrics
consumerFetcherManager
ConsumerFetcherThread
consumerGroupDir
ZKGroupDirs
consumerGroupOffsetsDir
ZKGroupDirs
consumerGroupOwnersDir
ZKGroupDirs
consumerId
AssignmentContext ConsumerConfig MemberKey
consumerOffsetDir
ZKGroupTopicDirs
consumerOpt
AclCommandOptions
consumerOwnerDir
ZKGroupTopicDirs
consumerProps
ConsumerConfig
consumerQuotaBytesPerSecondDefault
KafkaConfig
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
controllerSocketTimeoutMs
KafkaConfig
convertHWToLocalOffsetMetadata
Replica
convertToOffsetMetadata
Log
coordinator
kafka GroupCoordinatorResponse KafkaApis
coordinatorOpt
GroupCoordinatorResponse
correlationId
ControlledShutdownRequest ControlledShutdownResponse FetchRequest FetchResponse GroupCoordinatorRequest GroupCoordinatorResponse LeaderAndIsrRequest LeaderAndIsrResponse OffsetCommitRequest OffsetCommitResponse OffsetFetchRequest OffsetFetchResponse OffsetRequest OffsetResponse ProducerRequest ProducerResponse StopReplicaRequest StopReplicaResponse TopicMetadataRequest TopicMetadataResponse UpdateMetadataRequest UpdateMetadataResponse TopicMetadataRequest DefaultEventHandler KafkaServer
count
TooManyConnectionsException
crc32
CoreUtils
create
AdminClient Consumer GroupCoordinator ZKCheckedEphemeral
createBroker
Broker
createBrokerEndPoint
BrokerEndPoint
createEndPoint
EndPoint
createEphemeral
ZkPath
createEphemeralPathExpectConflict
ZkUtils
createFetcherThread
ConsumerFetcherManager AbstractFetcherManager ReplicaFetcherManager
createInstance
PartitionAssignor
createJavaConsumerConnector
Consumer
createLog
LogManager
createMessageStreams
ConsumerConnector ConsumerConnector
createMessageStreamsByFilter
ConsumerConnector ConsumerConnector
createNewConsumers
MirrorMaker
createObject
CoreUtils
createOpt
TopicCommandOptions
createOrUpdateTopicPartitionAssignmentPathInZK
AdminUtils
createPersistent
ZkPath
createPersistentPath
ZkUtils
createPersistentSequential
ZkPath
createSequentialPersistentPath
ZkUtils
createSimplePlaintext
AdminClient
createSyncProducer
ProducerPool
createTopic
AdminUtils TopicCommand
createZkClient
ZkUtils
createZkClientAndConnection
ZkUtils
created
LogSegment
csvMetricsReporterEnabled
ProducerPerfConfig
csvMetricsReporterEnabledOpt
ConsumerConfig ProducerPerfConfig
currentGroups
GroupMetadataManager
currentSegment
BufferingOutputStream
currentState
BrokerState