Producer

Kafka源码的exmaple模块有一个Producer类，继承了Thread类，构造方法会指定topic，是否异步，是否幂等，配置Kafka集群信息，初始化一个KafkaProducer主线程，它会分别初始化一个拦截器，kv序列化器，分区选择器（均匀分配消息到不同分区，也可以使用自定义分区器指定），消息累加器RecordAccumulator（缓冲区）以及一个Sender子线程。Producer是一个线程，所以run方法里面，KafkaProducer将消息封装为ProducerRecord然后调用send方法带着指定的topic发送。

最新文章

1. 【Java并发编程实战】-----“J.U.C”：Semaphore
2. 我为什么要拒绝Ctrl+C和Ctrl+V？
3. 【代码笔记】iOS-饼图
4. java的文件流：字节流（FileInputStream、FileOutputStream）和字符流（FileReader、FileWriter）。
5. uva11426 GCD Extreme(II)
6. Ubuntu 13.10 PHP 5.5.x mcrypt missing – Fatal Error: Undefined function mcrypt_encrypt()!
7. Matlab图像处理系列4———傅立叶变换和反变换的图像
8. 统计SQLSERVER表行数，以及每天数据变化的行数
9. （转）Nginx与tomcat组合的简单使用
10. Java自己动手写连接池四
11. 笔记：Maven Web项目
12. java中八种基本数据类型以及它们的封装类，String类型的一些理解
13. [Swift]LeetCode515. 在每个树行中找最大值 | Find Largest Value in Each Tree Row
14. hql和sql练习题
15. Python如何发布程序
16. UVA-11214 Guarding the Chessboard （迭代加深搜索）
17. mysql binlog协议分析--具体event
18. PAT甲级1131. Subway Map
19. 我的javascript心跳机
20. Android Camera的使用（一） 读书笔记

热门文章

1. C# 调用c库
2. django项目中使用swagger来实现接口文档自动生成
3. libmodbus 源码分析转
4. 实践：带您用多种姿势将存储在腾讯云COS 上的视频播放
5. JDK、JRE、JVM和i++
6. JAVA远程调用 webService
7. k8s资源清单
8. （面试题）面试官为啥总是让我们手撕call、apply、bind?
9. aspx页面，Page_Load 无人进入，解决
10. ubuntu 20.04 基于kubeadm部署kubernetes 1.22.4集群—报错解决