suyograo

input {
  beats {
    port => 5044
  }
  jdbc {
    jdbc_driver_library => '/Users/suyog/demos/mysql-connector-java-5.1.39-bin.jar'
    jdbc_driver_class => "com.mysql.jdbc.Driver"
    jdbc_connection_string => "jdbc:mysql://localhost:3306/testme"
    jdbc_user => "logstash"
    statement => "SELECT * from tweet_analysis"