spring-cloud-stream-kafka在應用程序啓動後僅使用最新消息

Question

在我們的項目中，我們使用spring-cloud-stream-binder-kafka 1.1.2版與kafka集成。最近我們遇到了這樣一種情況：我們的某項服務在啓動後會消耗某個主題的舊消息（已經消耗）。該主題有2個分區和2個消費者組成的消費者羣體。我們不確定偏移量是否適用於動物園管理員。在啓動過程中，每條消息都會引發錯誤消息。

[-kafka-listener-2] ERROR o.s.k.listener.LoggingErrorHandler.handle - Error while processing: ConsumerRecord(topic = statemachine_deal_notification, partition = 1, offset = 926, key = null, value = [B@6fab0a32) 

爲確保不再發生，我們一直只想閱讀主題中的最新消息。我發現設置resetOffsets到true和startOffset到latest將做這項工作。但是這些屬性不會影響消費者。後來發現這個功能已經被丟棄了。

有沒有其他方法可以確保特定羣組中的消費者只消費最新消息？

Answer 1

這是一個bug，隨後在這裏修復：https://github.com/spring-cloud/spring-cloud-stream-binder-kafka/commit/7355ada4613ad50fe95430f1859d4ea65f004be1。您可以試用SNAPSHOT（1.2.2.BUILD-SNAPSHOT或1.3.0.BUILD-SNAPSHOT）版本來驗證此修復。