Package | Description |
---|---|
org.apache.storm.kafka | |
org.apache.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)
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 © 2019 The Apache Software Foundation. All Rights Reserved.