Uses of Class
org.apache.storm.kafka.spout.trident.KafkaTridentSpoutConfig
Packages that use KafkaTridentSpoutConfig
Package
Description
-
Uses of KafkaTridentSpoutConfig in org.apache.storm.kafka.spout.trident
Methods in org.apache.storm.kafka.spout.trident that return KafkaTridentSpoutConfigConstructors in org.apache.storm.kafka.spout.trident with parameters of type KafkaTridentSpoutConfigModifierConstructorDescriptionKafkaTridentSpoutCoordinator
(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 KafkaTridentSpoutConfigModifier and TypeMethodDescription<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 KafkaTridentSpoutConfigModifier and TypeMethodDescriptionprotected KafkaTridentSpoutConfig<String,
String> TridentKafkaClientTopologyNamedTopics.newKafkaSpoutConfig
(String bootstrapServers) protected KafkaTridentSpoutConfig<String,
String> TridentKafkaClientTopologyWildcardTopics.newKafkaSpoutConfig
(String bootstrapServers)