tonglin0325的个人主页

Kafka学习笔记——Producer API

参考kafka官方文档,版本1.0.x

1
2
http://kafka.apache.org/10/documentation.html#consumerapi

依赖,选择 Cloudera Rel 中的 1.0.1-kafka-3.1.0

1
2
3
4
5
6
<dependency>
<groupId>org.apache.kafka</groupId>
<artifactId>kafka-clients</artifactId>
<version>1.0.1-kafka-3.1.0</version>
</dependency>

Kafka的生产者配置

1
2
http://kafka.apache.org/10/documentation.html#producerconfigs

其中producer api中文含义参考:kafka系列七、kafka核心配置

producer是线程安全的,通常应该在所有线程之间共享,以获得最佳性能。producer管理着一个后台线程,该线程执行I/O操作,并与每个需要通信的broker建立TCP连接。如果使用后不能关闭producer,将会泄漏这些资源。