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