春季集成 - 卡夫卡消息驅動通道 - 自動確認

Question

我已經使用了春季io文檔中列出的示例配置，它工作正常。

<int-kafka:message-driven-channel-adapter 
     id="kafkaListener" 
     listener-container="container1" 
     auto-startup="false" 
     phase="100" 
     send-timeout="5000" 
     channel="nullChannel" 
     message-converter="messageConverter" 
     error-channel="errorChannel" /> 

但是，當我測試它與下游應用程序，我從卡夫卡消耗併發布到下游。如果下游關閉，則消息仍然消耗並且不會重播。

或者讓我們說從kafka話題中消費後，如果我在服務激活器中發現一些異常，我想拋出一些異常以及應該回滾事務，以便可以重放kafka消息。

簡而言之，如果消費應用程序有問題，那麼我想要回滾事務，以便消息不會自動確認，並且一次又一次地重播回來，除非它被成功處理。

Answer 1

這不是Apache Kafka的工作原理。有類似於JMS的TX語義。卡夫卡話題中的抵消與逆轉或重新交付沒有任何關係。

我建議你從他們的官方資源學習Apache Kafka更近。

春卡夫卡帶來什麼比普通的Apache卡夫卡協議，但是你可以考慮使用重試在春節卡夫卡能力重新提交本地相同的記錄：http://docs.spring.io/spring-kafka/docs/1.2.2.RELEASE/reference/html/_reference.html#_retrying_deliveries

而且是的，ACK模式必須是手動的，做消費後不自動向卡夫卡提交補償。