如何在 mule 中动态设置 kafka 偏移值，以便我们可以从该特定偏移量开始处理
how to dynamically set kafka offset value in mule so that we can start processing from that particular offset
我想动态设置 KAFKA 偏移量，以便我的处理在需要时从相同的偏移量开始，使用 mulesoft...
举个例子：
kafka 总共有 150 条消息，我想从偏移值 51 到最后一条开始处理。在配置中我们可以从 beginning/from latest..
我如何使用 mule 实现此目的？
我认为你不能避免读取消息，但你可以使用上次读取的属性attributes.offset来找到偏移量，避免处理那些你不感兴趣的偏移量编号的消息。
我想动态设置 KAFKA 偏移量，以便我的处理在需要时从相同的偏移量开始，使用 mulesoft...
举个例子： kafka 总共有 150 条消息，我想从偏移值 51 到最后一条开始处理。在配置中我们可以从 beginning/from latest.. 我如何使用 mule 实现此目的？
我认为你不能避免读取消息，但你可以使用上次读取的属性attributes.offset来找到偏移量，避免处理那些你不感兴趣的偏移量编号的消息。