CREATE TABLE `tb_test` (

  `id` bigint(20) NOT NULL AUTO_INCREMENT,

  `name` varchar(50) DEFAULT NULL,

  PRIMARY KEY (`id`)

) ENGINE=InnoDB DEFAULT CHARSET=utf8;

input {

        stdin{

        }

        jdbc {

          jdbc_connection_string => "jdbc:mysql://127.0.0.1:3306/elk?characterEncoding=UTF-8&useSSL=false"

          jdbc_user => "erp_test"

          jdbc_password => "erp_test@abc"

          jdbc_driver_library => "/home/es/logstash-6.2.2/lib/mysql-connector-java-5.1.46.jar"

          jdbc_driver_class => "com.mysql.jdbc.Driver"

          jdbc_paging_enabled => "true"

          jdbc_page_size => "10000"

          statement => "select * from tb_test"

          schedule => "* * * * *"

          type => "jbh_show"

        }

}

filter {

        json {

          source => "message"

          remove_field => ["message"]

        }

}

output {

        elasticsearch {

          hosts => ["localhost:9200"]

          index => "cmscontent"

          document_id => "%{id}"

        }

        stdout {

          codec => json_lines

        }

}