storm-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From kabh...@apache.org
Subject [01/11] storm git commit: Added Kafka Topic as Stream ID for emitted tuples
Date Tue, 25 Aug 2015 03:05:19 GMT
Repository: storm
Updated Branches:
  refs/heads/master 949da3853 -> 528958c27


Added Kafka Topic as Stream ID for emitted tuples


Project: http://git-wip-us.apache.org/repos/asf/storm/repo
Commit: http://git-wip-us.apache.org/repos/asf/storm/commit/3ba9aba3
Tree: http://git-wip-us.apache.org/repos/asf/storm/tree/3ba9aba3
Diff: http://git-wip-us.apache.org/repos/asf/storm/diff/3ba9aba3

Branch: refs/heads/master
Commit: 3ba9aba3983ac14fe6b25e74e05aa24cb1e9e44e
Parents: 544e55c
Author: rohan_agarwal <rohanag12@gmail.com>
Authored: Fri Aug 7 17:03:22 2015 +0530
Committer: rohan_agarwal <rohanag12@gmail.com>
Committed: Fri Aug 7 17:03:22 2015 +0530

----------------------------------------------------------------------
 external/storm-kafka/src/jvm/storm/kafka/PartitionManager.java | 2 +-
 1 file changed, 1 insertion(+), 1 deletion(-)
----------------------------------------------------------------------


http://git-wip-us.apache.org/repos/asf/storm/blob/3ba9aba3/external/storm-kafka/src/jvm/storm/kafka/PartitionManager.java
----------------------------------------------------------------------
diff --git a/external/storm-kafka/src/jvm/storm/kafka/PartitionManager.java b/external/storm-kafka/src/jvm/storm/kafka/PartitionManager.java
index ce18677..e72cf3c 100644
--- a/external/storm-kafka/src/jvm/storm/kafka/PartitionManager.java
+++ b/external/storm-kafka/src/jvm/storm/kafka/PartitionManager.java
@@ -138,7 +138,7 @@ public class PartitionManager {
             Iterable<List<Object>> tups = KafkaUtils.generateTuples(_spoutConfig,
toEmit.msg);
             if (tups != null) {
                 for (List<Object> tup : tups) {
-                    collector.emit(tup, new KafkaMessageId(_partition, toEmit.offset));
+                    collector.emit(_spoutConfig.topic, tup, new KafkaMessageId(_partition,
toEmit.offset));
                 }
                 break;
             } else {


Mime
View raw message