为 Spring Boot Kafka 项目配置 Kafka 消费者确认模式

Question

我正在使用 Spring 引导版本 1.5.2.RELEASE 以及 Spring Kafka 版本 1.1.2.RELEASE。通过 application.properties 文件，我确实看到了配置 Kafka Consumer 的可用选项 (spring.kafka.consumer.*)。

不过我找不到配置确认模式的方法。

Answer 1

您可以使用 Spring Cloud Stream Kafka Binder 来流式传输消息。那样的话

<dependency>
  <groupId>org.springframework.cloud</groupId>
  <artifactId>spring-cloud-stream-binder-kafka</artifactId>
</dependency>

并像这样配置消费者。

spring.cloud.stream.kafka.bindings.<channelName>.consumer..

和这样的制作人

spring.cloud.stream.kafka.bindings.<channelName>.producer..

更多详情请关注this or this video

Answer 2

spring.kafka.listener.ack-mode=

为 Spring Boot Kafka 项目配置 Kafka 消费者确认模式

Configure Kafka consumer acknowledgement mode for Spring Boot Kafka project

spring-boot

spring-kafka