camel-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From davscl...@apache.org
Subject [1/3] camel git commit: Fixed example
Date Sun, 05 Mar 2017 14:00:50 GMT
Repository: camel
Updated Branches:
  refs/heads/master ff863cebc -> abda88d2b


Fixed example


Project: http://git-wip-us.apache.org/repos/asf/camel/repo
Commit: http://git-wip-us.apache.org/repos/asf/camel/commit/afcb0c3b
Tree: http://git-wip-us.apache.org/repos/asf/camel/tree/afcb0c3b
Diff: http://git-wip-us.apache.org/repos/asf/camel/diff/afcb0c3b

Branch: refs/heads/master
Commit: afcb0c3b7b098a7c7fa8bbf2fe944cc380a1a59b
Parents: ff863ce
Author: Claus Ibsen <davsclaus@apache.org>
Authored: Sun Mar 5 14:20:35 2017 +0100
Committer: Claus Ibsen <davsclaus@apache.org>
Committed: Sun Mar 5 14:20:35 2017 +0100

----------------------------------------------------------------------
 .../java/org/apache/camel/example/kafka/MessageConsumerClient.java | 2 +-
 .../camel-example-kafka/src/main/resources/application.properties  | 2 +-
 2 files changed, 2 insertions(+), 2 deletions(-)
----------------------------------------------------------------------


http://git-wip-us.apache.org/repos/asf/camel/blob/afcb0c3b/examples/camel-example-kafka/src/main/java/org/apache/camel/example/kafka/MessageConsumerClient.java
----------------------------------------------------------------------
diff --git a/examples/camel-example-kafka/src/main/java/org/apache/camel/example/kafka/MessageConsumerClient.java
b/examples/camel-example-kafka/src/main/java/org/apache/camel/example/kafka/MessageConsumerClient.java
index 7513ba9..5dc42b4 100644
--- a/examples/camel-example-kafka/src/main/java/org/apache/camel/example/kafka/MessageConsumerClient.java
+++ b/examples/camel-example-kafka/src/main/java/org/apache/camel/example/kafka/MessageConsumerClient.java
@@ -48,7 +48,7 @@ public final class MessageConsumerClient {
                 from("kafka:{{consumer.topic}}?brokers={{kafka.host}}:{{kafka.port}}"
                         + "&maxPollRecords={{consumer.maxPollRecords}}"
                         + "&consumersCount={{consumer.consumersCount}}"
-                        + "&seekToBeginning={{consumer.seekToBeginning}}"
+                        + "&seekTo={{consumer.seekTo}}"
                         + "&groupId={{consumer.group}}")
                         .routeId("FromKafka")
                     .log("${body}");

http://git-wip-us.apache.org/repos/asf/camel/blob/afcb0c3b/examples/camel-example-kafka/src/main/resources/application.properties
----------------------------------------------------------------------
diff --git a/examples/camel-example-kafka/src/main/resources/application.properties b/examples/camel-example-kafka/src/main/resources/application.properties
index 08738bd..67b360d 100644
--- a/examples/camel-example-kafka/src/main/resources/application.properties
+++ b/examples/camel-example-kafka/src/main/resources/application.properties
@@ -37,4 +37,4 @@ consumer.maxPollRecords=5000
 consumer.consumersCount=1
 
 # Get records from the begining
-consumer.seekToBeginning=true
+consumer.seekTo=beginning


Mime
View raw message