使用kafka connect將MySQL數據導入kafka

一、kafka1.0版本以上(bin目錄包含connect，conf目錄包含connect) 二、下載kafka-connect-jdbc插件https://www.confluent.io/hub/ 解壓獲得如下目錄結構: html 三、將插件中lib裏面的jar文件提取出來，放到kafka的libs目錄 四、複製Java的MySQL驅動包到kafka的libs目錄 五、將kafka-conne

>>阅读原文<<