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



是否可以为 Kafka 读取配置最少消息数?

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

我尝试将max-poll-interval-ms与fetch-max-wait-ms和max-poll-records一起使用,但kafka继续一个接一个地读取。

您不能指定最小记录数,只能通过指定最小字节数(fetch.min.bytesfetch.max.wait.ms一起(来近似。

最新更新