写在开头 好久没有去写博客了,最近一年发生了太多事情,感觉自己需要好好沉淀和消化这些,也更加需要去思考未来的路该如何去走,趁着这段时间比较空闲,写几篇关于spring的知识点...

写在开头 好久没有去写博客了,最近一年发生了太多事情,感觉自己需要好好沉淀和消化这些,也更加需要去思考未来的路该如何去走,趁着这段时间比较空闲,写几篇关于spring的知识点...
上一章节我们重点分析了获取消息的分区号,这样我们才知道消息到底要发送到哪个broker上,对吧,同时我们看到后面把消息封装到一个TopicPartition对象 接下来,我们...
上一节我们详细解析了生产端在发消息的dosend()里,首先是拉取元数据信息,在拉取过程中,先唤醒了sender线程,接着主线程进入等待状态,直到sender线程拉取元数据成...
上一节我们详细解析了生产端拉取元数据的数据结构,其实也可以看出来,无非就是topic ,partition,node之间的对应关系,同时我们在第二章节KafkaProduce...
前面我们讲到,在KafkaProducer初始化时,初始化了一个非常核心的组件Metadata 这个组件前面也详细说明过,是去broker上 拉取一次集群的元数据过来的,我...
当我们学习Kafka时,通常写kafka producer api如下面简单的代码: 从上面的API可以看到其中一个非常重要的对象: KafkaProducer produ...
上一节我们讲到了在KafkaProducer初始化的时候,初始化了三个组件: 分区器Partitioner 序列化器Serializer 拦截器Interceptor 接下来...
上一章节我们详细 分析了Kafka在发送消息的时候,是如何拉取元数据的,正如我们源码里doSend()里waitOnMetadata介绍的: 接下是key,value的序列化...
下载 到 https://github.com/protocolbuffers/protobuf/releases 选择下载最新的protoc-3.6.1-osx-x86_6...