参考kafka官方文档，版本1.0.x
1 | http://kafka.apache.org/10/documentation.html#consumerapi |
依赖，选择 Cloudera Rel 中的 1.0.1-kafka-3.1.0
1 | <dependency> |
Kafka的生产者配置
1 | http://kafka.apache.org/10/documentation.html#producerconfigs |
其中producer api中文含义参考：kafka系列七、kafka核心配置
producer是线程安全的，通常应该在所有线程之间共享，以获得最佳性能。producer管理着一个后台线程，该线程执行I/O操作，并与每个需要通信的broker建立TCP连接。如果使用后不能关闭producer，将会泄漏这些资源。
