kafkaKafka Consumer 中的心跳线程有什么作用?

Posted 九师兄

tags:

篇首语:本文由小常识网(cha138.com)小编为大家整理,主要介绍了kafkaKafka Consumer 中的心跳线程有什么作用?相关的知识,希望对你有一定的参考价值。

1.概述

翻译:What does the heartbeat thread do in Kafka Consumer?

官网:https://cwiki.apache.org/confluence/display/KAFKA/KIP-62%3A+Allow+consumer+to+send+heartbeats+from+a+background+thread

2.回顾

在上一篇文章中,我们讨论了 Kafka Consumer 在底层是如何工作的。现在我们知道获取记录的第一步是什么。

还记得我在上一篇文章中故意省略的内容吗?这是正确的!心跳线程。我们将调查它究竟做了什么以及它是如何工作的。

3.简单案例

如果您想在调试时运行一些示例以自己发现心跳代码&#

以上是关于kafkaKafka Consumer 中的心跳线程有什么作用?的主要内容,如果未能解决你的问题,请参考以下文章

kafkakafka InstanceAlreadyExists jmx consumer addMBean registerAppInfo AppInfoParser

时间轮原理及其在框架中的应用

kafkaKafka 之 Group 状态变化分析及 Rebalance 过程

kafkakafka 消费的时候 退出

时间轮原理及其在框架中的应用

Kafkakafka Removed ✘✘✘ expired offsets in ✘✘✘ milliseconds.