TestEndToEndLatency
tools
TestLogCleaning
tools
TestRecord
tools
ThreadShutdownException
common
Throttler
utils
Time
utils
TooManyConnectionsException
network
ToolsUtils
utils
Topic
common
TopicAndPartition
common
TopicChangeListener
PartitionStateMachine
TopicCommand
admin
TopicCommandOptions
TopicCommand
TopicConfigChangeZnodePrefix
AdminUtils
TopicConfigChangesPath
ZkUtils
TopicConfigManager
server
TopicConfigPath
ZkUtils
TopicData
api
TopicDataSend
api
TopicDeletionManager
controller
TopicEventHandler
consumer
TopicExistsException
common
TopicFilter
consumer
TopicMetadata
api javaapi
TopicMetadataRequest
api javaapi
TopicMetadataResponse
api javaapi
tags
ConsumerTopicMetrics FetchRequestAndResponseMetrics Log RequestMetrics ProducerRequestMetrics ProducerStats ProducerTopicMetrics BrokerTopicMetrics FetcherStats
take
DataChannel
tcpNoDelay
ConnectionConfig
threadId
ConsumerThreadId ProducerThread ProducerThread
threadName
ProducerSendThread
threadNamePrefix
KafkaScheduler
threads
KafkaRequestHandlerPool KafkaScheduler
threadsafe
utils
throttleDown
Throttler
time
PartitionOffsetRequestInfo KafkaTimer Throttler
timestamp
OffsetAndMetadata
toBroker
RequestSendThread
toBytes
DefaultEncoder Encoder NullEncoder StringEncoder
toProps
LogConfig
toString
ControlledShutdownRequest FetchRequest LeaderAndIsr LeaderAndIsrRequest OffsetCommitRequest OffsetFetchRequest OffsetRequest PartitionMetadata PartitionOffsetsResponse PartitionStateInfo ProducerRequest StopReplicaRequest TopicMetadata TopicMetadataRequest UpdateMetadataRequest Broker Partition Replica ClientIdAllBrokers ClientIdAllTopics ClientIdAndBroker ClientIdAndTopic OffsetAndMetadata OffsetMetadataAndError TopicAndPartition ConsumerThreadId KafkaStream PartitionTopicInfo TopicFilter LeaderIsrAndControllerEpoch PartitionAndReplica ConsumerMetadataResponse FetchRequest OffsetCommitRequest OffsetFetchRequest OffsetRequest OffsetResponse PartitionMetadata TopicMetadata TopicMetadataRequest TopicMetadataResponse ByteBufferMessageSet Log LogSegment Message MessageSet ClientIdTopicPartition DelayedProduceResponseStatus GroupTopicPartition LogOffsetMetadata TestRecord VerifiableProperties
tools
kafka
topic
TopicData TopicMetadata Partition Replica ClientIdAndTopic TopicAndPartition PartitionTopicInfo PartitionAndReplica TopicMetadata MessageAndMetadata KafkaLog4jAppender KeyedMessage PartitionAndLeader ClientIdTopicPartition LineMessageReader ProducerConfig ConsumerPerfConfig ConsumerPerfConfig StateChangeLogMerger TestRecord
topicAndKey
TestRecord
topicAndPartition
Log
topicConfigManager
KafkaServer
topicConfigs
LogManager
topicData
TopicDataSend
topicEventListener
ZkSessionExpireListener
topicExists
AdminUtils
topicInfo
FetchedDataChunk
topicMetadataRefreshIntervalMs
ProducerConfig
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
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