input {
  jdbc {
    jdbc_driver_library => "/config-dir/lib/mysql-connector-java-5.1.39-bin.jar"
    jdbc_driver_class => "com.mysql.jdbc.Driver"
    jdbc_connection_string => "jdbc:mysql://mysql:3306/db"
    jdbc_user => ""
    jdbc_password => ""
    type => "database"
    statement => "select * from test where id > :sql_last_value" # query should include sql_last_value
    schedule => "* * * * * *"
    jdbc_paging_enabled => true
    jdbc_page_size => "5000"
    use_column_value => true
    tracking_column => id
  }
}

output {
  file {
    path => "/opt/logstash/log.txt"
  }
  stdout {
    codec => rubydebug
  }
}