Kafka消费者的心跳请求
发布时间
阅读量：
阅读量
1. 发起心跳请求
当Consumer客户端初始化运行时，系统将自动创建并激活名为HeartbeatThread的心跳监测线程，
该线程的命名格式为：kafka-coordinator-heartbeat-thread|group.id
举例来说，具体名称可能显示为：kafka-coordinator-heartbeat-thread | consumer0
/** * Java学习资料
* wx: javataozi888
**/
private boolean enabled = false;
private synchronized void startHeartbeatThreadIfNeeded() {
if (heartbeatThread == null) {
heartbeatThread = new HeartbeatThread();
heartbeatThread.start();
}
}
全部评论 (0)
还没有任何评论哟~