commit bae09a19d873eef9309dacf7085e5e88787d6dc4
author Jan Hendriks <dahoc3150@googlemail.com> Tue Dec 08 13:18:37 2020 +0100
committer Andrea Cosentino <ancosen@gmail.com> Tue Dec 08 13:30:19 2020 +0100
tree 80b9806d4ef97ce78b61e998ec852b85b2d37b39
parent 4a9b5cacceb21293fc6411b2c6963a5b9808331e

Fix MessageConsumerClient subscription

Resolving 
Error while fetching metadata with correlation id 2: {TestLog&maxPollRecords=5000&consumersCount=1&seekTo=beginning&groupId=kafkaGroup=INVALID_TOPIC_EXCEPTION}

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