kafka consumer 是什么时候获取自己的分区信息的？
回答·2
最热
最新
- 我假定你讨论的是 java consumer。 当 Kafka consumer 首次调用 poll 时它会调用 coordinator 组件的 poll 方法发起组管理操作，比如确定并连接 group coordinator，加入组，等待组 leader 同步分区分配方案等。 获取分区分配方案就是在这个过程中完成的。 之后 consumer 才开始创建 fetcher 消费被分配的分区
- 首次调用 poll 时，会发起组件管理方法组调用，会由主服务器同步分区