首先了解kafka读写流程,参考这篇文章:kafka存储机制与读写流程
先建立连接,即我们配置的那个bootstrap.servers,连接建立后,会返回相关信息,如broker地址、topic、offset、partition等信息,consumer拿到后会存到元数据metadata中。metadata参考这篇文章:Kafka集群metadata管理
四、解决方案 五、实施 六、总结参考:
Kafka与zk的关系及连接参数bootstrap.server的正确理解_zollty的专栏-CSDN博客
欢迎分享,转载请注明来源:内存溢出
评论列表(0条)