my.conf

input {
    jdbc {
        jdbc_connection_string => "jdbc:mysql://myhostmachine:3306/mydb"
        jdbc_user => "root"
        jdbc_password => "root"
        jdbc_validate_connection => true
        jdbc_driver_library => "/home/chamith/work/ELK/mysql_jar/mysql-connector-java-5.1.39-bin.jar"
        jdbc_driver_class => "com.mysql.jdbc.Driver"
        statement => "SELECT * from tablename"
		schedule => "* * * * *"
		jdbc_paging_enabled => "true"
		jdbc_page_size => "50000"
    }
}

filter {
		mutate {
    			add_field => [ "datetime", "%{created_date}" ]
				convert => { "amount" => "float" }
		}
		date {
    		locale => "en"
			timezone => "Pacific/Easter"
			match => ["datetime", "yyyy-MM-dd'T'HH:mm:ss.SSSZ"]
			target => "datetime"
		}
	}

output {
    elasticsearch {
        #protocol => http
        index => "payment_transaction5"
        document_type => "message_logs"
        document_id => "%{id_order}"
		action => index
		hosts => ["http://myhostmachine:9402"]
    }
}