HeartbeatKey
RequestKeys
HighWatermarkFilename
ReplicaManager
HostName
Defaults
HostNameDoc
KafkaConfig
HostNameProp
KafkaConfig
HostsKey
Acl
HoursPerDay
Time
handle
DefaultEventHandler EventHandler KafkaApis MirrorMakerMessageHandler
handleChildChange
NodeChangeListener ZkTopicEventListener IsrChangeNotificationListener DeleteTopicsListener TopicChangeListener BrokerChangeListener ConfigChangeListener
handleCommitOffsets
GroupCoordinator
handleControlledShutdownRequest
KafkaApis
handleDataChange
AddPartitionsListener PartitionsReassignedListener PreferredReplicaElectionListener ReassignedPartitionsIsrChangeListener LeaderChangeListener
handleDataDeleted
AddPartitionsListener DeleteTopicsListener PartitionsReassignedListener PreferredReplicaElectionListener ReassignedPartitionsIsrChangeListener LeaderChangeListener
handleDescribeGroup
GroupCoordinator
handleDescribeGroupRequest
KafkaApis
handleError
ControlledShutdownRequest FetchRequest GroupCoordinatorRequest LeaderAndIsrRequest OffsetCommitRequest OffsetFetchRequest OffsetRequest ProducerRequest RequestOrResponse StopReplicaRequest TopicMetadataRequest UpdateMetadataRequest
handleFetchOffsets
GroupCoordinator
handleFetchRequest
KafkaApis
handleGroupCoordinatorRequest
KafkaApis
handleGroupEmigration
GroupCoordinator
handleGroupImmigration
GroupCoordinator
handleHeartbeat
GroupCoordinator
handleHeartbeatRequest
KafkaApis
handleJoinGroup
GroupCoordinator
handleJoinGroupRequest
KafkaApis
handleLeaderAndIsrRequest
KafkaApis
handleLeaveGroup
GroupCoordinator
handleLeaveGroupRequest
KafkaApis
handleListGroups
GroupCoordinator
handleListGroupsRequest
KafkaApis
handleNewSession
ZkSessionExpireListener SessionExpirationListener ZkStateChangeListener SessionExpireListener
handleOffsetCommitRequest
KafkaApis
handleOffsetFetchRequest
KafkaApis
handleOffsetOutOfRange
ConsumerFetcherThread AbstractFetcherThread ReplicaFetcherThread
handleOffsetRequest
KafkaApis
handlePartitionsWithErrors
ConsumerFetcherThread AbstractFetcherThread ReplicaFetcherThread
handleProducerRequest
KafkaApis
handleSessionEstablishmentError
ZkSessionExpireListener SessionExpirationListener ZkStateChangeListener SessionExpireListener
handleStateChange
ReplicaStateMachine
handleStateChanged
ZkSessionExpireListener SessionExpirationListener ZkStateChangeListener SessionExpireListener
handleStateChanges
PartitionStateMachine ReplicaStateMachine
handleStopReplicaRequest
KafkaApis
handleSyncGroup
GroupCoordinator
handleSyncGroupRequest
KafkaApis
handleTopicEvent
TopicEventHandler
handleTopicMetadataRequest
KafkaApis
handleUpdateMetadataRequest
KafkaApis
handler
ProducerSendThread
hasCollision
Topic
hasCollisionChars
Topic
hasError
FetchResponse OffsetCommitResponse OffsetResponse ProducerResponse FetchResponse OffsetCommitResponse OffsetResponse
hasKey
Message KeyedMessage
hasNext
IteratorTemplate
hashAlgorithm
CleanerConfig SkimpyOffsetMap
hashCode
Partition Replica FetchRequest FetchResponse GroupCoordinatorResponse OffsetCommitRequest OffsetFetchRequest OffsetRequest OffsetResponse TopicMetadataResponse ByteBufferMessageSet ByteBufferMessageSet Message
header
Request
headerSize
FetchResponse FetchResponsePartitionData TopicData
headerSizeInBytes
FetchResponse
helpOpt
AclCommandOptions ConfigCommandOptions TopicCommandOptions PerfConfig
hideHeader
ConsumerPerfConfig ProducerPerfConfig ConsumerPerfConfig
hideHeaderOpt
PerfConfig
highWatermark
FetchResponse Replica PartitionData FetchResponse PartitionData
highWatermarkCheckpoints
ReplicaManager
highWatermark_=
Replica
host
BrokerEndPoint EndPoint SimpleConsumer SimpleConsumer BlockingChannel ConnectionConfig SyncProducerConfig Acl
hostName
KafkaConfig
hw
FetchResponsePartitionData LogReadResult