我正在使用Kafka的高级消费者.因为我正在使用Kafka作为我的应用程序的"事务队列",所以我需要确保我不会错过或重读任何消息.我有两个问题:
如何将偏移量提交给zookeeper？在每次成功使用消息后,我将关闭自动提交和提交偏移量.我似乎无法找到如何使用高级消费者执行此操作的实际代码示例.谁能帮我这个？
另一方面,我听说承诺动物园管理员可能会很慢,所以另一种方式可能是在本地跟踪偏移？这种替代方法是否可取？如果是的话,你会怎么做？
message-queue distributed-transactions apache-kafka apache-zookeeper