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 <davscl...@apache.org> Authored: Sun Mar 5 14:20:35 2017 +0100 Committer: Claus Ibsen <davscl...@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
