我正在使用Spring Boot 1.5.2.RELEASE和Spring Kafka 1.1.2.RELEASE版本。 通過application.properties文件,我確實看到了可用選項(spring.kafka.consumer。*)來配置Kafka Consumer。爲Spring Boot Kafka項目配置Kafka客戶確認模式
我無法找到雖然是一種配置確認模式的方法。
我正在使用Spring Boot 1.5.2.RELEASE和Spring Kafka 1.1.2.RELEASE版本。 通過application.properties文件,我確實看到了可用選項(spring.kafka.consumer。*)來配置Kafka Consumer。爲Spring Boot Kafka項目配置Kafka客戶確認模式
我無法找到雖然是一種配置確認模式的方法。
spring.kafka.listener.ack模式=
您可以使用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或this video
是否有溶液不涉及Spring Cloud Stream? – Ajay
關注此https://www.codenotfound.com/2017/04/spring-kafka-boot-example.html – wthamira
您能否指出在引用的鏈接中提及了配置確認模式的位置? – Ajay