消息队列MQ

kafka消费者源码解读笔记

本文主要是介绍kafka消费者源码解读笔记,对大家解决编程问题具有一定的参考价值,需要的程序猿们随着小编来一起学习吧!

春节放假,因为疫情封锁,回不了老家,呆在家里无所事事,把kafka的客户端源码又拿出来仔细看了一下,本来想写几篇总结博客,但是我发现,想写的网上都已经有人写过了,那就不用再白费力气了,直接捡几篇好文章放上来。

还是做个简单的总结,以备自己后续查看。

下图是我画的一个kafka消费者客户端基本结构图,KafkaConsumer内部有两个主要模块,一个是ConsumerCoordinator,用于维护消费组和分区信息,包括连接coordinator、加入group、分配分区、提交offset等,在加入group后,还会启动HeartBeatThread线程,用于定时向kafka服务端心跳信息。另一个是Fetcher,用于从kafka服务端拉取数据。

  1. 关于kafka消费者的总体代码解读:
    https://www.zhenchao.org/2019/06/19/kafka/kafka-consumer/
  2. 关于kafka的ConsumerNetworkClient的代码解读:
    https://zhmin.github.io/posts/kafka-consumer-network-client/
  3. 关于kafka的NetworkClient的代码解读:
    https://zhmin.github.io/posts/kafka-networkclient/
  4. 关于kafka的selector的代码解读:
    https://www.cnblogs.com/devos/p/5699839.html
这篇关于kafka消费者源码解读笔记的文章就介绍到这儿,希望我们推荐的文章对大家有所帮助,也希望大家多多支持为之网!