消費批次

從 3.0 版本開始，當 spring.cloud.stream.bindings.<name>.consumer.batch-mode 設定為 true 時，透過輪詢 Kafka Consumer 接收到的所有記錄都將作為 List<?> 呈現給監聽器方法。否則，該方法將一次接收一條記錄。批次的大小由 Kafka 消費者屬性 max.poll.records、fetch.min.bytes、fetch.max.wait.ms 控制；有關更多資訊，請參閱 Kafka 文件。

接收批次時，允許使用以下型別簽名：

在 List<Person> 的第一個選項中，監聽器將不會獲取任何訊息頭。如果使用第二個型別簽名 (Message<List<Person>>)，則可以訪問訊息頭；但是，所有訊息頭仍將以 Collection 的形式存在。讓我們看以下示例。

假設 Message 包含一個包含十個 Person 物件的列表。Message 的 MessageHeaders 包含一個訊息頭對映，其中鍵是訊息頭名稱，值是一個列表。此列表包含該訊息頭的值，順序與有效載荷列表相同。因此，應用程式需要根據有效載荷列表的迭代，從 MessageHeaders 對映中正確訪問訊息頭。

請注意，在批處理模式下消費時，不允許使用 List<Message<Person>> 形式的型別簽名。

從 4.0.2 版本開始，該繫結器在批次消費模式下支援 DLQ 功能。請記住，當在批次模式下對消費者繫結使用 DLQ 時，從上一次輪詢接收到的所有記錄都將傳送到 DLQ 主題。