Package | Description |
---|---|
org.apache.storm.kafka.spout.trident | |
org.apache.storm.kafka.spout.trident.internal | |
org.apache.storm.kafka.trident |
Modifier and Type | Method and Description |
---|---|
KafkaTridentSpoutConfig<K,V> |
KafkaTridentSpoutConfig.Builder.build() |
Constructor and Description |
---|
KafkaTridentSpoutCoordinator(KafkaTridentSpoutConfig<K,V> kafkaSpoutConfig)
Creates a new coordinator based on the given spout config.
|
KafkaTridentSpoutEmitter(KafkaTridentSpoutConfig<K,V> kafkaSpoutConfig,
TopologyContext topologyContext)
Create a new Kafka spout emitter.
|
KafkaTridentSpoutOpaque(KafkaTridentSpoutConfig<K,V> kafkaSpoutConfig)
Creates a new opaque transactional Trident Kafka spout.
|
KafkaTridentSpoutTransactional(KafkaTridentSpoutConfig<K,V> kafkaSpoutConfig)
Creates a new non-opaque transactional Trident Kafka spout.
|
Modifier and Type | Method and Description |
---|---|
<K,V> Fields |
OutputFieldsExtractor.getOutputFields(KafkaTridentSpoutConfig<K,V> kafkaSpoutConfig)
Extract the output fields from the config.
|
Modifier and Type | Method and Description |
---|---|
protected KafkaTridentSpoutConfig<String,String> |
TridentKafkaClientTopologyNamedTopics.newKafkaSpoutConfig(String bootstrapServers) |
protected KafkaTridentSpoutConfig<String,String> |
TridentKafkaClientTopologyWildcardTopics.newKafkaSpoutConfig(String bootstrapServers) |
Copyright © 2022 The Apache Software Foundation. All rights reserved.