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
1