Interface | Description |
---|---|
BrokerHosts | |
KeyValueScheme | |
PartitionCoordinator |
Class | Description |
---|---|
Broker | |
DynamicBrokersReader | |
DynamicPartitionConnections | |
KafkaConfig | |
KafkaSpout | |
KafkaSpout.MessageAndRealOffset | |
KafkaUtils | |
KafkaUtils.KafkaOffsetMetric | |
KeyValueSchemeAsMultiScheme | |
Partition | |
PartitionManager | |
SpoutConfig | |
StaticCoordinator | |
StaticHosts |
Date: 11/05/2013
Time: 14:43
|
StaticPartitionConnections | |
StringKeyValueScheme | |
StringScheme | |
ZkCoordinator | |
ZkHosts | |
ZkState |
Enum | Description |
---|---|
KafkaError |
Exception | Description |
---|---|
FailedFetchException | |
UpdateOffsetException |
Copyright © 2016 The Apache Software Foundation. All Rights Reserved.