爲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客戶確認模式

我無法找到雖然是一種配置確認模式的方法。

來源

2017-07-20 Ajay

spring.kafka.listener.ack模式=

來源

2017-07-20 09:27:48 Ajay

您可以使用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

來源

2017-07-20 05:51:36 wthamira

是否有溶液不涉及Spring Cloud Stream？ – Ajay

關注此https://www.codenotfound.com/2017/04/spring-kafka-boot-example.html – wthamira

您能否指出在引用的鏈接中提及了配置確認模式的位置？ – Ajay

爲Spring Boot Kafka項目配置Kafka客戶確認模式

回答

相關問題