Uses of Interface
org.apache.storm.kafka.spout.RecordTranslator

Packages that use RecordTranslator

Package	Description
org.apache.storm.kafka.spout

Uses of RecordTranslator in org.apache.storm.kafka.spout

Classes in org.apache.storm.kafka.spout that implement RecordTranslator

Modifier and Type	Class and Description
class	ByTopicRecordTranslator<K,V> Based off of a given Kafka topic a ConsumerRecord came from it will be translated to a Storm tuple and emitted to a given stream
class	DefaultRecordTranslator<K,V>
class	SimpleRecordTranslator<K,V>

Methods in org.apache.storm.kafka.spout that return RecordTranslator

Modifier and Type	Method and Description
RecordTranslator<K,V>	KafkaSpoutConfig.getTranslator()

Methods in org.apache.storm.kafka.spout with parameters of type RecordTranslator

Modifier and Type	Method and Description
ByTopicRecordTranslator<K,V>	ByTopicRecordTranslator.forTopic(String topic, RecordTranslator<K,V> translator) Configure a translator for a given kafka topic
KafkaSpoutConfig.Builder<K,V>	KafkaSpoutConfig.Builder.setRecordTranslator(RecordTranslator<K,V> translator)

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

Constructor and Description
ByTopicRecordTranslator(RecordTranslator<K,V> defaultTranslator)