为了账号安全,请及时绑定邮箱和手机立即绑定

网上下载的配置文件换行有问题,分享一份我本地修改后的配置

input {

  jdbc {

jdbc_driver_library => "F:\Respository\Maven\mysql\mysql-connector-java\8.0.15\mysql-connector-java-8.0.15.jar"

jdbc_driver_class => "com.mysql.cj.jdbc.Driver"

jdbc_connection_string => "jdbc:mysql://localhost:3306/test?serverTimezone=Asia/Shanghai&characterEncoding=utf-8&useSSL=false&allowPublicKeyRetrieval=true"

jdbc_user => "root"

jdbc_password => "Mysql.1236121273.."

schedule => "* * * * *"

statement => "SELECT (p.id+pw.id) id,p.id pid,p.first_name,p.last_name,p.age,p.about,pw.id pw_id,pw.wife_name,pw.wife_age FROM person p LEFT JOIN person_wife pw ON p.id = pw.person_id where (p.update_time >=:sql_last_value and p.update_time<now()) or (pw.update_time >=:sql_last_value and p.update_time<now())"

  }

}


output {

  elasticsearch {

    index => "my_index"

document_type => "_doc"

document_id => "%{id}"

hosts => ["localhost:9200"]

  }

}


正在回答

1 回答

+1~

1 回复 有任何疑惑可以回复我~

举报

0/150
提交
取消

网上下载的配置文件换行有问题,分享一份我本地修改后的配置

我要回答 关注问题
意见反馈 帮助中心 APP下载
官方微信