Added missing ack for the tick
Project: http://git-wip-us.apache.org/repos/asf/storm/repo Commit: http://git-wip-us.apache.org/repos/asf/storm/commit/cd47f1d6 Tree: http://git-wip-us.apache.org/repos/asf/storm/tree/cd47f1d6 Diff: http://git-wip-us.apache.org/repos/asf/storm/diff/cd47f1d6 Branch: refs/heads/master Commit: cd47f1d6e4165f8e3393aa5be01d02f4148c3216 Parents: 59b2a42 Author: Niels Basjes <[email protected]> Authored: Thu Oct 30 10:27:05 2014 +0100 Committer: Niels Basjes <[email protected]> Committed: Thu Oct 30 10:27:05 2014 +0100 ---------------------------------------------------------------------- external/storm-kafka/src/jvm/storm/kafka/bolt/KafkaBolt.java | 1 + 1 file changed, 1 insertion(+) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/storm/blob/cd47f1d6/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 2025766..7de25db 100644 --- a/external/storm-kafka/src/jvm/storm/kafka/bolt/KafkaBolt.java +++ b/external/storm-kafka/src/jvm/storm/kafka/bolt/KafkaBolt.java @@ -90,6 +90,7 @@ public class KafkaBolt<K, V> extends BaseRichBolt { @Override public void execute(Tuple input) { if (input.isTick()) { + collector.ack(input); return; // Do not try to send ticks to Kafka }
