hoose

通常，我们写一段flink stream api代码类型如下： 熟悉flink的人都知道，最后这行代码env.execute(topics);实际上是把我们的代码提交到环境上...

hoose

写的不错，加油，我看好你

3.Kafka源码深入解析之元数据结构

前面我们讲到，在KafkaProducer初始化时，初始化了一个非常核心的组件Metadata 这个组件前面也详细说明过，是去broker上 拉取一次集群的元数据过来的，我...

hoose

713 1 1

hoose

加油，写的很好

7.Kafka源码深入解析之发送消息01

上一章节我们重点分析了获取消息的分区号，这样我们才知道消息到底要发送到哪个broker上，对吧，同时我们看到后面把消息封装到一个TopicPartition对象 接下来，我们...

hoose

265 2 1

hoose

上一章节我们重点分析了获取消息的分区号，这样我们才知道消息到底要发送到哪个broker上，对吧，同时我们看到后面把消息封装到一个TopicPartition对象 接下来，我们...

hoose

上一章节我们详细 分析了Kafka在发送消息的时候，是如何拉取元数据的，正如我们源码里doSend()里waitOnMetadata介绍的： 接下是key,value的序列化...

hoose

metadata.max.age.ms //缺省300000，即10分钟1次
五分钟一次吧，
写的不错，赞，快达到我水平的十分之一了，加油😊

Kafka源码深度解析－序列2 －Producer －Metadata的数据结构与读取、更新策略

在上一篇，我们从使用方式和策略上，对消息队列做了一个宏观描述。从本篇开始，我们将深入到源码内部，仔细分析Kafka到底是如何实现一个分布式消息队列。我们的分析将从Produc...

编码前线

506 1 2

hoose

在上一篇，我们从使用方式和策略上，对消息队列做了一个宏观描述。从本篇开始，我们将深入到源码内部，仔细分析Kafka到底是如何实现一个分布式消息队列。我们的分析将从Produc...

hoose

上一节我们详细解析了生产端在发消息的dosend()里，首先是拉取元数据信息，在拉取过程中，先唤醒了sender线程，接着主线程进入等待状态，直到sender线程拉取元数据成...

hoose

上一节我们详细解析了生产端拉取元数据的数据结构，其实也可以看出来，无非就是topic ,partition,node之间的对应关系，同时我们在第二章节KafkaProduce...

hoose

前面我们讲到，在KafkaProducer初始化时，初始化了一个非常核心的组件Metadata 这个组件前面也详细说明过，是去broker上 拉取一次集群的元数据过来的，我...

hoose

上一节我们讲到了在KafkaProducer初始化的时候，初始化了三个组件： 分区器Partitioner 序列化器Serializer 拦截器Interceptor 接下来...

hoose

当我们学习Kafka时，通常写kafka producer api如下面简单的代码： 从上面的API可以看到其中一个非常重要的对象： KafkaProducer produ...