【发布时间】:2016-02-19 21:39:05
【问题描述】:
这是关于让 Producer 知道消息是否已被 Consumer 消费的用例。
我的想法是,每次消费消息时,Consumer 提交偏移量,Producer 可以跟踪和读取当前偏移量,以查看是否消费了相应的消息。
另外,请不要犹豫,让我知道这是否是处理用例的正确方法,因为我没有 Kafka 经验。我知道 Kafka 并非设计为以这种方式工作(处理上述用例),但我必须坚持使用 Kafka。
【问题讨论】:
-
你用的是什么版本?您打算如何让 Producer 了解偏移量?
-
如果需要,我可以使用最新版本。我正在考虑使用 kafka API 以与 consumer does it 相同的方式获取偏移量。
标签: message-queue apache-kafka