Camel Kafka 2.14.3版无法读取邮件

Question

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

我尝试使用camel kafka2.14.3从java应用程序中消费消息

<route id="ReadFromTopic">
    <from uri="kafka:[[broker.list]]?topic=[[topic]]&amp;zookeeperHost=[[zookeeper.host]]&amp;zookeeperPort=[[zookeeper.port]]&amp;groupId=[[consumer.group]]&amp;consumerStreams=[[concurrency]]" />
    <log message="Message Read from kafka topic : [[topic]]" loggingLevel="INFO" />
    <log message=" BODY is ${body}" loggingLevel="INFO" />
</route>

路由启动正常，但没有读取任何消息。

当我尝试使用camel kafka3.0.1，路线如下时，我能够阅读信息

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

由于依赖关系，我只能使用camel kafka2.14.3。我该如何解决这个问题？

Answer 1

我刚刚找到了这个维基页面，其中列出了不同版本的Kafka。

检查2.16或更高版本的选项。Camel2. x的组件留档似乎对2.17或更高版本有效。