上传者: ytp552200ytp
|
上传时间: 2022-05-28 17:03:15
|
文件大小: 210.56MB
|
文件类型: TAR
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