重复接收未提交的消息

Question

是否可以设置接收来自kafka的消息，以便阅读器一次又一次地接收未提交的消息，并且不采取下一个偏移量？ 设置enable.auto.commit等于false

我使用 java 和 kafka 没有 Spring

Answer 1

您可以设置max.poll.records=1 并简单地“一次又一次地”缓存并返回单个消费记录，而不是循环轮询。

否则，从同一个客户端继续轮询将向前寻找偏移量。