| Package | Description | 
|---|---|
| org.apache.storm.kafka | |
| org.apache.storm.kafka.trident | 
| Modifier and Type | Method and Description | 
|---|---|
static IBrokerReader | 
KafkaUtils.makeBrokerReader(Map stormConf,
                KafkaConfig conf)  | 
| Constructor and Description | 
|---|
DynamicPartitionConnections(KafkaConfig config,
                           IBrokerReader brokerReader)  | 
| Modifier and Type | Class and Description | 
|---|---|
class  | 
StaticBrokerReader  | 
class  | 
ZkBrokerReader  | 
Copyright © 2019 The Apache Software Foundation. All Rights Reserved.