java - Camel Kafka 版本 2.14.3 无法读取消息
问题描述
我有一个 Kafka 集群(版本:0.10.1.0),有 9 个代理和 10 个分区。
我尝试使用 camel kafka 使用来自 java 应用程序的消息2.14.3
。这是我的骆驼路线
<route id="ReadFromTopic">
<from uri="kafka:[[broker.list]]?topic=[[topic]]&zookeeperHost=[[zookeeper.host]]&zookeeperPort=[[zookeeper.port]]&groupId=[[consumer.group]]&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]]&groupId=[[consumer.group]]" />
<log message="read message : ${body}" />
</route>
由于我的依赖关系,我只能使用 camel kafka 2.14.3
。我该如何解决这个问题?
解决方案
我刚刚找到了这个 Wiki 页面,其中列出了 Camel-Kafka 的不同选项,具体取决于版本。
查看 2.16 或更早版本的选项。Camel 2.x的组件文档似乎对 2.17 或更高版本有效。
推荐阅读
- vba - 如何使用 Application.ActivateMicrosoftApp xlMicrosoftAccess 打开特定的访问数据库
- react-native - 如何在反应原生 bugsnag 中使用后备组件?
- sql - 计算连接表
- android - 分叉 AOSP 源码
- javascript - 从数组中删除重复项,但使用 JS 忽略一个参数
- reactjs - isomorphic-unfetch 在 NextJs 的反应组件中抛出 400 个错误请求
- reactjs - 我正在使用 ag-grid 构建反应应用程序,但在尝试如何在单元格中放置链接时遇到问题
- wordpress - 从 Wordpress 数据库更新序列化数据
- css - 对象拟合、对象定位和绝对定位
- algorithm - A* of Tiles out-place 的自定义启发式 - 瓷砖不合适是不可接受的吗?