内容简述：
分析Kafka消费者的主要组件与消费消息的主流程
名词解释：
- KafkaConsumer
消息消费者 - ConsumerRecord
消息载体 - ConsumerInterceptor
消息消费拦截器接口，有两个拦截点: onComsume（在拉取到消息后），onCommit（提交消费位移后） - KeySerializer && ValueSerializer
消息Key\值的序列化器，消息会序列化为二进制数组进行发送 - IsolationLevel
事务级别，有READ_UNCOMMITTED，READ_COMMITTED
6. SubscriptionState
订阅状态，记录着消费者对订阅的主题、分区以及消费位移的状态 - ConsumerNetworkClient
消息者专有的网络客户端 - ConsumerCoordinator
消费者协调器 - Fetcher
消息拉取器，向kafka broker发送消息拉取请求, 接收服务器推送的消息
生产者与消息者共用组件：
参考生产者篇: https://blog.csdn.net/weixin_39818495/article/details/123785400
消费流程图
时序图：
待补充
版权声明：本文为weixin_39818495原创文章，遵循CC 4.0 BY-SA版权协议，转载请附上原文出处链接和本声明。