input {
    jdbc {
        jdbc_connection_string => "jdbc:mysql://host:port/resrv"
        jdbc_user => "booker"
        jdbc_password => "rhkdrh123!@#"
        jdbc_driver_library => "jdbc"
        jdbc_driver_class => "com.mysql.jdbc.Driver"
        statement_filepath => "test.sql"
        lowercase_column_names => false
    }
}

filter {
  json {
    source => "message"
  }
}

output {
        stdout { codec => rubydebug }
        kafka {
                bootstrap_servers => 'host:9092'
                codec => plain {
                        format => "%{message}"
                }
                topic_id => 'logstash'
        }
}