input{
    jdbc{
        jdbc_connection_string => "jdbc:mysql://188.166.237.247/flipshope"
        jdbc_user => "admin"
        jdbc_password => "swapnil@admin"
        jdbc_driver_library => "/home/pavanreddy/Downloads/FlipShope/mysql-connector-java-5.1.21.jar"
        jdbc_driver_class => "com.mysql.jdbc.driver"
        statement => "SELECT * FROM mobile_data"
    }
}

output{
    stdout  {   codec => json_lines }
    elasticsearch   {
        "hosts" => "localhost:9200"
        "index" => "test-migrate"
        "document_type" => "data"
    }
}