【发布时间】:2022-01-24 17:59:15
【问题描述】:
在 Kafka for Spring 中,我看到默认情况下 max-poll-records 值为 500。 所以我的问题是假设如果主题中不存在 500 条消息,消费者将等待获取 500 条记录,然后 poll 方法将运行并获取这批记录。
我在这里有点困惑,比如从主题中提取消息之前的所有检查。
【问题讨论】:
-
不,它限制了一次 poll() 返回的消息数量。可能这个答案会帮助你stackoverflow.com/questions/51753883/…
-
这不是最小轮询记录大小,它是最大的,所以它不会阻塞,直到 500 条记录满。
标签: spring spring-boot spring-kafka