| Interface | Description |
|---|---|
| BrokerHosts | |
| FailedMsgRetryManager | |
| KeyValueScheme | |
| MessageMetadataScheme | |
| PartitionCoordinator |
| Class | Description |
|---|---|
| Broker | |
| ByteBufferSerializer | |
| DynamicBrokersReader | |
| DynamicPartitionConnections | |
| ExponentialBackoffMsgRetryManager | |
| IntSerializer | |
| KafkaConfig | |
| KafkaSpout | Deprecated
storm-kafka has been deprecated and will be removed in a future Storm release.
|
| KafkaUtils | |
| KafkaUtils.KafkaOffsetMetric | |
| KeyValueSchemeAsMultiScheme | |
| MessageMetadataSchemeAsMultiScheme | |
| Partition | |
| PartitionManager | |
| PartitionManager.OffsetData | |
| SpoutConfig | |
| StaticCoordinator | |
| StaticHosts |
Date: 11/05/2013 Time: 14:43
|
| StaticPartitionConnections | |
| StringKeyValueScheme | |
| StringMessageAndMetadataScheme | |
| StringMultiSchemeWithTopic | |
| StringScheme | |
| ZkCoordinator | |
| ZkHosts | |
| ZkState |
| Enum | Description |
|---|---|
| KafkaError |
| Exception | Description |
|---|---|
| FailedFetchException | |
| TopicOffsetOutOfRangeException |
Copyright © 2019 The Apache Software Foundation. All Rights Reserved.