Uses of Class
org.apache.storm.kafka.spout.trident.KafkaTridentSpoutConfig

Packages that use KafkaTridentSpoutConfig

Package	Description
org.apache.storm.kafka.spout.trident
org.apache.storm.kafka.spout.trident.internal
org.apache.storm.kafka.trident

Uses of KafkaTridentSpoutConfig in org.apache.storm.kafka.spout.trident

Methods in org.apache.storm.kafka.spout.trident that return KafkaTridentSpoutConfig

Modifier and Type	Method and Description
KafkaTridentSpoutConfig<K,V>	KafkaTridentSpoutConfig.Builder.build()

Constructors in org.apache.storm.kafka.spout.trident with parameters of type KafkaTridentSpoutConfig

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.

Uses of KafkaTridentSpoutConfig in org.apache.storm.kafka.spout.trident.internal

Methods in org.apache.storm.kafka.spout.trident.internal with parameters of type KafkaTridentSpoutConfig

Modifier and Type	Method and Description
<K,V> Fields	OutputFieldsExtractor.getOutputFields(KafkaTridentSpoutConfig<K,V> kafkaSpoutConfig) Extract the output fields from the config.

Uses of KafkaTridentSpoutConfig in org.apache.storm.kafka.trident

Methods in org.apache.storm.kafka.trident that return KafkaTridentSpoutConfig

Modifier and Type	Method and Description
protected KafkaTridentSpoutConfig<String,String>	TridentKafkaClientTopologyNamedTopics.newKafkaSpoutConfig(String bootstrapServers)
protected KafkaTridentSpoutConfig<String,String>	TridentKafkaClientTopologyWildcardTopics.newKafkaSpoutConfig(String bootstrapServers)