rand
AdminUtils ProducerThread
randomGenerator
SyncProducer
randomSegmentJitter
LogConfig
RangeAssignor
consumer
rawRegex
Blacklist Whitelist
read
FileMessageSet Log LogSegment ByteBufferBackedInputStream OffsetCheckpoint Utils
readBufferSize
BlockingChannel
readBytes
Utils
readCompletely
Receive
readData
ZkUtils
readDataMaybeNull
ZkUtils
reader
LineMessageReader
readerClass
ProducerConfig
readFileAsString
Utils
readFrom
ConsumerMetadataRequest ConsumerMetadataResponse ControlledShutdownRequest ControlledShutdownResponse FetchRequest FetchResponse FetchResponsePartitionData HeartbeatRequestAndHeader HeartbeatResponseAndHeader JoinGroupRequestAndHeader JoinGroupResponseAndHeader LeaderAndIsrRequest LeaderAndIsrResponse OffsetCommitRequest OffsetCommitResponse OffsetFetchRequest OffsetFetchResponse OffsetRequest OffsetResponse PartitionMetadata PartitionStateInfo ProducerRequest ProducerResponse StopReplicaRequest StopReplicaResponse TopicData TopicMetadata TopicMetadataRequest TopicMetadataResponse UpdateMetadataRequest UpdateMetadataResponse Broker ConsumerMetadataResponse OffsetCommitResponse OffsetFetchResponse Receive
readInt
Utils
readIntInRange
ApiUtils
readInto
FileMessageSet
readLastEntry
OffsetIndex
readLongInRange
ApiUtils
readMessage
LineMessageReader MessageReader
readMessageKey
OffsetManager
readMessageSets
ReplicaManager
readMessageValue
OffsetManager
readNext
TestLogCleaning
readProps
Utils
readResolve
ReassignmentCompleted ReassignmentFailed ReassignmentInProgress ConsumerMetadataRequest ConsumerMetadataResponse ControlledShutdownRequest ControlledShutdownResponse FetchRequest FetchResponse FetchResponsePartitionData HeartbeatRequestAndHeader HeartbeatResponseAndHeader JoinGroupRequestAndHeader JoinGroupResponseAndHeader LeaderAndIsr LeaderAndIsrRequest LeaderAndIsrResponse OffsetCommitRequest OffsetCommitResponse OffsetFetchRequest OffsetFetchResponse OffsetRequest OffsetResponse PartitionMetadata PartitionStateInfo ProducerRequest ProducerResponse StopReplicaRequest StopReplicaResponse TopicData TopicMetadata TopicMetadataRequest TopicMetadataResponse UpdateMetadataRequest UpdateMetadataResponse Broker OffsetAndMetadata OffsetMetadataAndError NewPartition NewReplica NonExistentPartition NonExistentReplica OfflinePartition OfflineReplica OnlinePartition OnlineReplica ReplicaDeletionIneligible ReplicaDeletionStarted ReplicaDeletionSuccessful LogConfig DefaultCompressionCodec GZIPCompressionCodec LZ4CompressionCodec NoCompressionCodec SnappyCompressionCodec CloseConnectionAction NoOpAction SendAction BrokerShuttingDown LogOffsetMetadata NotRunning OffsetManagerConfig PendingControlledShutdown RecoveringFromUncleanShutdown RunningAsBroker RunningAsController Starting dateBasedOrdering
readShortInRange
ApiUtils
readShortString
ApiUtils
readString
Utils
readTimeoutMs
BlockingChannel
readUnsignedInt
Utils
READY
utils
ReassignedPartitionLeaderSelector
controller
ReassignedPartitionsContext
controller
ReassignedPartitionsIsrChangeListener
controller
ReassignmentCompleted
admin
ReassignmentFailed
admin
ReassignmentInProgress
admin
reassignmentJsonFileOpt
ReassignPartitionsCommandOptions
ReassignmentStatus
admin
reassignPartitions
ReassignPartitionsCommand
ReassignPartitionsCommand
admin
ReassignPartitionsCommandOptions
ReassignPartitionsCommand
ReassignPartitionsPath
ZkUtils
rebalanceBackoffMs
ConsumerConfig
rebalanceMaxRetries
ConsumerConfig
receive
BlockingChannel network
receiveBufferSize
ConnectionConfig
receiveRequest
RequestChannel
receiveResponse
RequestChannel
recover
LogSegment
RecoveringFromUncleanShutdown
server
recoveryPoint
Log
RecoveryPointCheckpointFile
LogManager
recvBufferSize
SocketServer
refreshLeaderBackoffMs
ConsumerConfig
RefreshMetadataBackoffMs
ConsumerConfig
regex
TopicFilter
register
KafkaHealthcheck
registerBrokerInZk
ZkUtils
registerInfo
AppInfo
registerListeners
PartitionStateMachine ReplicaStateMachine
registerMBean
Utils
registerPartitionChangeListener
PartitionStateMachine
relativePositionInSegment
LogOffsetMetadata
remoteAddress
Request
remoteTimeHist
RequestMetrics
remove
IteratorTemplate Pool
removeAllConsumerMetrics
KafkaMetricsGroup
removeAllProducerMetrics
KafkaMetricsGroup
removeBroker
ControllerChannelManager
removeConsumerFetchRequestAndResponseStats
FetchRequestAndResponseStatsRegistry
removeConsumerTopicStat
ConsumerTopicStatsRegistry
removeFetcherForPartitions
AbstractFetcherManager
removeMetric
KafkaMetricsGroup
removePartitionFromReassignedPartitions
KafkaController
removePartitions
AbstractFetcherThread
removePartitionsFromPreferredReplicaElection
KafkaController
removeProducerRequestStats
ProducerRequestStatsRegistry
removeProducerStats
ProducerStatsRegistry
removeProducerTopicStats
ProducerTopicStatsRegistry
removeReplica
Partition
removeReplicaFromIsr
KafkaController
removeTopic
ControllerContext
renameTo
FileMessageSet OffsetIndex
RententionMsProp
LogConfig
replaceSuffix
Utils
ReplayLogProducer
tools
Replica
cluster PartitionAndReplica StopReplicaRequestInfo
replicaAssignmentOpt
TopicCommandOptions
replicaAssignmentZkData
ZkUtils
ReplicaDeletionIneligible
controller
ReplicaDeletionStarted
controller
ReplicaDeletionSuccessful
controller
ReplicaFetcherManager
server ReplicaManager
ReplicaFetcherThread
server
replicaFetchMaxBytes
KafkaConfig
replicaFetchMinBytes
KafkaConfig
replicaFetchWaitMaxMs
KafkaConfig
replicaHighWatermarkCheckpointIntervalMs
KafkaConfig
replicaId
FetchRequest OffsetRequest
replicaLagMaxMessages
KafkaConfig
replicaLagTimeMaxMs
KafkaConfig
replicaManager
KafkaApis KafkaServer server
ReplicaNotAvailableCode
ErrorMapping
ReplicaNotAvailableException
common
replicas
PartitionMetadata PartitionMetadata
replicasForPartition
ControllerContext
replicasForTopic
ControllerContext
replicasInDeletionStates
ReplicaStateMachine
replicasInState
ReplicaStateMachine
replicaSocketReceiveBufferBytes
KafkaConfig
replicaSocketTimeoutMs
KafkaConfig
replicasOnBrokers
ControllerContext
ReplicaState
controller
replicaStateMachine
KafkaController controller TopicDeletionManager
replicationFactor
PartitionStateInfo
replicationFactorOpt
TopicCommandOptions
ReplicationUtils
utils
ReplicaVerificationTool
tools
reporters
KafkaMetricsConfig
ReporterStarted
KafkaMetricsReporter
reportingInterval
ConsumerPerfConfig ProducerPerfConfig Config ConsumerPerfConfig
reportingIntervalOpt
PerfConfig Config
reportUnavailablePartitionsOpt
TopicCommandOptions
reportUnderReplicatedPartitionsOpt
TopicCommandOptions
Request
api RequestChannel Response DelayedFetch DelayedProduce DelayedRequest
RequestChannel
network SocketServer KafkaApis KafkaRequestHandler KafkaRequestHandlerPool
requestDequeueTimeMs
Request
requestHandlerPool
KafkaServer
requestId
RequestOrResponse Request
requestInfo
FetchRequest OffsetCommitRequest OffsetFetchRequest OffsetFetchResponse OffsetRequest
requestInfoGroupedByTopic
FetchRequest OffsetCommitRequest OffsetFetchRequest OffsetFetchResponse OffsetRequest
requestKey
Request SyncProducer
RequestKeys
api
RequestMetrics
network
requestObj
Request
RequestOrResponse
api
RequestPurgatory
server
requestQueueTimeHist
RequestMetrics
requestRate
RequestMetrics FetcherStats
requestRequiredAcks
SyncProducerConfigShared ProducerConfig
requestRequiredAcksOpt
ProducerConfig
requestSendThread
ControllerBrokerStateInfo controller
requestSizeHist
FetchRequestAndResponseMetrics ProducerRequestMetrics
RequestTimedOutCode
ErrorMapping
RequestTimedOutException
common
requestTimeoutMs
SyncProducerConfigShared ProducerConfig
requestTimeoutMsOpt
ProducerConfig
requestTimer
FetchRequestAndResponseMetrics ProducerRequestMetrics
requiredAcks
ProducerRequest
requiredNumAcks
KafkaLog4jAppender
requiredOffset
DelayedProduceResponseStatus
requiresLayout
KafkaLog4jAppender
resendRate
ProducerStats
reset
Crc32
resetBeginningOffsetOpt
ConsumerPerfConfig ConsumerPerfConfig
resetConsumeOffset
PartitionTopicInfo
resetFetchOffset
PartitionTopicInfo
resetState
IteratorTemplate
resign
ZookeeperLeaderElector
resize
OffsetIndex
respond
DelayedFetch DelayedProduce FetchRequestPurgatory ProducerRequestPurgatory
Response
RequestChannel
responseAction
Response RequestChannel
responseCompleteTimeMs
Request
responseDequeueTimeMs
Request
responseFor
OffsetCommitRequest
responseMap
LeaderAndIsrResponse StopReplicaResponse
responseQueueTimeHist
RequestMetrics
responseSend
Response
responseSendTimeHist
RequestMetrics
responseStatus
DelayedProduceResponseStatus
resumeCleaning
LogCleaner
resumeDeletionForTopics
TopicDeletionManager
RetentionBytesProp
LogConfig
retentionCheckMs
LogManager
RetentionMs
Defaults LogConfig
RetentionSize
Defaults LogConfig
retryBackoffMs
ProducerConfig ProducerConfig
retryBackoffMsOpt
ProducerConfig
rm
Utils
roll
Log
rollJitterMs
LogSegment
RoundRobinAssignor
consumer
run
ProducerSendThread KafkaRequestHandler ConsumerPerfThread ConsumerThread ProducerThread ProducerThread ZKConsumerThread ShutdownableThread
runCmd
ZooKeeperMainWrapper
runnable
Utils
runnables
KafkaRequestHandlerPool
RunningAsBroker
server
RunningAsController
server