logstash2.conf

input {
  jdbc {
    jdbc_driver_library => "opt/logstash/mariadb-java-client-1.5.8.jar"
    jdbc_driver_class => "org.mariadb.jdbc.Driver"
    jdbc_connection_string => "jdbc:mariadb://212.129.16.243/crosswor_db"
    jdbc_user => "crosswor_db"
    jdbc_password => "jonian12"
    parameters => {
     }
    # schedule => "* * * * *"
    statement => "SELECT * FROM answers WHERE id > :sql_last_value"
    use_column_value => true
    tracking_column => id
  }
}

output {
  elasticsearch {
    hosts => ["192.168.0.109:9200"]
    index => "answers"
    document_type => "data"
    document_id => "%{id}"
  }
}