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:20 GMT
Repository: storm
Updated Branches:
  refs/heads/1.x-branch b00663386 -> dd206b663


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/9bbfdef7
Tree: http://git-wip-us.apache.org/repos/asf/storm/tree/9bbfdef7
Diff: http://git-wip-us.apache.org/repos/asf/storm/diff/9bbfdef7

Branch: refs/heads/1.x-branch
Commit: 9bbfdef74b60b065be96093b1b1521f0bea50b8a
Parents: b006633
Author: Prasanna Ranganathan <prasanna.ranga@flipkart.com>
Authored: Wed Jun 14 17:52:57 2017 +0530
Committer: Jungtaek Lim <kabhwan@gmail.com>
Committed: Thu Jun 22 08:05:43 2017 +0900

----------------------------------------------------------------------
 .../storm/kafka/spout/KafkaSpoutMessageId.java      | 16 ++++++++++------
 1 file changed, 10 insertions(+), 6 deletions(-)
----------------------------------------------------------------------


http://git-wip-us.apache.org/repos/asf/storm/blob/9bbfdef7/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 a9163eb..59a25c2 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,15 +18,19 @@
 
 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;
-    private boolean emitted;   // true if the record was emitted using a form of collector.emit(...).
-                               // false when skipping null tuples as configured by the user
in KafkaSpoutConfig
+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
+     */
+    private boolean emitted;
 
     public KafkaSpoutMessageId(ConsumerRecord<?, ?> consumerRecord) {
         this(consumerRecord, true);


Mime
View raw message