Repository: storm Updated Branches: refs/heads/master ef283a17b -> 648f0d6e3
STORM-2552: KafkaSpoutMessageId should be serializable Project: http://git-wip-us.apache.org/repos/asf/storm/repo Commit: http://git-wip-us.apache.org/repos/asf/storm/commit/b0258d5e Tree: http://git-wip-us.apache.org/repos/asf/storm/tree/b0258d5e Diff: http://git-wip-us.apache.org/repos/asf/storm/diff/b0258d5e Branch: refs/heads/master Commit: b0258d5e38b5bafd43f19bc109d7ae3488379460 Parents: 38e997e Author: Prasanna Ranganathan <prasanna.ra...@flipkart.com> Authored: Wed Jun 14 17:52:57 2017 +0530 Committer: Prasanna Ranganathan <prasanna.ra...@flipkart.com> Committed: Wed Jun 21 18:19:16 2017 +0530 ---------------------------------------------------------------------- .../org/apache/storm/kafka/spout/KafkaSpoutMessageId.java | 9 +++++---- 1 file changed, 5 insertions(+), 4 deletions(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/storm/blob/b0258d5e/external/storm-kafka-client/src/main/java/org/apache/storm/kafka/spout/KafkaSpoutMessageId.java ---------------------------------------------------------------------- diff --git a/external/storm-kafka-client/src/main/java/org/apache/storm/kafka/spout/KafkaSpoutMessageId.java b/external/storm-kafka-client/src/main/java/org/apache/storm/kafka/spout/KafkaSpoutMessageId.java index 1a60723..b802a52 100644 --- a/external/storm-kafka-client/src/main/java/org/apache/storm/kafka/spout/KafkaSpoutMessageId.java +++ b/external/storm-kafka-client/src/main/java/org/apache/storm/kafka/spout/KafkaSpoutMessageId.java @@ -18,13 +18,14 @@ package org.apache.storm.kafka.spout; +import java.io.Serializable; import org.apache.kafka.clients.consumer.ConsumerRecord; import org.apache.kafka.common.TopicPartition; -public class KafkaSpoutMessageId { - private final transient TopicPartition topicPart; - private final transient long offset; - private transient int numFails = 0; +public class KafkaSpoutMessageId implements Serializable { + private final TopicPartition topicPart; + private final long offset; + private int numFails = 0; /** * true if the record was emitted using a form of collector.emit(...). false * when skipping null tuples as configured by the user in KafkaSpoutConfig
