如何禁用 Spring Kafka 中的偏移量提交以在本地存储偏移量？
How do I disable committing of offsets in Spring Kafka to store offsets locally?
我想使用 Spring Kafka 将事件处理到本地数据库中并将偏移量存储在数据库本身中，如 https://kafka.apache.org/25/javadoc/index.html?org/apache/kafka/clients/consumer/KafkaConsumer.html “在 Kafka 外部存储偏移量”中所述。
Spring Kafka（带有 KafkaListener）似乎总是提交偏移量（因此需要 group.id），有没有办法完全禁用提交以允许在没有组的情况下收听？
Spring Kafka Consumer 有一个配置 属性 enable.auto.commit。这可以设置为 false，以便您可以在代码中实施提交策略。请在此处查看文档：https://docs.spring.io/spring-kafka/reference/html/#committing-offsets
KafkaListener 注解可以直接定义配置。请参阅 JavaDoc - https://docs.spring.io/spring-kafka/api/org/springframework/kafka/annotation/KafkaListener.html.
容器 属性 AckMode.MANUAL 将禁用容器的偏移量提交。
我想使用 Spring Kafka 将事件处理到本地数据库中并将偏移量存储在数据库本身中，如 https://kafka.apache.org/25/javadoc/index.html?org/apache/kafka/clients/consumer/KafkaConsumer.html “在 Kafka 外部存储偏移量”中所述。
Spring Kafka（带有 KafkaListener）似乎总是提交偏移量（因此需要 group.id），有没有办法完全禁用提交以允许在没有组的情况下收听？
Spring Kafka Consumer 有一个配置 属性 enable.auto.commit。这可以设置为 false，以便您可以在代码中实施提交策略。请在此处查看文档：https://docs.spring.io/spring-kafka/reference/html/#committing-offsets
KafkaListener 注解可以直接定义配置。请参阅 JavaDoc - https://docs.spring.io/spring-kafka/api/org/springframework/kafka/annotation/KafkaListener.html.
容器 属性 AckMode.MANUAL 将禁用容器的偏移量提交。