Kafkaenable.auto.commit设置为假，但民意测验仍然获取“下一条”信息

Question

我想告诉Kafka我的消费者何时成功处理了一条记录，因此我通过设置enable关闭了自动提交。汽车将提交到false。我有两条关于我订阅的主题的消息，偏移量分别为0和1，并创建了一个消费者，因此每次调用poll最多返回一条记录（通过将max.poll.records设置为1）。

我现在调用consumer.poll（5000）并收到第一条消息，但我不承认它；我不调用委员会同步或委员会同步。如果我现在再次调用consumer.poll（5000），使用相同的消费者，我希望得到我刚刚阅读的完全相同的消息，但是，相反，我收到了第二条消息。

如何获得消费者。轮询，在我明确确认之前继续发送相同的消息？




Answer 1

你所描述的是预期的行为。每次调用poll（），它都会返回下一条消息。您提交的偏移量仅在连接新使用者时使用，以便它知道从何处（重新）开始。

在MessageHub中，我们设置了会话。超时至30秒。因此，您需要稍微加快调用poll（）的速度，以避免断开连接。如果您的处理时间比这要长，那么我可以考虑两个选项：

>

使用Kafka 0.10.2并设置max.poll.interval.ms来告诉您的Kafka客户端在处理前一条记录时保持会话活动（而不必调用投票（））。（此功能是在0.10.1中添加的，但我们不支持该版本。0.10.2工作，因为它能够与0.10.0经纪人工作）

使用seek（）返回到poll之后的上一个偏移量，以便它继续返回相同的记录。

希望这能有所帮助！