READY
utils
REQ
ConsumerFetcherThread AbstractFetcherThread ReplicaFetcherThread
RangeAssignor
consumer
Read
auth
ReassignPartitionsCommand
admin
ReassignPartitionsCommandOptions
ReassignPartitionsCommand
ReassignPartitionsPath
ZkUtils
ReassignedPartitionLeaderSelector
controller
ReassignedPartitionsContext
controller
ReassignedPartitionsIsrChangeListener
controller
ReassignmentCompleted
admin
ReassignmentFailed
admin
ReassignmentInProgress
admin
ReassignmentStatus
admin
RecoveringFromUncleanShutdown
server
RecoveryPointCheckpointFile
LogManager
RefreshMetadataBackoffMs
ConsumerConfig
ReplayLogProducer
tools
Replica
cluster
ReplicaDeletionIneligible
controller
ReplicaDeletionStarted
controller
ReplicaDeletionSuccessful
controller
ReplicaFetchBackoffMs
Defaults
ReplicaFetchBackoffMsDoc
KafkaConfig
ReplicaFetchBackoffMsProp
KafkaConfig
ReplicaFetchMaxBytes
Defaults
ReplicaFetchMaxBytesDoc
KafkaConfig
ReplicaFetchMaxBytesProp
KafkaConfig
ReplicaFetchMinBytes
Defaults
ReplicaFetchMinBytesDoc
KafkaConfig
ReplicaFetchMinBytesProp
KafkaConfig
ReplicaFetchWaitMaxMs
Defaults
ReplicaFetchWaitMaxMsDoc
KafkaConfig
ReplicaFetchWaitMaxMsProp
KafkaConfig
ReplicaFetcherManager
server
ReplicaFetcherThread
server
ReplicaHighWatermarkCheckpointIntervalMs
Defaults
ReplicaHighWatermarkCheckpointIntervalMsDoc
KafkaConfig
ReplicaHighWatermarkCheckpointIntervalMsProp
KafkaConfig
ReplicaLagTimeMaxMs
Defaults
ReplicaLagTimeMaxMsDoc
KafkaConfig
ReplicaLagTimeMaxMsProp
KafkaConfig
ReplicaManager
server
ReplicaNotAvailableCode
ErrorMapping
ReplicaNotAvailableException
common
ReplicaSocketReceiveBufferBytes
Defaults
ReplicaSocketReceiveBufferBytesDoc
KafkaConfig
ReplicaSocketReceiveBufferBytesProp
KafkaConfig
ReplicaSocketTimeoutMs
Defaults
ReplicaSocketTimeoutMsDoc
KafkaConfig
ReplicaSocketTimeoutMsProp
KafkaConfig
ReplicaState
controller
ReplicaStateMachine
controller
ReplicaVerificationTool
tools
ReplicationUtils
utils
ReporterStarted
KafkaMetricsReporter
Request
api RequestChannel
RequestChannel
network
RequestKey
SyncProducer
RequestKeys
api
RequestMetrics
network
RequestOrResponse
api
RequestOrResponseSend
network
RequestSendThread
controller
RequestTimedOutCode
ErrorMapping
RequestTimedOutException
common
RequestTimeoutMs
Defaults
RequestTimeoutMsDoc
KafkaConfig
RequestTimeoutMsProp
KafkaConfig
ReservedOutput
BufferingOutputStream
Resource
auth
ResourceType
auth
ResourceTypeToValidOperations
AclCommand
Response
RequestChannel
ResponseAction
RequestChannel
RetentionBytesProp
LogConfig
RetentionMs
Defaults
RetentionMsDoc
LogConfig
RetentionMsProp
LogConfig
RetentionSize
Defaults
RetentionSizeDoc
LogConfig
RoundRobinAssignor
consumer
RunningAsBroker
server
RunningAsController
server
rand
AdminUtils ProducerThread
randomBytesOfLen
EndToEndLatency
randomGenerator
SyncProducer
randomSegmentJitter
LogConfig
rawRegex
Blacklist Whitelist
read
FileMessageSet Log LogSegment ByteBufferBackedInputStream BrokerMetadataCheckpoint OffsetCheckpoint CoreUtils
readBufferSize
BlockingChannel
readData
ZkUtils
readDataMaybeNull
ZkUtils
readFrom
ControlledShutdownRequest ControlledShutdownResponse FetchRequest FetchResponse FetchResponsePartitionData GroupCoordinatorRequest GroupCoordinatorResponse LeaderAndIsrRequest LeaderAndIsrResponse OffsetCommitRequest OffsetCommitResponse OffsetFetchRequest OffsetFetchResponse OffsetRequest OffsetResponse PartitionMetadata PartitionStateInfo ProducerRequest ProducerResponse StopReplicaRequest StopReplicaResponse TopicData TopicMetadata TopicMetadataRequest TopicMetadataResponse UpdateMetadataRequest UpdateMetadataResponse Broker BrokerEndPoint EndPoint GroupCoordinatorResponse OffsetCommitResponse OffsetFetchResponse
readFromLocalLog
ReplicaManager
readGroupMessageValue
GroupMetadataManager
readInt
CoreUtils
readIntInRange
ApiUtils
readInto
FileMessageSet
readLastEntry
OffsetIndex
readLongInRange
ApiUtils
readMessage
LineMessageReader MessageReader
readMessageKey
GroupMetadataManager
readOffsetMessageValue
GroupMetadataManager
readShortInRange
ApiUtils
readShortString
ApiUtils
readSize
LogReadResult
readTimeoutMs
BlockingChannel
reader
LineMessageReader
readerClass
ProducerConfig
reassignPartitions
ReassignPartitionsCommand
reassignmentJsonFileOpt
ReassignPartitionsCommandOptions
rebalanceBackoffMs
ConsumerConfig
rebalanceMaxRetries
ConsumerConfig
receive
BaseConsumer NewShinyConsumer OldConsumer BlockingChannel
receiveBufferSize
ConnectionConfig
receiveRequest
RequestChannel
receiveResponse
RequestChannel
recordAndMaybeThrottle
ClientQuotaManager
recordExpiration
DelayedProduceMetrics
recordIsrChange
ReplicaManager
recordIter
NewShinyConsumer
recover
LogSegment
recoveryPoint
Log
refreshLeaderBackoffMs
ConsumerConfig
regex
TopicFilter
register
KafkaHealthcheck
registerBrokerInZk
ZkUtils
registerInfo
AppInfo
registerListeners
PartitionStateMachine ReplicaStateMachine
registerMBean
CoreUtils
registerPartitionChangeListener
PartitionStateMachine
relativePositionInSegment
LogOffsetMetadata
remainingByteSize
ByteBoundedBlockingQueue
remainingSize
ByteBoundedBlockingQueue
remoteTimeHist
RequestMetrics
remove
IteratorTemplate Pool
removeAcls
Authorizer SimpleAclAuthorizer
removeAllConsumerMetrics
KafkaMetricsGroup
removeAllProducerMetrics
KafkaMetricsGroup
removeBroker
ControllerChannelManager
removeConsumerFetchRequestAndResponseStats
FetchRequestAndResponseStatsRegistry
removeConsumerTopicStat
ConsumerTopicStatsRegistry
removeFetcherForPartitions
AbstractFetcherManager
removeGroup
GroupMetadataManager
removeGroupsForPartition
GroupMetadataManager
removeMetric
KafkaMetricsGroup
removeOpt
AclCommandOptions
removePartitionFromReassignedPartitions
KafkaController
removePartitions
AbstractFetcherThread
removePartitionsFromPreferredReplicaElection
KafkaController
removeProducerRequestStats
ProducerRequestStatsRegistry
removeProducerStats
ProducerStatsRegistry
removeProducerTopicStats
ProducerTopicStatsRegistry
removeReplica
Partition
removeReplicaFromIsr
KafkaController
removeTopic
ControllerContext
renameTo
FileMessageSet OffsetIndex
replaceSuffix
CoreUtils
replica
PartitionAndReplica StopReplicaRequestInfo
replicaAssignmentOpt
TopicCommandOptions
replicaAssignmentZkData
ZkUtils
replicaFetchBackoffMs
KafkaConfig
replicaFetchMaxBytes
KafkaConfig
replicaFetchMinBytes
KafkaConfig
replicaFetchWaitMaxMs
KafkaConfig
replicaFetcherManager
ReplicaManager
replicaHighWatermarkCheckpointIntervalMs
KafkaConfig
replicaId
FetchRequest OffsetRequest
replicaLagTimeMaxMs
KafkaConfig
replicaManager
KafkaApis KafkaServer
replicaSocketReceiveBufferBytes
KafkaConfig
replicaSocketTimeoutMs
KafkaConfig
replicaStateMachine
KafkaController TopicDeletionManager
replicas
PartitionMetadata PartitionMetadata
replicasForPartition
ControllerContext
replicasForTopic
ControllerContext
replicasInDeletionStates
ReplicaStateMachine
replicasInState
ReplicaStateMachine
replicasOnBrokers
ControllerContext
replicationFactor
PartitionStateInfo
replicationFactorOpt
TopicCommandOptions
reportRecordCount
ConsoleConsumer
reportUnavailablePartitionsOpt
TopicCommandOptions
reportUnderReplicatedPartitionsOpt
TopicCommandOptions
reporters
KafkaMetricsConfig
reportingInterval
ConsumerPerfConfig ProducerPerfConfig Config ConsumerPerfConfig
reportingIntervalOpt
PerfConfig Config
request
QueueItem Response
requestChannel
SocketServer KafkaApis KafkaRequestHandler KafkaRequestHandlerPool
requestDequeueTimeMs
Request
requestHandlerPool
KafkaServer
requestId
RequestOrResponse Request
requestInfo
FetchRequest OffsetCommitRequest OffsetFetchRequest OffsetFetchResponse OffsetRequest
requestInfoGroupedByTopic
FetchRequest OffsetCommitRequest OffsetFetchRequest OffsetFetchResponse OffsetRequest
requestObj
Request
requestQueueTimeHist
RequestMetrics
requestRate
RequestMetrics FetcherStats
requestRequiredAcks
SyncProducerConfigShared ProducerConfig
requestRequiredAcksOpt
ProducerConfig
requestSendThread
ControllerBrokerStateInfo
requestSizeHist
FetchRequestAndResponseMetrics ProducerRequestMetrics
requestTimeoutMs
AdminClient SyncProducerConfigShared KafkaConfig ProducerConfig
requestTimeoutMsOpt
ProducerConfig
requestTimer
FetchRequestAndResponseMetrics ProducerRequestMetrics
requestVersion
FetchRequestBuilder FetchResponse ProducerResponse
requiredAcks
ProducerRequest
requiredOffset
ProducePartitionStatus
resendRate
ProducerStats
reserve
BufferingOutputStream
resetBeginningOffsetOpt
ConsumerPerfConfig ConsumerPerfConfig
resetBeginningOpt
ConsumerConfig
resetConsumeOffset
PartitionTopicInfo
resetFetchOffset
PartitionTopicInfo
resetNamespaceCheckedState
ZkPath
resetState
IteratorTemplate
resign
ZookeeperLeaderElector
resize
OffsetIndex
resourceType
Resource
responseAction
Response
responseCompleteTimeMs
Request
responseDequeueTimeMs
Request
responseMap
LeaderAndIsrResponse StopReplicaResponse BecomeLeaderOrFollowerResult
responseQueueTimeHist
RequestMetrics
responseSend
Response
responseSendTimeHist
RequestMetrics
responseSize
FetchResponse
responseStatus
ProducePartitionStatus
result
ZKCheckedEphemeral
resumeCleaning
LogCleaner
resumeDeletionForTopics
TopicDeletionManager
retentionCheckMs
LogManager
retentionMs
OffsetCommitRequest LogConfig
retentionSize
LogConfig
retryBackoffMs
ProducerConfig ProducerConfig
retryBackoffMsOpt
ProducerConfig
rm
CoreUtils
roll
Log
rollJitterMs
LogSegment
run
ZkSecurityMigrator ProducerSendThread DelayedOperation KafkaRequestHandler ConsoleConsumer ConsumerPerfThread MirrorMakerThread ProducerThread ZKConsumerThread ShutdownableThread
runCmd
ZooKeeperMainWrapper
runnable
CoreUtils
runnables
KafkaRequestHandlerPool