Polished
Project: http://git-wip-us.apache.org/repos/asf/camel/repo Commit: http://git-wip-us.apache.org/repos/asf/camel/commit/38f9d3bc Tree: http://git-wip-us.apache.org/repos/asf/camel/tree/38f9d3bc Diff: http://git-wip-us.apache.org/repos/asf/camel/diff/38f9d3bc Branch: refs/heads/camel-2.15.x Commit: 38f9d3bc8955fcee6010d12e093b63461b1ed504 Parents: 990c6b5 Author: Claus Ibsen <[email protected]> Authored: Fri Aug 7 16:39:42 2015 +0200 Committer: Claus Ibsen <[email protected]> Committed: Fri Aug 7 16:57:07 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/38f9d3bc/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; }
