sanityCheck
OffsetIndex
satisfied
DelayedRequest
schedule
KafkaScheduler Scheduler
Scheduler
utils
searchFor
FileMessageSet
SecsPerDay
Time
SecsPerHour
Time
SecsPerMin
Time
segmentBaseOffset
LogOffsetMetadata
SegmentBytesProp
LogConfig
SegmentIndexBytesProp
LogConfig
SegmentJitterMs
Defaults LogConfig
SegmentJitterMsProp
LogConfig
SegmentMs
Defaults LogConfig
SegmentMsProp
LogConfig
SegmentSize
Defaults LogConfig
selectLeader
ControlledShutdownLeaderSelector NoOpLeaderSelector OfflinePartitionLeaderSelector PartitionLeaderSelector PreferredReplicaPartitionLeaderSelector ReassignedPartitionLeaderSelector
send
SimpleConsumer SimpleConsumer Producer BlockingChannel network BaseProducer NewShinyProducer OldProducer Producer SyncProducer
SendAction
RequestChannel
sendBufferBytes
SyncProducerConfigShared
sendBufferSize
ConnectionConfig SocketServer
sendRequest
ControllerChannelManager KafkaController RequestChannel
sendRequestsToBrokers
ControllerBrokerRequestBatch
sendResponse
RequestChannel
sends
FetchResponseSend TopicDataSend MultiSend
sendTimeout
ProducerConfig
sendTimeoutOpt
ProducerConfig
sendUpdateMetadataRequest
KafkaController
seqIdMode
ProducerPerfConfig
seqIdNumDigit
ProducerThread
serializationErrorRate
ProducerStats
serialize
DefaultEventHandler ZKStringSerializer
serializer
kafka
serializerClass
AsyncProducerConfig
server
kafka
serverConfig
KafkaServerStartable
SessionExpirationListener
KafkaController
sessionExpireListener
KafkaHealthcheck KafkaHealthcheck
setBrokerList
KafkaLog4jAppender
setCompressionType
KafkaLog4jAppender
setRequiredNumAcks
KafkaLog4jAppender
setServerState
KafkaServerStartable
setSyncSend
KafkaLog4jAppender
setTopic
KafkaLog4jAppender
setupCommonPaths
ZkUtils
shallowCount
LogAppendInfo
shallowIterator
ByteBufferMessageSet
shortStringLength
ApiUtils
showDetailedStats
ConsumerPerfConfig ConsumerPerfConfig
showDetailedStatsOpt
PerfConfig
shutdown
ConsumerConnector ZookeeperTopicEventWatcher ControllerChannelManager KafkaController PartitionStateMachine ReplicaStateMachine TopicDeletionManager ConsumerConnector LogCleaner LogManager RequestChannel SocketServer ProducerSendThread AbstractFetcherThread KafkaRequestHandler KafkaRequestHandlerPool KafkaServer KafkaServerStartable OffsetManager ReplicaFetcherManager ReplicaManager RequestPurgatory ProducerThread ZKConsumerThread KafkaScheduler Scheduler ShutdownableThread
ShutdownableThread
utils
shutdownBroker
KafkaController
shutdownIdleFetcherThreads
AbstractFetcherManager
shutdownLatch
ZKConsumerThread
shuttingDownBrokerIds
ControllerContext
SimpleConsumer
consumer consumer AbstractFetcherThread
SimpleConsumerPerformance
tools
SimpleConsumerShell
tools
size
Log LogSegment OffsetMap SkimpyOffsetMap Message Pool
sizeInBytes
ConsumerMetadataRequest ConsumerMetadataResponse ControlledShutdownRequest ControlledShutdownResponse FetchRequest FetchResponse FetchResponsePartitionData LeaderAndIsrRequest LeaderAndIsrResponse OffsetCommitRequest OffsetCommitResponse OffsetFetchRequest OffsetFetchResponse OffsetRequest OffsetResponse PartitionMetadata PartitionStateInfo ProducerRequest ProducerResponse RequestOrResponse StopReplicaRequest StopReplicaResponse TopicData TopicMetadata TopicMetadataRequest TopicMetadataResponse UpdateMetadataRequest UpdateMetadataResponse Broker ByteBufferMessageSet MessageSet PartitionMetadata TopicMetadata TopicMetadataRequest TopicMetadataResponse FileMessageSet OffsetIndex ByteBufferMessageSet MessageSet
SkimpyOffsetMap
log
sleep
SystemTime Time
slots
OffsetMap SkimpyOffsetMap
SmallestTimeString
OffsetRequest
SnappyCompressionCodec
message
socketBuffer
ProducerConfig
SocketBufferSize
ConsumerConfig
socketBufferSizeOpt
ProducerConfig ConsumerPerfConfig
socketReceiveBufferBytes
ConsumerConfig KafkaConfig
socketRequestMaxBytes
KafkaConfig
socketSendBufferBytes
KafkaConfig
SocketServer
network KafkaServer
SocketTimeout
ConsumerConfig
socketTimeoutMs
ConsumerConfig
soTimeout
SimpleConsumer SimpleConsumer
stackTrace
Utils
StaleControllerEpochCode
ErrorMapping
StaleLeaderEpochCode
ErrorMapping
start
TopicDeletionManager ProduceResult
startConnections
ConsumerFetcherManager
startDate
StateChangeLogMerger
startHighWaterMarksCheckPointThread
ReplicaManager
Starting
server
startReporter
KafkaMetricsReporterMBean
startReporters
KafkaMetricsReporter
startTimeMs
Request
startup
ControllerChannelManager KafkaController PartitionStateMachine ReplicaStateMachine LogCleaner LogManager SocketServer KafkaHealthcheck KafkaServer KafkaServerStartable LeaderElector ReplicaManager TopicConfigManager ZookeeperLeaderElector KafkaScheduler Scheduler
state
NewPartition NewReplica NonExistentPartition NonExistentReplica OfflinePartition OfflineReplica OnlinePartition OnlineReplica PartitionState ReplicaDeletionIneligible ReplicaDeletionStarted ReplicaDeletionSuccessful ReplicaState BrokerShuttingDown BrokerStates NotRunning PendingControlledShutdown RecoveringFromUncleanShutdown RunningAsBroker RunningAsController Starting utils
StateChangeFailedException
common
stateChangeLogger
KafkaController KafkaController ReplicaManager
StateChangeLogMerger
tools
stats
FetcherLagStats
status
ReassignmentCompleted ReassignmentFailed ReassignmentInProgress ReassignmentStatus ProducerResponse
stopConnections
ConsumerFetcherManager
stopReplica
ReplicaManager
stopReplicaCallback
CallbackBuilder
StopReplicaKey
RequestKeys
StopReplicaRequest
api
StopReplicaRequestInfo
controller
stopReplicaRequestMap
ControllerBrokerRequestBatch
StopReplicaResponse
api
stopReplicaResponseCallback
Callbacks
stopReplicaResponseCbk
CallbackBuilder
stopReplicas
ReplicaManager
stopReporter
KafkaMetricsReporterMBean
StringDecoder
serializer
StringEncoder
serializer
subAppend
KafkaLog4jAppender
swallow
Logging Utils
swallowDebug
Logging
swallowError
Logging
swallowInfo
Logging
swallowTrace
Logging
swallowWarn
Logging
SwapFileSuffix
Log
sync
NewShinyProducer ProducerConfig
syncOpt
ProducerConfig ProducerPerfConfig Config
SyncProducer
producer
SyncProducerConfig
producer
SyncProducerConfigShared
producer
syncSend
KafkaLog4jAppender
SystemTime
utils