Uses of Class
org.apache.storm.kafka.spout.ByTopicRecordTranslator

Packages that use ByTopicRecordTranslator

Package	Description
org.apache.storm.kafka.spout

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

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

Modifier and Type	Method and Description
ByTopicRecordTranslator<K,V>	ByTopicRecordTranslator.forTopic(String topic, Func<org.apache.kafka.clients.consumer.ConsumerRecord<K,V>,List<Object>> func, Fields fields) Configure a translator for a given topic with tuples to be emitted to the default stream.
ByTopicRecordTranslator<K,V>	ByTopicRecordTranslator.forTopic(String topic, Func<org.apache.kafka.clients.consumer.ConsumerRecord<K,V>,List<Object>> func, Fields fields, String stream) Configure a translator for a given topic.
ByTopicRecordTranslator<K,V>	ByTopicRecordTranslator.forTopic(String topic, RecordTranslator<K,V> translator) Configure a translator for a given kafka topic.