Package | Description |
---|---|
org.apache.storm.kafka.spout.trident |
Modifier and Type | Method and Description |
---|---|
static KafkaTridentSpoutConfig.Builder<String,String> |
KafkaTridentSpoutConfig.builder(String bootstrapServers,
Pattern topics)
Factory method that creates a Builder with String key/value deserializers.
|
static KafkaTridentSpoutConfig.Builder<String,String> |
KafkaTridentSpoutConfig.builder(String bootstrapServers,
Set<String> topics)
Factory method that creates a Builder with String key/value deserializers.
|
static KafkaTridentSpoutConfig.Builder<String,String> |
KafkaTridentSpoutConfig.builder(String bootstrapServers,
String... topics)
Factory method that creates a Builder with String key/value deserializers.
|
Constructor and Description |
---|
KafkaTridentSpoutConfig(KafkaTridentSpoutConfig.Builder<K,V> builder) |
Copyright © 2019 The Apache Software Foundation. All rights reserved.