使用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
相关文章
相关标签/搜索