具有 enable.auto.commit = false 的 Kafka Consumer 仍在提交偏移量

Question

Kafka 消费者已经处理了消息 1、2、3、4，并且 enable.auto.commit 设置为 false。

但是在重新启动消费者时，它不会再次重新处理上述消息，从 CLI 我可以看到偏移量已经增加并且没有延迟（因此它正在提交）。

您能否对此提供帮助，以了解消费者如何在属性 enable.auto.commit 设置为 false 的情况下仍然提交偏移量。

以下是消费者属性

allow.auto.create.topics = true
auto.commit.interval.ms = 0
auto.offset.reset = latest
bootstrap.servers = [localhost:9092]
enable.auto.commit = false
fetch.max.bytes = 52428800
fetch.max.wait.ms = 500
fetch.min.bytes = 1
group.id = EmployeeConsumer

目前使用 spring-kafka-2.5.0.RELEASE.jar 作为依赖

Answer 1

您需要显示您的 Spring 配置。

enable.auto.commit=false 告诉 kafka-clients 不要提交偏移量，但默认情况下 Spring 会提交偏移量。

将侦听器容器ackMode属性设置AckMode.MANUAL为禁用容器提交。

此外：

auto.offset.reset = latest意味着从未提交偏移量的消费者将从主题/分区的当前末尾开始消费，因此它不会获得现有记录。