Scheduler
utils
SecsPerDay
Time
SecsPerHour
Time
SecsPerMin
Time
SegmentBytesProp
LogConfig
SegmentIndexBytesProp
LogConfig
SegmentJitterMs
Defaults
SegmentJitterMsProp
LogConfig
SegmentMs
Defaults
SegmentMsProp
LogConfig
SegmentSize
Defaults
Send
network
SendAction
RequestChannel
SessionExpirationListener
KafkaController
SessionExpireListener
KafkaHealthcheck
ShutdownableThread
utils
SimpleConsumer
consumer consumer
SimpleConsumerPerformance
tools
SimpleConsumerShell
tools
SkimpyOffsetMap
log
SmallestTimeString
OffsetRequest
SnappyCompressionCodec
message
SocketBufferSize
ConsumerConfig
SocketServer
network
SocketTimeout
ConsumerConfig
StaleControllerEpochCode
ErrorMapping
StaleLeaderEpochCode
ErrorMapping
Starting
server
State
utils
StateChangeFailedException
common
StateChangeLogMerger
tools
StateChangeLogger
KafkaController
StopReplicaKey
RequestKeys
StopReplicaRequest
api
StopReplicaRequestInfo
controller
StopReplicaResponse
api
StringDecoder
serializer
StringEncoder
serializer
SwapFileSuffix
Log
SyncProducer
producer
SyncProducerConfig
producer
SyncProducerConfigShared
producer
SystemTime
utils
sanityCheck
OffsetIndex
satisfied
DelayedRequest
schedule
KafkaScheduler Scheduler
searchFor
FileMessageSet
segmentBaseOffset
LogOffsetMetadata
segmentJitterMs
LogConfig
segmentMs
LogConfig
segmentSize
LogConfig
selectLeader
ControlledShutdownLeaderSelector NoOpLeaderSelector OfflinePartitionLeaderSelector PartitionLeaderSelector PreferredReplicaPartitionLeaderSelector ReassignedPartitionLeaderSelector
send
SimpleConsumer SimpleConsumer Producer BlockingChannel BaseProducer NewShinyProducer OldProducer Producer SyncProducer
sendBufferBytes
SyncProducerConfigShared
sendBufferSize
ConnectionConfig SocketServer
sendRequest
ControllerChannelManager KafkaController RequestChannel
sendRequestsToBrokers
ControllerBrokerRequestBatch
sendResponse
RequestChannel
sendTimeout
ProducerConfig
sendTimeoutOpt
ProducerConfig
sendUpdateMetadataRequest
KafkaController
sends
FetchResponseSend TopicDataSend MultiSend
seqIdMode
ProducerPerfConfig
seqIdNumDigit
ProducerThread
serializationErrorRate
ProducerStats
serialize
DefaultEventHandler ZKStringSerializer
serializer
kafka
serializerClass
AsyncProducerConfig
server
kafka
serverConfig
KafkaServerStartable
sessionExpireListener
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 KafkaHealthcheck KafkaRequestHandler KafkaRequestHandlerPool KafkaServer KafkaServerStartable OffsetManager ReplicaFetcherManager ReplicaManager RequestPurgatory ProducerThread ZKConsumerThread KafkaScheduler Scheduler ShutdownableThread
shutdownBroker
KafkaController
shutdownIdleFetcherThreads
AbstractFetcherManager
shutdownLatch
ZKConsumerThread
shuttingDownBrokerIds
ControllerContext
simpleConsumer
AbstractFetcherThread
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 PartitionMetadata TopicMetadata TopicMetadataRequest TopicMetadataResponse ByteBufferMessageSet MessageSet FileMessageSet OffsetIndex ByteBufferMessageSet MessageSet
sleep
SystemTime Time
slots
OffsetMap SkimpyOffsetMap
soTimeout
SimpleConsumer SimpleConsumer
socketBuffer
ProducerConfig
socketBufferSizeOpt
ProducerConfig ConsumerPerfConfig
socketReceiveBufferBytes
ConsumerConfig KafkaConfig
socketRequestMaxBytes
KafkaConfig
socketSendBufferBytes
KafkaConfig
socketServer
KafkaServer
socketTimeoutMs
ConsumerConfig
stackTrace
Utils
start
TopicDeletionManager ProduceResult
startConnections
ConsumerFetcherManager
startDate
StateChangeLogMerger
startHighWaterMarksCheckPointThread
ReplicaManager
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
stateChangeLogger
KafkaController ReplicaManager
stats
FetcherLagStats
status
ReassignmentCompleted ReassignmentFailed ReassignmentInProgress ReassignmentStatus ProducerResponse
stopConnections
ConsumerFetcherManager
stopReplica
ReplicaManager
stopReplicaCallback
CallbackBuilder
stopReplicaRequestMap
ControllerBrokerRequestBatch
stopReplicaResponseCallback
Callbacks
stopReplicaResponseCbk
CallbackBuilder
stopReplicas
ReplicaManager
stopReporter
KafkaMetricsReporterMBean
subAppend
KafkaLog4jAppender
swallow
Logging Utils
swallowDebug
Logging
swallowError
Logging
swallowInfo
Logging
swallowTrace
Logging
swallowWarn
Logging
sync
NewShinyProducer ProducerConfig
syncOpt
ProducerConfig ProducerPerfConfig Config
syncSend
KafkaLog4jAppender