消费批次

从 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 主题。