| Package | Description | 
|---|---|
| org.apache.storm.kafka | |
| org.apache.storm.kafka.trident | 
| Modifier and Type | Class and Description | 
|---|---|
| class  | StaticHostsDate: 11/05/2013 Time: 14:43 | 
| class  | ZkHosts | 
| Modifier and Type | Field and Description | 
|---|---|
| BrokerHosts | KafkaConfig. hosts | 
| Constructor and Description | 
|---|
| KafkaConfig(BrokerHosts hosts,
           String topic) | 
| KafkaConfig(BrokerHosts hosts,
           String topic,
           String clientId) | 
| SpoutConfig(BrokerHosts hosts,
           String topic,
           String zkRoot,
           String id)Create a SpoutConfig without setting client.id, which can make the source application ambiguous when tracing Kafka calls. | 
| SpoutConfig(BrokerHosts hosts,
           String topic,
           String clientId,
           String zkRoot,
           String id)Create a SpoutConfig with a client.id value. | 
| Constructor and Description | 
|---|
| TridentKafkaConfig(BrokerHosts hosts,
                  String topic) | 
| TridentKafkaConfig(BrokerHosts hosts,
                  String topic,
                  String clientId) | 
Copyright © 2022 The Apache Software Foundation. All Rights Reserved.