Camel Kafka:无法读取来自Kafka主题的消息

Question

我有一个Kafka集群（版本：0.10.1.0），有9个代理和10个分区。

我尝试使用camel kafka2.14.3从java应用程序中获取消息。这是我的pom。xml

<dependency>
    <groupId>org.apache.camel</groupId>
    <artifactId>camel-kafka</artifactId>
    <version>2.14.3</version>
</dependency>

这只是我使用的与骆驼Kafka相关的依赖项。下面是骆驼Kafka消费者代码。

<route id="ReadFromTopic">
    <from uri="kafka:[[topic]]?brokers=[[broker.list]]&amp;groupId=[[consumer.group]]" />   
    <log message="read message : ${body}" />
</route>

我正在使用文档中指定的KafkaURIhttps://camel.apache.org/components/latest/kafka-component.html.

但下面是我在加载camel上下文时遇到的异常

Caused by: org.apache.camel.ResolveEndpointFailedException: Failed to resolve endpoint: kafka://[[topic]]?brokers=[[broker.list]]&groupId=[[consumer.group]] due to: Failed to resolve endpoint: kafka://[[topic]]?brokers=[[broker.list]]&groupId=[[consumer.group]] due to: There are 1 parameters that couldn't be set on the endpoint. Check the uri if the parameters are spelt correctly and that they are properties of the endpoint. Unknown parameters=[{brokers=[[broker.list]]}]

它表示未知参数=[{brokers=[[broker.list]]}]。我试过《Kafka3》。x，它消耗的能量很好。但我必须在制作中使用camel kafka2.14.3。我是否缺少任何依赖项或使用了错误的URI？

Answer 1

我认为你的第一个问题是正确的。我感到非常惊讶的是，Camel Kafka的URI格式在2.14.2和Camel 2的更新版本之间发生了如此大的变化。x、 也许是因为Kafka的新版本？

您可以在2.24.3版和2.14.3版的kafkanconfiguration文档中看到它。在2.14.3版上，没有getBrokers方法来获取brokers参数，因此您得到的错误消息取决于您使用的版本。

相比之下，在版本2.24.3上有这样一种方法，因此它对应于较新版本2的组件文档。x版本。

不幸的是，我没有找到版本2.14.3的组件文档，但也许您可以使用kafkanconfiguration的可能参数从第一个问题的URI构建它。