input {
stdin {
  }
jdbc {
jdbc_connection_string=>"jdbc:mysql://localhost:3306/jy_brand?useUnicode=true&characterEncoding=utf-8&useSSL=true&serverTimezone=UTC"# the user we wish to excute our statement asjdbc_user=>"root"jdbc_password=>123456# the path to our downloaded jdbc driver  jdbc_driver_library=>"F:/develop/maven/repository3/mysql/mysql-connector-java/5.1.41/mysql-connector-java-5.1.41.jar"# the name of the driver class for mysqljdbc_driver_class=>"com.mysql.jdbc.Driver"jdbc_paging_enabled=>"true"jdbc_page_size=>"50000"#要执行的sql文件#statement_filepath => "/conf/course.sql"statement=>"select * from course_pub where timestamp > date_add(:sql_last_value,INTERVAL 8 HOUR)"#定时配置schedule=>"* * * * *"record_last_run=>truelast_run_metadata_path=>"D:/ElasticSearch/logstash-6.2.1/config/logstash_metadata"  }
}
output {
elasticsearch {
#ES的ip地址和端口hosts=>"localhost:6200"#hosts => ["localhost:6200","localhost:6202","localhost:6203"]#ES索引库名称index=>"jy_brand"document_id=>"%{id}"document_type=>"doc"template=>"D:/ElasticSearch/logstash-6.2.1/config/jy_brand_template.json"template_name=>"jy_brand"template_overwrite=>"true"  }
stdout {
#日志输出codec=>json_lines  }
}