问Kafka10 heartbeat.interval.ms性质
EN

Stack Overflow用户

提问于 2017-05-15 14:44:49

回答 1查看 887关注 0票数 0

我对属性heartbeat.interval.ms和poll()方法感到困惑。

我希望，在调用轮询()方法时，poll()方法将发送心跳。比方说，heartbeat.interval.ms被配置为1秒，但是轮询()方法需要2秒才能完成处理。它是在2秒后发送心跳，还是每一秒通过后台线程发送一次心跳。

回答已采纳

发布于 2017-05-16 01:25:16

就我个人而言，我认为heartbeat.interval.ms是心跳间隔的下限。也就是说，如果将其设置为1秒，心跳线程必须等待至少1秒才能发送心跳请求，但是线程可以在发送请求之前等待1.5秒。

从0.10.1开始，心跳将从调用poll的用户线程移动到一个单独的线程，因此它不再与poll事物交织。请参阅更详细的信息：基普-62

票数 3

页面原文内容由Stack Overflow提供。腾讯云小微IT领域专用引擎提供翻译支持

原文链接：

https://stackoverflow.com/questions/43982417

复制

相似问题

问Kafka10 heartbeat.interval.ms性质EN