handle
DefaultEventHandler EventHandler KafkaApis
handleChildChange
ZkTopicEventListener DeleteTopicsListener TopicChangeListener BrokerChangeListener ConfigChangeListener
handleConsumerMetadataRequest
KafkaApis
handleControlledShutdownRequest
KafkaApis
handleDataChange
PartitionsReassignedListener AddPartitionsListener PreferredReplicaElectionListener ReassignedPartitionsIsrChangeListener LeaderChangeListener
handleDataDeleted
PartitionsReassignedListener AddPartitionsListener DeleteTopicsListener 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
handler
ProducerSendThread
handleStateChange
ReplicaStateMachine
handleStateChanged
ZkSessionExpireListener SessionExpirationListener SessionExpireListener
handleStateChanges
PartitionStateMachine ReplicaStateMachine
handleStopReplicaRequest
KafkaApis
handleTopicEvent
TopicEventHandler
handleTopicMetadataRequest
KafkaApis
handleUpdateMetadataRequest
KafkaApis
hasError
FetchResponse OffsetCommitResponse OffsetResponse ProducerResponse FetchResponse OffsetCommitResponse OffsetResponse
hashAlgorithm
CleanerConfig SkimpyOffsetMap
hashCode
ReassignmentCompleted ReassignmentFailed ReassignmentInProgress ConsumerMetadataRequest ConsumerMetadataResponse ControlledShutdownRequest ControlledShutdownResponse FetchRequest FetchResponse FetchResponsePartitionData HeartbeatRequestAndHeader HeartbeatResponseAndHeader JoinGroupRequestAndHeader JoinGroupResponseAndHeader LeaderAndIsr LeaderAndIsrRequest LeaderAndIsrResponse OffsetCommitRequest OffsetCommitResponse OffsetFetchRequest OffsetFetchResponse OffsetRequest OffsetResponse PartitionFetchInfo PartitionMetadata PartitionOffsetRequestInfo PartitionOffsetsResponse PartitionStateInfo ProducerRequest ProducerResponse ProducerResponseStatus StopReplicaRequest StopReplicaResponse TopicData TopicMetadata TopicMetadataRequest TopicMetadataResponse UpdateMetadataRequest UpdateMetadataResponse Broker Partition Replica ClientIdAllBrokers ClientIdAllTopics ClientIdAndBroker ClientIdAndTopic OffsetAndMetadata OffsetMetadataAndError TopicAndPartition Blacklist ConsumerThreadId FetchedDataChunk Whitelist ControllerBrokerStateInfo StateChangeLogger LeaderIsrAndControllerEpoch NewPartition NewReplica NonExistentPartition NonExistentReplica OfflinePartition OfflineReplica OnlinePartition OnlineReplica PartitionAndReplica ReassignedPartitionsContext ReplicaDeletionIneligible ReplicaDeletionStarted ReplicaDeletionSuccessful StopReplicaRequestInfo ConsumerMetadataResponse FetchRequest FetchResponse ByteBufferMessageSet OffsetCommitRequest OffsetFetchRequest OffsetRequest OffsetResponse TopicMetadataResponse CleanerConfig LogAppendInfo LogConfig OffsetPosition ByteBufferMessageSet DefaultCompressionCodec GZIPCompressionCodec LZ4CompressionCodec Message MessageAndMetadata MessageAndOffset NoCompressionCodec SnappyCompressionCodec CloseConnectionAction NoOpAction Request Response SendAction KeyedMessage PartitionAndLeader BrokerAndFetcherId BrokerAndInitialOffset BrokerShuttingDown BrokerState ClientIdTopicPartition DelayedProduceResponseStatus FetchDataInfo GroupTopicPartition ProduceResult LogOffsetMetadata NotRunning OffsetManagerConfig PartitionDataAndOffset PendingControlledShutdown RecoveringFromUncleanShutdown RunningAsBroker RunningAsController Starting TestRecord Utils
hasKey
Message KeyedMessage
hasNext
IteratorTemplate
headerSize
FetchResponse FetchResponsePartitionData TopicData
HeartbeatKey
RequestKeys
HeartbeatRequestAndHeader
api
HeartbeatResponseAndHeader
api
helpOpt
TopicCommandOptions PerfConfig
hideHeader
ConsumerPerfConfig ProducerPerfConfig ConsumerPerfConfig
hideHeaderOpt
PerfConfig
highWatermark
FetchResponse Replica FetchResponse
highWatermark_=
Replica
highWatermarkCheckpoints
ReplicaManager
HighWatermarkFilename
ReplicaManager
host
Broker SimpleConsumer SimpleConsumer BlockingChannel ConnectionConfig SocketServer SyncProducerConfig
hostName
KafkaConfig
HoursPerDay
Time
hw
FetchResponsePartitionData