生产者可以在kafka中发送偏移量获取请求吗?
Can producer send offset fetch request in kafka?
这是关于让 生产者 知道消息是否已被 消费者 使用的用例。
我的想法是,每次消费消息时,Consumer 提交偏移量,Producer 可以跟踪和读取当前偏移量查看是否消费了对应的消息
此外,请不要犹豫让我知道这是否是处理用例的正确方法,因为我没有使用 Kafka 的经验。我知道 Kafka 并非设计为以这种方式工作(处理上述用例),但我必须坚持使用 Kafka。
如果问题是标题,答案是否定的,至少在最新版本的kafka 0.9.0.1中,无法知道生产者的分区偏移量是多少。
这是关于让 生产者 知道消息是否已被 消费者 使用的用例。
我的想法是,每次消费消息时,Consumer 提交偏移量,Producer 可以跟踪和读取当前偏移量查看是否消费了对应的消息
此外,请不要犹豫让我知道这是否是处理用例的正确方法,因为我没有使用 Kafka 的经验。我知道 Kafka 并非设计为以这种方式工作(处理上述用例),但我必须坚持使用 Kafka。
如果问题是标题,答案是否定的,至少在最新版本的kafka 0.9.0.1中,无法知道生产者的分区偏移量是多少。