storm-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From kabh...@apache.org
Subject [1/3] storm git commit: STORM-2552: KafkaSpoutMessageId should be serializable
Date Wed, 21 Jun 2017 23:06:29 GMT
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.ranga@flipkart.com>
Authored: Wed Jun 14 17:52:57 2017 +0530
Committer: Prasanna Ranganathan <prasanna.ranga@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


Mime
View raw message