tags
ConsumerTopicMetrics
FetchRequestAndResponseMetrics
Log
RequestMetrics
ProducerRequestMetrics
ProducerStats
ProducerTopicMetrics
BrokerTopicMetrics
FetcherStats
take
DataChannel
tcpNoDelay
ConnectionConfig
TestEndToEndLatency
tools
TestLogCleaning
tools
TestRecord
tools
threadId
ConsumerThreadId
ProducerThread
ProducerThread
threadName
ProducerSendThread
threadNamePrefix
KafkaScheduler
threads
KafkaRequestHandlerPool
KafkaScheduler
threadsafe
utils
ThreadShutdownException
common
throttleDown
Throttler
Throttler
utils
time
PartitionOffsetRequestInfo
KafkaTimer
Throttler
utils
timestamp
OffsetAndMetadata
toBroker
RequestSendThread
toBytes
DefaultEncoder
Encoder
NullEncoder
StringEncoder
tools
kafka
ToolsUtils
utils
TooManyConnectionsException
network
topic
TopicData
TopicMetadata
Partition
Replica
ClientIdAndTopic
common
TopicAndPartition
PartitionTopicInfo
PartitionAndReplica
TopicMetadata
MessageAndMetadata
KafkaLog4jAppender
KeyedMessage
PartitionAndLeader
ClientIdTopicPartition
LineMessageReader
ProducerConfig
ConsumerPerfConfig
ConsumerPerfConfig
StateChangeLogMerger
TestRecord
topicAndKey
TestRecord
TopicAndPartition
common
Log
TopicChangeListener
PartitionStateMachine
TopicCommand
admin
TopicCommandOptions
TopicCommand
TopicConfigChangesPath
ZkUtils
TopicConfigChangeZnodePrefix
AdminUtils
topicConfigManager
KafkaServer
server
TopicConfigPath
ZkUtils
topicConfigs
LogManager
TopicData
api
TopicDataSend
TopicDataSend
api
TopicDeletionManager
controller
TopicEventHandler
consumer
topicEventListener
ZkSessionExpireListener
topicExists
AdminUtils
TopicExistsException
common
TopicFilter
consumer
topicInfo
FetchedDataChunk
TopicMetadata
api
javaapi
topicMetadataRefreshIntervalMs
ProducerConfig
TopicMetadataRequest
api
javaapi
TopicMetadataResponse
api
javaapi
topicOpt
TopicCommandOptions
ProducerConfig
ConsumerPerfConfig
ConsumerPerfConfig
topicPartition
GroupTopicPartition
topicPartitionMessageSizeMap
ProducerRequest
topicPartitionRegex
StateChangeLogMerger
topics
TopicMetadataRequest
TopicMetadataRequest
ProducerPerfConfig
topicsIneligibleForDeletion
TopicDeletionManager
topicsMetadata
TopicMetadataResponse
TopicMetadataResponse
topicsOpt
ProducerPerfConfig
topicsStr
ProducerPerfConfig
topicsToBeDeleted
TopicDeletionManager
topicsToMoveJsonFileOpt
ReassignPartitionsCommandOptions
topicsWithOverridesOpt
TopicCommandOptions
toProps
LogConfig
toString
ReassignmentCompleted
ReassignmentFailed
ReassignmentInProgress
ConsumerMetadataRequest
ConsumerMetadataResponse
ControlledShutdownRequest
ControlledShutdownResponse
FetchRequest
FetchResponse
FetchResponsePartitionData
LeaderAndIsr
LeaderAndIsrRequest
LeaderAndIsrResponse
OffsetCommitRequest
OffsetCommitResponse
OffsetFetchRequest
OffsetFetchResponse
OffsetRequest
OffsetResponse
PartitionFetchInfo
PartitionMetadata
PartitionOffsetRequestInfo
PartitionOffsetsResponse
PartitionStateInfo
ProducerRequest
ProducerResponse
ProducerResponseStatus
StopReplicaRequest
StopReplicaResponse
TopicData
TopicMetadata
TopicMetadataRequest
TopicMetadataResponse
UpdateMetadataRequest
UpdateMetadataResponse
Broker
Partition
Replica
ClientIdAllBrokers
ClientIdAllTopics
ClientIdAndBroker
ClientIdAndTopic
OffsetAndMetadata
OffsetMetadataAndError
TopicAndPartition
ConsumerThreadId
FetchedDataChunk
KafkaStream
PartitionTopicInfo
TopicFilter
ControllerBrokerStateInfo
StateChangeLogger
LeaderIsrAndControllerEpoch
NewPartition
NewReplica
NonExistentPartition
NonExistentReplica
OfflinePartition
OfflineReplica
OnlinePartition
OnlineReplica
PartitionAndReplica
ReassignedPartitionsContext
ReplicaDeletionIneligible
ReplicaDeletionStarted
ReplicaDeletionSuccessful
StopReplicaRequestInfo
ConsumerMetadataResponse
FetchRequest
ByteBufferMessageSet
OffsetCommitRequest
OffsetFetchRequest
OffsetRequest
OffsetResponse
PartitionMetadata
TopicMetadata
TopicMetadataRequest
TopicMetadataResponse
CleanerConfig
Log
LogAppendInfo
LogConfig
LogSegment
OffsetPosition
DefaultCompressionCodec
GZIPCompressionCodec
LZ4CompressionCodec
Message
MessageAndMetadata
MessageAndOffset
MessageSet
NoCompressionCodec
SnappyCompressionCodec
CloseConnectionAction
NoOpAction
Request
Response
SendAction
KeyedMessage
PartitionAndLeader
BrokerAndFetcherId
BrokerAndInitialOffset
BrokerShuttingDown
BrokerState
ClientIdTopicPartition
DelayedProduceResponseStatus
FetchDataInfo
GroupTopicPartition
ProduceResult
LogOffsetMetadata
NotRunning
OffsetManagerConfig
PartitionDataAndOffset
PendingControlledShutdown
RecoveringFromUncleanShutdown
RunningAsBroker
RunningAsController
Starting
TestRecord
VerifiableProperties
totalBytesSent
ProducerThread
totalHandlerThreads
KafkaRequestHandler
totalMessagesSent
ProducerThread
totalTimeHist
RequestMetrics
totalWritten
MultiSend
trace
Logging
triggerOnlinePartitionStateChange
PartitionStateMachine
trimToValidSize
OffsetIndex
truncate
OffsetIndex
truncateFullyAndStartAt
LogManager
truncateTo
FileMessageSet
LogManager
LogSegment
OffsetIndex
tryLock
FileLock
tryParse
ConsoleConsumer
tryToHandle
ProducerSendThread