NOT_READY
utils
NetworkClientBlockingOps
utils
NewConsumerDoc
ConsumerGroupCommandOptions
NewPartition
controller
NewReplica
controller
NewShinyConsumer
consumer
NewShinyProducer
producer
Newline
AclCommand
NoBrokersForPartitionException
common
NoCompression
Message
NoCompressionCodec
message
NoEpochForPartitionException
common
NoError
ErrorMapping
NoLeader
LeaderAndIsr GroupCoordinator
NoLeaderNodeId
TopicMetadata
NoMembers
GroupCoordinator
NoMetadata
OffsetMetadata
NoOffset
OffsetMetadataAndError
NoOpAction
RequestChannel
NoOpLeaderSelector
controller
NoOpMessageFormatter
tools
NoProtocol
GroupCoordinator
NoProtocolType
GroupCoordinator
NoReplicaOnlineException
common
NoState
GroupCoordinator
NodeChangeListener
ZkNodeChangeNotificationListener
NonExistentPartition
controller
NonExistentReplica
controller
NotAssignedReplicaException
common
NotCoordinatorForConsumerCode
ErrorMapping
NotCoordinatorForConsumerException
common
NotCoordinatorForGroup
OffsetMetadataAndError
NotEnoughReplicasAfterAppendCode
ErrorMapping
NotEnoughReplicasAfterAppendException
common
NotEnoughReplicasCode
ErrorMapping
NotEnoughReplicasException
common
NotInit
LeaderAndIsrRequest UpdateMetadataRequest
NotLeaderForPartitionCode
ErrorMapping
NotLeaderForPartitionException
common
NotRunning
server
NotificationHandler
common
NsPerMs
Time
NsPerSec
Time
NsPerUs
Time
NullEncoder
serializer
NumConsumerFetchers
ConsumerConfig
NumIoThreads
Defaults
NumIoThreadsDoc
KafkaConfig
NumIoThreadsProp
KafkaConfig
NumNetworkThreads
Defaults
NumNetworkThreadsDoc
KafkaConfig
NumNetworkThreadsProp
KafkaConfig
NumPartitions
Defaults
NumPartitionsDoc
KafkaConfig
NumPartitionsProp
KafkaConfig
NumQuotaSamples
Defaults
NumQuotaSamplesDoc
KafkaConfig
NumQuotaSamplesProp
KafkaConfig
NumRecoveryThreadsPerDataDir
Defaults
NumRecoveryThreadsPerDataDirDoc
KafkaConfig
NumRecoveryThreadsPerDataDirProp
KafkaConfig
NumReplicaFetchers
Defaults
NumReplicaFetchersDoc
KafkaConfig
NumReplicaFetchersProp
KafkaConfig
name
BaseEnum Log BrokerCompressionCodec CompressionCodec DefaultCompressionCodec GZIPCompressionCodec LZ4CompressionCodec NoCompressionCodec ProducerCompressionCodec SnappyCompressionCodec UncompressedCodec All Allow Alter Cluster ClusterAction Create Delete Deny Describe Group Read Resource Topic Write AbstractFetcherManager Os ShutdownableThread
nameForKey
RequestKeys
nanoseconds
SystemTime Time
network
kafka
networkClient
ControllerBrokerStateInfo RequestSendThread
networkClientBlockingOps
NetworkClientBlockingOps
newBatch
ControllerBrokerRequestBatch
newConsumerOpt
ConsumerGroupCommandOptions
newGauge
KafkaMetricsGroup
newHistogram
KafkaMetricsGroup
newMeter
KafkaMetricsGroup
newReplicas
ReassignedPartitionsContext
newState
BrokerState
newTimer
KafkaMetricsGroup
next
ConsumerIterator Segment DoublyLinkedListNode IteratorTemplate
nextOffset
LogSegment MessageAndOffset
nextOffsetMetadata
Log
nl
ConfigCommandOptions ConsumerGroupCommandOptions TopicCommandOptions
noOperation
RequestChannel
nonthreadsafe
utils
numConsumerFetchers
ConsumerConfig
numFetchersOpt
ConsumerPerfConfig
numIoThreads
KafkaConfig
numMessages
ConsumerPerfConfig ProducerPerfConfig Config ConsumerPerfConfig
numMessagesOpt
PerfConfig Config
numNetworkThreads
KafkaConfig
numPartitions
FetchRequest ProducerRequest KafkaConfig
numProcessors
RequestChannel
numQuotaSamples
ClientQuotaManagerConfig KafkaConfig
numRecoveryThreadsPerDataDir
KafkaConfig
numReplicaFetchers
KafkaConfig
numThreads
CleanerConfig ConsumerPerfConfig ProducerPerfConfig Config
numThreadsOpt
ConsumerPerfConfig ProducerPerfConfig Config
numberOfSegments
Log