Package | Description |
---|---|
storm.kafka | |
storm.kafka.trident |
Modifier and Type | Class and Description |
---|---|
class |
StaticHosts
Date: 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) |
Constructor and Description |
---|
TridentKafkaConfig(BrokerHosts hosts,
String topic) |
TridentKafkaConfig(BrokerHosts hosts,
String topic,
String clientId) |
Copyright © 2016 The Apache Software Foundation. All Rights Reserved.