1 input {

 2   jdbc {

 3     jdbc_driver_library => "/home/elastic/mysql-connector-java-5.1.30.jar"

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

 5     jdbc_connection_string => "jdbc:mysql://localhost:3306/myes"

 6     jdbc_user => "root"

 7     jdbc_password => "gaofeng****"

 8     schedule => "*/2 * * * *"

 9     use_column_value => false

10     tracking_column => "update_date"

11     statement => "SELECT * from app_stat where update_date > :sql_last_value"

12   }

13 }

14

15

16  output{

17

18         elasticsearch {

19                 hosts => ["127.0.0.1:9200"]

20                 index => "myes"

21     }

22

23         stdout {

24           codec => json_lines

25         }

26 }