input {

  jdbc {

    jdbc_driver_library => "C:\Users\junhyeon.kim\Desktop\jar_data\mysql-connector-java-5.1.47\mysql-connector-java-5.1.47-bin.jar"

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

    jdbc_connection_string => "jdbc:mysql://localhost:3306/s20190106"

    jdbc_user => "root"

    jdbc_password => "1234"

    schedule => "* * * * *"

    statement => "SELECT * FROM t where nu >:sql_last_value"

    use_column_value => true

    tracking_column => "nu"

  }

}

filter {

  mutate {

    remove_field => ["@version", "@timestamp"]

  }

}

output {

  elasticsearch {

    hosts => "localhost"

    index => "test"

  }

}