首页
Python
Java
前端
数据库
Linux
Chatgpt专题
开发者工具箱
consumercoordinator专题
Kafka-消费者-KafkaConsumer分析-ConsumerCoordinator
在前面介绍了Kafka中Rebalance操作的相关方案和原理。 在KafkaConsumer中通过ConsumerCoordinator组件实现与服务端的GroupCoordinator的交互,ConsumerCoordinator继承了AbstractCoordinator抽象类。 下面我们先来介绍AbstractCoordinator的核心字段,如图所示。 - heartbeat:心跳
阅读更多...