Class TopicPartitionSerializer

java.lang.Object
org.apache.storm.kafka.spout.trident.TopicPartitionSerializer

public class TopicPartitionSerializer extends Object
  • Field Details

  • Constructor Details

    • TopicPartitionSerializer

      public TopicPartitionSerializer()
  • Method Details

    • toMap

      public Map<String,Object> toMap(org.apache.kafka.common.TopicPartition topicPartition)
      Serializes the given TopicPartition to Map so Trident can serialize it to JSON.
    • fromMap

      public org.apache.kafka.common.TopicPartition fromMap(Map<String,Object> map)
      Deserializes the given map into a TopicPartition. The map keys are expected to be those produced by toMap(org.apache.kafka.common.TopicPartition).