input {
jdbc {
    jdbc_driver_library => "/usr/share/elasticsearch/plugins/river-jdbc/mysql-connector-java-5.1.43-bin.jar"
    jdbc_driver_class => "com.mysql.jdbc.Driver"
    jdbc_connection_string => "jdbc:mysql://dbserver.com:3306/database?zeroDateTimeBehavior=convertToNull"
    jdbc_user => "user"
    jdbc_password => "pass"
    schedule => "* * * * *"
    statement => "select * from table1"
    type => "events"
    #document_id => "%{table1_id}"
  }
jdbc {
    jdbc_driver_library => "/usr/share/elasticsearch/plugins/river-jdbc/mysql-connector-java-5.1.43-bin.jar"
    jdbc_driver_class => "com.mysql.jdbc.Driver"
    jdbc_connection_string => "jdbc:mysql://dbserver.com:3306/database?zeroDateTimeBehavior=convertToNull"
    jdbc_user => "user"
    jdbc_password => "password"
    schedule => "* * * * *"
    statement => "select * from table2"
    type => "events_seating"
    #document_id => "%{table2_id}"
  }


}
output {
elasticsearch {
                index => "indexname"
                hosts => "localhost:9200"
                #document_id => "%{id}"
     }
}