腾讯云开发者社区-腾讯云

开发者社区

文档建议反馈控制台

最新优惠活动

文章/答案/技术大牛

发布

中间件兴趣圈

《RocketMQ技术内幕》作者维护，关注Netty、Mycat、Dubbo、es-job、Rocketmq、es、mybatis等。

专栏作者

129

文章

249797

阅读量

101

订阅数

源码分析Kafka 消息拉取流程（文末两张流程图）

缓存 kafka java

代码＠１：参数为超时时间，使用 java 的 Duration 来定义。代码＠２：调用内部的 poll 方法。

2019-12-10

2.1K0

初始 Kafka Consumer 消费者

编程算法 kafka

根据 KafkaConsumer 类上的注释上来看 KafkaConsumer 具有如下特征：

2019-11-28

1.2K0

KafkaProducer Sender 线程详解(含详细的执行流程图)

批量计算缓存数据结构 kafka

上文《源码分析 Kafka 消息发送流程》已经详细介绍了 KafkaProducer send 方法的流程，该方法只是将消息追加到 KafKaProducer 的缓存中，并未真正的向 broker 发送消息，本文将来探讨 Kafka 的 Sender 线程。

2019-11-19

1.6K0

源码分析 Kafka 消息发送流程(文末附流程图)

批量计算缓存 kafka 网络安全文件存储

从上文初识 Kafka Producer 生产者，可以通过 KafkaProducer 的 send 方法发送消息，send 方法的声明如下：

2019-11-12

1.2K0

初识 Kafka Producer 生产者

缓存 kafka 文件存储

根据 KafkaProducer 类上的注释上来看 KafkaProducer 具有如下特征：

2019-11-06

9450

RocketMQ实战：一个新的消费组初次启动时从何处开始消费呢？

apache 存储消息队列 CMQ 版 kafka

一个新的消费组订阅一个已存在的Topic主题时，消费组是从该Topic的哪条消息开始消费呢？

2019-07-23

5K0

没有更多了

社区活动

RAG七天入门训练营

鹅厂大牛手把手带你上手实战

Python精品学习库

代码在线跑，知识轻松学

博客搬家 | 分享价值百万资源包

自行/邀约他人一键搬运博客，速成社区影响力并领取好礼

技术创作特训营·精选知识专栏

往期视频·千货材料·成员作品最新动态