Spring for Apache Kafka 參考 使用 Spring for Apache Kafka 接收訊息 接收訊息 可以透過配置 MessageListenerContainer 並提供訊息監聽器來接收訊息,或者使用 @KafkaListener 註解。 本節概要 訊息監聽器 訊息監聽器容器 手動提交偏移量 非同步 @KafkaListener 返回型別 @KafkaListener 註解 獲取消費者 group.id 容器執行緒命名 @KafkaListener 作為元註解 類上的 @KafkaListener @KafkaListener 屬性修改 @KafkaListener 生命週期管理 @KafkaListener @Payload 驗證 重平衡監聽器 強制消費者重平衡 使用 @SendTo 轉發監聽器結果 訊息過濾 重試投遞 按順序啟動 @KafkaListener 使用 KafkaTemplate 接收 傳送訊息 訊息監聽器