代码之家 › 专栏 › 技术社区 › Ryuzaki L

每次投票之间的延迟时间是多少

spring-kafka kafka-consumer-api apache-kafka

0

Ryuzaki L · 技术社区 · 6 年前

在卡夫卡的文档中,我试图理解这个属性 最大轮询间隔毫秒

使用使用者群组管理时,调用poll()之间的最大延迟。这为消费者在获取更多记录之前可以空闲的时间量设置了一个上限。如果在此超时过期之前未调用poll(),则认为使用者失败,组将重新平衡,以便将分区重新分配给另一个成员。

这意味着每一次投票都将在选举前进行 poll-time-out

例如:使用者线程1

第一次投票-->有100张唱片 --&燃气轮机;处理100条记录(耗时1分钟) --&燃气轮机;消费者提交的抵消

第二次投票-->有100张唱片 --&燃气轮机;处理100条记录(耗时1分钟)

消费者在第一次和第二次投票之间需要时间吗?如果是,为什么?我们如何改变这个时间(假设这个主题有大量数据)

1 回复 | 直到 6 年前

1

2

Gary Russell 6 年前

不清楚你所说的“在两者之间花点时间”是什么意思;如果你说的是弹簧卡夫卡侦听器容器,没有等待或睡眠,如果这是你的意思。

在提交补偿后,立即轮询消费者。

max.poll.interval.ms 必须足够大以便侦听器处理 max.poll.records (加上一些额外的,以防万一)。

但是,不,在两次投票之间没有增加延迟,只是侦听器处理投票结果所需的时间。

推荐文章

user25089203 · 替代Kafka 3.6.2中的@EnableBinding和@StreamListener

1 年前

springenthusiast · 如何将springboot中的重复配置作为jar并用作依赖项

1 年前

bohunn · Kafka Streams-无法搜索状态存储

1 年前

Andrey P. · 添加spring-cloud-starter-bus-Kafka依赖项后,Kafka消费者没有收到消息

2 年前

StevenPG · Spring Cloud Streams错误处理不起作用

2 年前

pankaj · Kafka中的电流偏移量怎么会这么高,而日志端偏移量太低,导致负Kafka滞后过高?

2 年前