如何配置最少的消息读取 - Spring Kafka

Question

是否可以配置 Kafka 读取的最小消息数？

示例我希望我的消费者在收到 5 条或更多消息后开始阅读主题的消息。

我尝试将 max-poll-interval-ms 与 fetch-max-wait-ms 和 max-poll-records 一起使用，但 kafka 继续逐条读取。

Answer 1

您不能指定最小记录数，您只能通过指定最小字节数（fetch.min.bytes 和 fetch.max.wait.ms）来近似估计。