ThreadShutdownException
common
ThrottledRequestReaper
ClientQuotaManager
Throttler
utils
Time
utils
Timer
timer
TimerTask
timer
TooManyConnectionsException
network
ToolsUtils
utils
Topic
common auth ConfigType
TopicAlreadyMarkedForDeletionException
common
TopicAndPartition
common
TopicAuthorizationCode
ErrorMapping
TopicAuthorizationException
common
TopicChangeListener
PartitionStateMachine
TopicCommand
admin
TopicCommandOptions
TopicCommand
TopicConfigHandler
server
TopicData
api
TopicDataSend
api
TopicDeletionManager
controller
TopicDoc
ConsumerGroupCommandOptions
TopicEventHandler
consumer
TopicExistsException
common
TopicFilter
consumer
TopicMetadata
api javaapi
TopicMetadataRequest
api javaapi
TopicMetadataResponse
api javaapi
TopicPartitionOperationKey
server
tags
Partition ConsumerTopicMetrics FetchRequestAndResponseMetrics Log RequestMetrics ProducerRequestMetrics ProducerStats ProducerTopicMetrics BrokerTopicMetrics FetcherStats
take
ByteBoundedBlockingQueue
targetCodec
LogAppendInfo
tcpNoDelay
ConnectionConfig
threadId
ConsumerThreadId MirrorMakerThread ProducerThread
threadName
ProducerSendThread
threadNamePrefix
KafkaScheduler
threads
KafkaRequestHandlerPool KafkaScheduler
threadsafe
utils
throttleDown
Throttler
throttleTime
ProducerResponse
throttleTimeHist
RequestMetrics
throttleTimeMs
FetchResponse
throttleTimeStats
FetchRequestAndResponseMetrics ProducerRequestMetrics
throttledRequestReaper
ClientQuotaManager
throwException
Log
time
AdminClient PartitionOffsetRequestInfo RequestSendThread KafkaTimer SocketServer Throttler
timeoutMs
NewShinyConsumer ConsumerConfig
timeoutMsOpt
ConsumerConfig
timer
utils
toByteBufferMessageSet
PartitionData PartitionData
toBytes
DefaultEncoder Encoder NullEncoder StringEncoder
toJsonCompatibleMap
Acl
toMap
Acl
toResourcePath
SimpleAclAuthorizer
toString
ApiVersion ControlledShutdownRequest FetchRequest LeaderAndIsr LeaderAndIsrRequest OffsetCommitRequest OffsetFetchRequest OffsetRequest PartitionMetadata PartitionOffsetsResponse PartitionStateInfo ProducerRequest StopReplicaRequest TopicMetadata TopicMetadataRequest UpdateMetadataRequest Broker Partition Replica ClientIdAllBrokers ClientIdAllTopics ClientIdAndBroker ClientIdAndTopic OffsetAndMetadata OffsetMetadata OffsetMetadataAndError TopicAndPartition ConsumerThreadId KafkaStream PartitionTopicInfo TopicFilter LeaderIsrAndControllerEpoch PartitionAndReplica GroupMetadataKey GroupTopicPartition OffsetKey FetchRequest GroupCoordinatorResponse OffsetCommitRequest OffsetFetchRequest OffsetRequest OffsetResponse PartitionMetadata TopicMetadata TopicMetadataRequest TopicMetadataResponse ByteBufferMessageSet Log LogSegment Message MessageSet Acl Resource BecomeLeaderOrFollowerResult ClientIdTopicPartition FetchMetadata FetchPartitionStatus LogOffsetMetadata LogReadResult PartitionFetchState ProduceMetadata ProducePartitionStatus VerifiableProperties
tools
kafka
topic
TopicData TopicMetadata Partition Replica ClientIdAndTopic TopicAndPartition BaseConsumerRecord PartitionTopicInfo PartitionAndReplica TopicMetadata MessageAndMetadata KeyedMessage PartitionAndLeader ClientIdTopicPartition TopicPartitionOperationKey LineMessageReader ProducerConfig ConsumerPerfConfig ConsumerPerfConfig StateChangeLogMerger
topicAndPartition
Log
topicArg
ConsumerConfig
topicConfigs
LogManager
topicData
TopicDataSend
topicEventListener
ZkSessionExpireListener
topicExists
AdminUtils
topicIdOpt
ConsumerConfig
topicInfo
FetchedDataChunk
topicMetadataRefreshIntervalMs
ProducerConfig
topicOpt
AclCommandOptions ConsumerGroupCommandOptions 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
totalFetchRequestRate
BrokerTopicMetrics
totalHandlerThreads
KafkaRequestHandler
totalMessagesSent
ProducerThread
totalProduceRequestRate
BrokerTopicMetrics
totalTimeHist
RequestMetrics
trace
Logging
triggerOnlinePartitionStateChange
PartitionStateMachine
trim
FileMessageSet
trimToValidSize
OffsetIndex
truncate
OffsetIndex
truncateFullyAndStartAt
LogManager
truncateTo
FileMessageSet LogManager LogSegment OffsetIndex
tryComplete
DelayedFetch DelayedOperation DelayedProduce
tryCompleteDelayedFetch
ReplicaManager
tryCompleteDelayedProduce
ReplicaManager
tryCompleteElseWatch
DelayedOperationPurgatory
tryCompleteHeartbeat
GroupCoordinator
tryCompleteJoin
GroupCoordinator
tryLock
FileLock
tryParse
ConsumerConfig
tryToHandle
ProducerSendThread