首页
学习
活动
专区
工具
TVP
发布

后端技术

专栏作者
269
文章
266923
阅读量
31
订阅数
KafkaConsumer HeartbeatThread
我们已知ConsumerNetworkClient是对NetworkClient的封装,而消费者与服务器的交互分为两条线程
平凡的学生族
2021-12-08
2890
KafkaConsumer 组件源码 ConsumerCoordinator
ConsumerCoordinator继承于AbstractCoordinator,也是其唯一的实现类。AbstractCoordinator定义了有关集群协调的逻辑,定义了消费者与特定的broker(cordinator)交互的逻辑,供消费者加入消费组、探知消费组状态。
平凡的学生族
2020-07-02
6330
KafkaConsumer 入门理解
需要理解offset的提交机制、保存。比如commitSync、commitAsync、__consumer_offsets。 深入还能了解offset的恢复。
平凡的学生族
2020-06-28
3370
kafka MetaData
Metadata只是一个信息副本,其更新由MetadataUpdater完成。MetadataUpdater由NetworkClient调用,用于更新Metadata的接口
平凡的学生族
2020-06-16
6980
KafkaProducer
其中,Sender把准备好的Batch取出,把要发往同一Node的Batch放在一起,发给NetworkClient
平凡的学生族
2020-06-16
5340
kafka 网络模型2 Selector
在上一篇文章中,我分析了Kafka的请求、响应流程,但留下了Selector的疑点。本文会分析Selector和它的poll()是如何进行网络IO的,NetworkReceive是如何被完整读取的,Send是如何被完整写出的,还会涉及到KafkaChannel和它的mute机制。
平凡的学生族
2020-06-09
8440
kafka 启动1 入口函数
该函数的目的是读取config/server.properties中的参数到Properties中,供之后使用
平凡的学生族
2020-06-02
1.3K0
kafka 网络模型1 请求响应流程
在kafka 启动1 入口函数中,我们阅读了KafkaServer的注释,这里直接总结一下:
平凡的学生族
2020-06-02
1.1K0
docker-comopose kafka 一键搭建
本文是对使用Docker快速搭建Kafka开发环境的补充,跟随教程即可完成搭建,但还有些地方需要注意。
平凡的学生族
2020-05-04
4.6K0
kafka理解
参考消息队列模式:点对点 与 发布订阅 消息队列中点对点(RabbitMQ)与发布订阅区别(Kafka)
平凡的学生族
2019-05-25
4210
没有更多了
社区活动
腾讯技术创作狂欢月
“码”上创作 21 天,分 10000 元奖品池!
Python精品学习库
代码在线跑,知识轻松学
博客搬家 | 分享价值百万资源包
自行/邀约他人一键搬运博客,速成社区影响力并领取好礼
技术创作特训营·精选知识专栏
往期视频·千货材料·成员作品 最新动态
领券
问题归档专栏文章快讯文章归档关键词归档开发者手册归档开发者手册 Section 归档