Kafka producer(scala版)

一、简介 上一篇blog提到用Flink消费Kafka的数据，kafka的produce是用kafka console produce的。今天主要测试下kafka的produce程序（scala编写），模拟在应用服务器上日志的收集，看看Flink可否正常消费数据。html 这里的producer实现了每隔3秒去查找特定目录下的文件，将文件的内容批量produce到kafka（async），而后将文

>>阅读原文<<