You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@storm.apache.org by pt...@apache.org on 2016/05/24 20:38:29 UTC
[08/10] storm git commit: STORM-1848: Make KafkaMessageId and
Partition serializable to support eventlogging
STORM-1848: Make KafkaMessageId and Partition serializable to support eventlogging
Signed-off-by: P. Taylor Goetz <pt...@gmail.com>
Project: http://git-wip-us.apache.org/repos/asf/storm/repo
Commit: http://git-wip-us.apache.org/repos/asf/storm/commit/3265fba6
Tree: http://git-wip-us.apache.org/repos/asf/storm/tree/3265fba6
Diff: http://git-wip-us.apache.org/repos/asf/storm/diff/3265fba6
Branch: refs/heads/1.0.x-branch
Commit: 3265fba60c009bdc341abae9b8cbdbd02eaad9a8
Parents: c270ea8
Author: Stig Rohde D�ssing <sd...@it-minds.dk>
Authored: Wed May 18 13:13:15 2016 +0200
Committer: P. Taylor Goetz <pt...@gmail.com>
Committed: Tue May 24 16:34:37 2016 -0400
----------------------------------------------------------------------
.../storm-kafka/src/jvm/org/apache/storm/kafka/Partition.java | 3 ++-
.../src/jvm/org/apache/storm/kafka/PartitionManager.java | 4 ++--
2 files changed, 4 insertions(+), 3 deletions(-)
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/storm/blob/3265fba6/external/storm-kafka/src/jvm/org/apache/storm/kafka/Partition.java
----------------------------------------------------------------------
diff --git a/external/storm-kafka/src/jvm/org/apache/storm/kafka/Partition.java b/external/storm-kafka/src/jvm/org/apache/storm/kafka/Partition.java
index afdf8af..99bb9d3 100644
--- a/external/storm-kafka/src/jvm/org/apache/storm/kafka/Partition.java
+++ b/external/storm-kafka/src/jvm/org/apache/storm/kafka/Partition.java
@@ -18,10 +18,11 @@
package org.apache.storm.kafka;
import com.google.common.base.Objects;
+import java.io.Serializable;
import org.apache.storm.trident.spout.ISpoutPartition;
-public class Partition implements ISpoutPartition {
+public class Partition implements ISpoutPartition, Serializable {
public Broker host;
public int partition;
http://git-wip-us.apache.org/repos/asf/storm/blob/3265fba6/external/storm-kafka/src/jvm/org/apache/storm/kafka/PartitionManager.java
----------------------------------------------------------------------
diff --git a/external/storm-kafka/src/jvm/org/apache/storm/kafka/PartitionManager.java b/external/storm-kafka/src/jvm/org/apache/storm/kafka/PartitionManager.java
index 4fb5685..c20f237 100644
--- a/external/storm-kafka/src/jvm/org/apache/storm/kafka/PartitionManager.java
+++ b/external/storm-kafka/src/jvm/org/apache/storm/kafka/PartitionManager.java
@@ -19,6 +19,7 @@ package org.apache.storm.kafka;
import com.google.common.base.Strings;
import com.google.common.collect.ImmutableMap;
+import java.io.Serializable;
import org.apache.storm.Config;
import org.apache.storm.kafka.KafkaSpout.EmitState;
@@ -323,11 +324,10 @@ public class PartitionManager {
_connections.unregister(_partition.host, _partition.topic , _partition.partition);
}
- static class KafkaMessageId {
+ static class KafkaMessageId implements Serializable {
public Partition partition;
public long offset;
-
public KafkaMessageId(Partition partition, long offset) {
this.partition = partition;
this.offset = offset;