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 <[email protected]>
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}}")
