HeartbeatKey
RequestKeys
HeartbeatRequestAndHeader
api
HeartbeatResponseAndHeader
api
HighWatermarkFilename
ReplicaManager
HoursPerDay
Time
handle
DefaultEventHandler EventHandler KafkaApis
handleChildChange
ZkTopicEventListener DeleteTopicsListener TopicChangeListener BrokerChangeListener ConfigChangeListener
handleConsumerMetadataRequest
KafkaApis
handleControlledShutdownRequest
KafkaApis
handleDataChange
AddPartitionsListener PartitionsReassignedListener PreferredReplicaElectionListener ReassignedPartitionsIsrChangeListener LeaderChangeListener
handleDataDeleted
AddPartitionsListener DeleteTopicsListener PartitionsReassignedListener PreferredReplicaElectionListener ReassignedPartitionsIsrChangeListener LeaderChangeListener
handleError
ConsumerMetadataRequest ControlledShutdownRequest FetchRequest HeartbeatRequestAndHeader JoinGroupRequestAndHeader LeaderAndIsrRequest OffsetCommitRequest OffsetFetchRequest OffsetRequest ProducerRequest RequestOrResponse StopReplicaRequest TopicMetadataRequest UpdateMetadataRequest
handleFetchRequest
KafkaApis
handleLeaderAndIsrRequest
KafkaApis
handleNewSession
ZkSessionExpireListener SessionExpirationListener SessionExpireListener
handleOffsetCommitRequest
KafkaApis
handleOffsetFetchRequest
KafkaApis
handleOffsetOutOfRange
ConsumerFetcherThread AbstractFetcherThread ReplicaFetcherThread
handleOffsetRequest
KafkaApis
handlePartitionsWithErrors
ConsumerFetcherThread AbstractFetcherThread ReplicaFetcherThread
handleProducerOrOffsetCommitRequest
KafkaApis
handleStateChange
ReplicaStateMachine
handleStateChanged
ZkSessionExpireListener SessionExpirationListener SessionExpireListener
handleStateChanges
PartitionStateMachine ReplicaStateMachine
handleStopReplicaRequest
KafkaApis
handleTopicEvent
TopicEventHandler
handleTopicMetadataRequest
KafkaApis
handleUpdateMetadataRequest
KafkaApis
handler
ProducerSendThread
hasError
FetchResponse OffsetCommitResponse OffsetResponse ProducerResponse FetchResponse OffsetCommitResponse OffsetResponse
hasKey
Message KeyedMessage
hasNext
IteratorTemplate
hashAlgorithm
CleanerConfig SkimpyOffsetMap
hashCode
Broker Partition Replica ConsumerMetadataResponse FetchRequest FetchResponse OffsetCommitRequest OffsetFetchRequest OffsetRequest OffsetResponse TopicMetadataResponse ByteBufferMessageSet ByteBufferMessageSet Message
hashcode
Utils
headerSize
FetchResponse FetchResponsePartitionData TopicData
helpOpt
TopicCommandOptions PerfConfig
hideHeader
ConsumerPerfConfig ProducerPerfConfig ConsumerPerfConfig
hideHeaderOpt
PerfConfig
highWatermark
FetchResponse Replica FetchResponse
highWatermarkCheckpoints
ReplicaManager
highWatermark_=
Replica
host
Broker SimpleConsumer SimpleConsumer BlockingChannel ConnectionConfig SocketServer SyncProducerConfig
hostName
KafkaConfig
hw
FetchResponsePartitionData