Kafka10 heartbeat.interval.ms 属性
Kafka10 heartbeat.interval.ms property
我对 属性 heartbeat.interval.ms 和 poll() 方法感到困惑。
我希望，当我们调用poll() 方法时，poll() 方法会发送心跳。例如，heartbeat.interval.ms 配置为 1 秒，但 poll() 方法需要 2 秒才能完成处理。它会在 2 秒后发送心跳还是通过后台线程每隔一秒发送一次心跳。
就我个人而言，我认为 heartbeat.interval.ms 是心跳间隔的下限。也就是说，如果设置为1秒，心跳线程至少要等待1秒才能发送心跳请求，但是线程有可能等待1.5秒才发送请求。
从 0.10.1 开始，心跳从调用 poll 的用户线程转移到一个单独的线程，因此它不再与 poll 事物交织。详细见更多信息：KIP-62
我对 属性 heartbeat.interval.ms 和 poll() 方法感到困惑。
我希望，当我们调用poll() 方法时，poll() 方法会发送心跳。例如，heartbeat.interval.ms 配置为 1 秒，但 poll() 方法需要 2 秒才能完成处理。它会在 2 秒后发送心跳还是通过后台线程每隔一秒发送一次心跳。
就我个人而言，我认为 heartbeat.interval.ms 是心跳间隔的下限。也就是说，如果设置为1秒，心跳线程至少要等待1秒才能发送心跳请求，但是线程有可能等待1.5秒才发送请求。
从 0.10.1 开始，心跳从调用 poll 的用户线程转移到一个单独的线程，因此它不再与 poll 事物交织。详细见更多信息：KIP-62