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 2015/05/15 23:27:34 UTC
[14/27] storm git commit: KafkaBolt no longer tries to
map/process/send Tick Tuples to Kafka.
KafkaBolt no longer tries to map/process/send Tick Tuples to Kafka.
Project: http://git-wip-us.apache.org/repos/asf/storm/repo
Commit: http://git-wip-us.apache.org/repos/asf/storm/commit/62385d7b
Tree: http://git-wip-us.apache.org/repos/asf/storm/tree/62385d7b
Diff: http://git-wip-us.apache.org/repos/asf/storm/diff/62385d7b
Branch: refs/heads/0.10.x-branch
Commit: 62385d7b290ac3599546d73fbdd5880b1f53fc0d
Parents: 96f35cc
Author: Niels Basjes <nb...@bol.com>
Authored: Wed Oct 1 11:51:42 2014 +0200
Committer: P. Taylor Goetz <pt...@gmail.com>
Committed: Fri May 15 15:27:13 2015 -0400
----------------------------------------------------------------------
external/storm-kafka/src/jvm/storm/kafka/bolt/KafkaBolt.java | 4 ++++
1 file changed, 4 insertions(+)
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/storm/blob/62385d7b/external/storm-kafka/src/jvm/storm/kafka/bolt/KafkaBolt.java
----------------------------------------------------------------------
diff --git a/external/storm-kafka/src/jvm/storm/kafka/bolt/KafkaBolt.java b/external/storm-kafka/src/jvm/storm/kafka/bolt/KafkaBolt.java
index cf169dc..913843c 100644
--- a/external/storm-kafka/src/jvm/storm/kafka/bolt/KafkaBolt.java
+++ b/external/storm-kafka/src/jvm/storm/kafka/bolt/KafkaBolt.java
@@ -89,6 +89,10 @@ public class KafkaBolt<K, V> extends BaseRichBolt {
@Override
public void execute(Tuple input) {
+ if (input.isTick()) {
+ return; // Do not try to send ticks to Kafka
+ }
+
K key = null;
V message = null;
String topic = null;