如果消息未提交，Kafka Consumer如何自动轮询

Question

我有一个 Kafka 消费者，其中使用 HTTP POST 调用将消息传递给另一个应用程序。我还使用

手动提交偏移量

确认.acknowledge();

有一些 HTTP 返回错误代码，我们忽略错误并提交偏移量，还有一些错误代码我们不提交偏移量。问题是 kafka 消费者仅在我重新启动消费者时才轮询未提交的消息。如果分区中有未提交的消息，我可以在哪里轮询消息吗？

Answer 1

请参阅this answer 了解说明。

要重新传递一条记录，您必须抛出一个异常，并结合 SeekToCurrentErrorHandler，它会重新定位未处理的分区，以便在下一次轮询时再次获取它们。

或者您可以nack() 确认以达到类似的结果。