Kafka producer(scala版)

一、簡介 上一篇blog提到用Flink消費Kafka的數據，kafka的produce是用kafka console produce的。今天主要測試下kafka的produce程序（scala編寫），模擬在應用服務器上日誌的收集，看看Flink可否正常消費數據。html 這裏的producer實現了每隔3秒去查找特定目錄下的文件，將文件的內容批量produce到kafka（async），而後將文

>>阅读原文<<