[camel-examples] branch master updated: Fix MessageConsumerClient subscription

[acosentino]

This is an automated email from the ASF dual-hosted git repository.

acosentino pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/camel-examples.git


The following commit(s) were added to refs/heads/master by this push:
     new bae09a1  Fix MessageConsumerClient subscription
bae09a1 is described below

commit bae09a19d873eef9309dacf7085e5e88787d6dc4
Author: Jan Hendriks <dahoc3...@googlemail.com>
AuthorDate: Tue Dec 8 13:18:37 2020 +0100

    Fix MessageConsumerClient subscription
    
    Resolving
    Error while fetching metadata with correlation id 2: 
{TestLog&maxPollRecords=5000&consumersCount=1&seekTo=beginning&groupId=kafkaGroup=INVALID_TOPIC_EXCEPTION}
---
 .../main/java/org/apache/camel/example/kafka/MessageConsumerClient.java | 2 +-
 1 file changed, 1 insertion(+), 1 deletion(-)

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 347ed5b..5540678 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
@@ -50,7 +50,7 @@ public final class MessageConsumerClient {
                         .register(camelContext, "kafka");
 
                 from("kafka:{{consumer.topic}}"
-                        + "&maxPollRecords={{consumer.maxPollRecords}}"
+                        + "?maxPollRecords={{consumer.maxPollRecords}}"
                         + "&consumersCount={{consumer.consumersCount}}"
                         + "&seekTo={{consumer.seekTo}}"
                         + "&groupId={{consumer.group}}")