提问人:soumya 提问时间:1/10/2023 更新时间:1/11/2023 访问量:206
如何使用 mule 4 在 kafka 中禁用自动提交
How to disable auto commit in kafka using mule 4
问:
我正在使用 kafka 发布连接器,该连接器正在发布通过邮递员提供的有效负载。现在,有一个 kafka 侦听器,它监听该主题中的消息(它只有 1 个分区)。在同一个 kafka 侦听器流中,有一个 seek 操作,它试图为特定偏移量寻找值。当它被自动提交时,搜索不会获取我们提供的偏移值。需要您的宝贵建议,使 seek 运算符从以前的偏移量中查找值。
答:
0赞
aled
1/11/2023
#1
在 Kafka 连接器配置中将确认模式设置为 MANUAL,并确保在正确结束时执行 Commit 操作。
评论