【问题标题】:How Kafka poll method works behind the scene in Spring Boot?Kafka poll 方法如何在 Spring Boot 的幕后工作?
【发布时间】: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


【解决方案1】:

Kafka 采用混合的轮询策略。通常是记录数(或字节数)和时间间隔的组合。

所有属性都可以被覆盖以满足您的消费期望。

【讨论】:

  • 查看https://kafka.apache.org/documentation/#consumerconfigs_fetch.min.byteskafka.apache.org/documentation/… 默认情况下,只要有任何记录(最多max.poll.records 可用),投票就会返回。
猜你喜欢
  • 2018-06-23
  • 2012-02-06
  • 1970-01-01
  • 1970-01-01
  • 2016-10-07
  • 1970-01-01
  • 1970-01-01
  • 2022-12-25
  • 2015-05-18
相关资源
最近更新 更多