如何使用 mule 4 在 kafka 中禁用自动提交

How to disable auto commit in kafka using mule 4

提问人:soumya 提问时间:1/10/2023 更新时间:1/11/2023 访问量:206

问:

我正在使用 kafka 发布连接器,该连接器正在发布通过邮递员提供的有效负载。现在,有一个 kafka 侦听器,它监听该主题中的消息(它只有 1 个分区)。在同一个 kafka 侦听器流中,有一个 seek 操作,它试图为特定偏移量寻找值。当它被自动提交时,搜索不会获取我们提供的偏移值。需要您的宝贵建议,使 seek 运算符从以前的偏移量中查找值。

apache-kafka mulesoft mule4 seek autocommit

评论


答:

0赞 aled 1/11/2023 #1

在 Kafka 连接器配置中将确认模式设置为 MANUAL,并确保在正确结束时执行 Commit 操作