Class TopicPartitionSerializer
java.lang.Object
org.apache.storm.kafka.spout.trident.TopicPartitionSerializer
-
Field Summary
-
Constructor Summary
-
Method Summary
Modifier and TypeMethodDescriptionorg.apache.kafka.common.TopicPartition
Deserializes the given map into a TopicPartition.toMap
(org.apache.kafka.common.TopicPartition topicPartition) Serializes the given TopicPartition to Map so Trident can serialize it to JSON.
-
Field Details
-
TOPIC_PARTITION_TOPIC_KEY
- See Also:
-
TOPIC_PARTITION_PARTITION_KEY
- See Also:
-
-
Constructor Details
-
TopicPartitionSerializer
public TopicPartitionSerializer()
-
-
Method Details
-
toMap
Serializes the given TopicPartition to Map so Trident can serialize it to JSON. -
fromMap
Deserializes the given map into a TopicPartition. The map keys are expected to be those produced bytoMap(org.apache.kafka.common.TopicPartition)
.
-