Package | Description |
---|---|
org.apache.storm.kafka.spout |
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> |
Modifier and Type | Method and Description |
---|---|
RecordTranslator<K,V> |
KafkaSpoutConfig.getTranslator() |
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) |
Constructor and Description |
---|
ByTopicRecordTranslator(RecordTranslator<K,V> defaultTranslator) |
Copyright © 2019 The Apache Software Foundation. All Rights Reserved.