You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@camel.apache.org by da...@apache.org on 2015/08/07 16:49:40 UTC
[3/4] camel git commit: Polished
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 <da...@apache.org>
Authored: Fri Aug 7 16:39:42 2015 +0200
Committer: Claus Ibsen <da...@apache.org>
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;
}