Repository: camel Updated Branches: refs/heads/camel-2.15.x 990c6b579 -> 654db0d39 refs/heads/master 91ff7d0b6 -> 805db35b4
Polished Project: http://git-wip-us.apache.org/repos/asf/camel/repo Commit: http://git-wip-us.apache.org/repos/asf/camel/commit/e09c51d2 Tree: http://git-wip-us.apache.org/repos/asf/camel/tree/e09c51d2 Diff: http://git-wip-us.apache.org/repos/asf/camel/diff/e09c51d2 Branch: refs/heads/master Commit: e09c51d2d9d7a1d71bde9a5a626f3e86153748f2 Parents: 91ff7d0 Author: Claus Ibsen <davscl...@apache.org> Authored: Fri Aug 7 16:39:42 2015 +0200 Committer: Claus Ibsen <davscl...@apache.org> Committed: Fri Aug 7 16:39:42 2015 +0200 ---------------------------------------------------------------------- .../java/org/apache/camel/component/kafka/KafkaConsumer.java | 8 ++++---- 1 file changed, 4 insertions(+), 4 deletions(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/camel/blob/e09c51d2/components/camel-kafka/src/main/java/org/apache/camel/component/kafka/KafkaConsumer.java ---------------------------------------------------------------------- diff --git a/components/camel-kafka/src/main/java/org/apache/camel/component/kafka/KafkaConsumer.java b/components/camel-kafka/src/main/java/org/apache/camel/component/kafka/KafkaConsumer.java index 1657fa7..cb2dc9d 100644 --- a/components/camel-kafka/src/main/java/org/apache/camel/component/kafka/KafkaConsumer.java +++ b/components/camel-kafka/src/main/java/org/apache/camel/component/kafka/KafkaConsumer.java @@ -121,11 +121,11 @@ public class KafkaConsumer extends DefaultConsumer { class BatchingConsumerTask implements Runnable { private KafkaStream<byte[], byte[]> stream; - private CyclicBarrier berrier; + private CyclicBarrier barrier; - public BatchingConsumerTask(KafkaStream<byte[], byte[]> stream, CyclicBarrier berrier) { + public BatchingConsumerTask(KafkaStream<byte[], byte[]> stream, CyclicBarrier barrier) { this.stream = stream; - this.berrier = berrier; + this.barrier = barrier; } public void run() { @@ -160,7 +160,7 @@ public class KafkaConsumer extends DefaultConsumer { if (processed >= endpoint.getBatchSize() || consumerTimeout || (processed > 0 && !hasNext)) { // Need to commit the offset for the last round try { - berrier.await(endpoint.getBarrierAwaitTimeoutMs(), TimeUnit.MILLISECONDS); + barrier.await(endpoint.getBarrierAwaitTimeoutMs(), TimeUnit.MILLISECONDS); if (!consumerTimeout) { processed = 0; }
