【文件属性】：
文件名称：Flume 抽取MYSQL Oracle数据 JSON格式 推送Kafka
文件大小：210.56MB
文件格式：TAR
更新时间：2022-05-28 15:07:26
kafka flume mysql oracle json
Flume二次开发，支持抽取MYSQL Oracle数据库数据 以JSON格式推送至Kafka。
demo：
sql_json.sources.sql_source.type = com.hbn.rdb.source.SQLSource
sql_json.sources.sql_source.connectionurl = jdbc:oracle:thin:@IP:PORT/orcl
sql_json.sources.sql_source.driverclass= oracle.jdbc.driver.OracleDriver
sql_json.sources.sql_source.filename = sqlSource.status
sql_json.sources.sql_source.customquery = SELECT INTID,ID_NO FROM TEST.TEST
sql_json.sources.sql_source.begin = 0
sql_json.sources.sql_source.autoincrementfield = INTID