Ignore
LogEndOffsetResult
IllegalGroupGenerationId
OffsetMetadataAndError
IllegalQueueStateException
async
ImportZkOffsets
tools
InactiveSensorExpirationTimeSeconds
ClientQuotaManagerConfig
InconsistentBrokerIdException
common
IndexFileSuffix
Log
IndexInterval
Defaults
IndexIntervalBytesProp
LogConfig
IndexIntervalDoc
LogConfig
InitialControllerEpoch
KafkaController
InitialControllerEpochZkVersion
KafkaController
InitialTaskDelayMs
LogManager
InterBrokerProtocolVersion
Defaults
InterBrokerProtocolVersionDoc
KafkaConfig
InterBrokerProtocolVersionProp
KafkaConfig
InterBrokerSecurityProtocol
Defaults
InterBrokerSecurityProtocolDoc
KafkaConfig
InterBrokerSecurityProtocolProp
KafkaConfig
InternalTopics
Topic
InvalidConfigException
common
InvalidFetchSizeCode
ErrorMapping
InvalidMessageCode
ErrorMapping
InvalidMessageException
message
InvalidMessageSizeException
common
InvalidOffset
OffsetMetadata PartitionTopicInfo
InvalidOffsetException
common
InvalidOffsetMetadata
OffsetMetadata
InvalidRequestException
network
InvalidTopicCode
ErrorMapping
InvalidTopicException
common
IsInit
LeaderAndIsrRequest UpdateMetadataRequest
IsrChangeNotificationListener
controller
IsrChangeNotificationPath
ZkUtils
IsrChangePropagationBlackOut
ReplicaManager
IsrChangePropagationInterval
ReplicaManager
IteratorTemplate
utils
id
ApiVersion KAFKA_080 KAFKA_081 KAFKA_082 KAFKA_090 Broker BrokerEndPoint
ignoreError
LineMessageReader
immutable
utils
inLock
CoreUtils
inReadLock
CoreUtils
inSyncReplicas
Partition
inWriteLock
CoreUtils
inc
ConnectionQuotas
incrementControllerEpoch
KafkaController
index
LogSegment ZookeeperLeaderElector
indexFilename
Log
indexInterval
LogConfig
indexIntervalBytes
LogSegment
info
LogAppendResult LogReadResult Logging
init
ZkNodeChangeNotificationListener KafkaMetricsReporter ChecksumMessageFormatter LineMessageReader MessageReader DefaultMessageFormatter MessageFormatter NoOpMessageFormatter
initFileSize
Log
initOffset
BrokerAndInitialOffset
initialLeaderEpoch
LeaderAndIsr
initialMessageId
ProducerPerfConfig
initialMessageIdOpt
ProducerPerfConfig
initialZKVersion
LeaderAndIsr
initiateReassignReplicasForTopicPartition
KafkaController
initiateShutdown
ConsumerFetcherThread ShutdownableThread
inputTopic
Config
inputTopicOpt
Config
interBrokerProtocolVersion
KafkaConfig
interBrokerSecurityProtocol
KafkaConfig
ioBufferSize
CleanerConfig
ip
TooManyConnectionsException
isActive
KafkaController PartitionFetchState
isAnyReplicaInState
ReplicaStateMachine
isAtLeastOneReplicaInDeletionStartedState
ReplicaStateMachine
isCompleted
DelayedOperation
isConnected
BlockingChannel
isConsumerGroupActive
AdminUtils
isDeleteTopicEnabled
TopicDeletionManager
isEmpty
FetchRequest FetchRequest LineIterator
isEmptyAclAndAuthorized
SimpleAclAuthorizer
isFixedSize
ProducerPerfConfig
isFromDebuggingClient
OffsetRequest
isFromFollower
FetchRequest FetchMetadata
isFromLowLevelConsumer
FetchRequest
isFromOrdinaryClient
OffsetRequest
isFromOrdinaryConsumer
FetchRequest
isFull
OffsetIndex
isGroupLoading
GroupMetadataManager
isGroupLocal
GroupMetadataManager
isInterruptible
ShutdownableThread
isLoading
GroupMetadataManager
isLocal
Replica
isNull
Message
isOffsetInvalid
PartitionTopicInfo
isPartitionToBeDeleted
TopicDeletionManager
isReadFromLogEnd
LogReadResult
isRunning
ShutdownableThread
isSecure
ZkUtils
isShuttingDown
ReplicaManager
isStarted
KafkaScheduler Scheduler
isSuperUser
SimpleAclAuthorizer
isSync
DefaultEventHandler ProducerPerfConfig Config
isTopicAllowed
Blacklist TopicFilter Whitelist
isTopicDeletionInProgress
TopicDeletionManager
isTopicIneligibleForDeletion
TopicDeletionManager
isTopicQueuedUpForDeletion
TopicDeletionManager
isUnderReplicated
Partition
isValid
BrokerCompressionCodec Message
isValidBrokerId
Request
isWindows
Os
isr
LeaderAndIsr PartitionMetadata PartitionMetadata
isrChangeListener
ReassignedPartitionsContext
isrExpandRate
ReplicaManager
isrShrinkRate
ReplicaManager
iter
OldConsumer
iterator
KafkaStream ByteBufferMessageSet MessageSet FileMessageSet ByteBufferMessageSet MessageSet ByteBoundedBlockingQueue DoublyLinkedList Pool
itr
LineIterator