Uses of Class
org.apache.storm.kafka.spout.ByTopicRecordTranslator
Packages that use ByTopicRecordTranslator
-
Uses of ByTopicRecordTranslator in org.apache.storm.kafka.spout
Methods in org.apache.storm.kafka.spout that return ByTopicRecordTranslatorModifier and TypeMethodDescriptionByTopicRecordTranslator.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.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.forTopic
(String topic, RecordTranslator<K, V> translator) Configure a translator for a given kafka topic.