input {
	stdin{}

	jdbc {
        jdbc_connection_string => "jdbc:mysql://127.0.0.1:3306/kylin?useUnicode=true&characterEncoding=UTF-8&serverTimezone=UTC"
        jdbc_user => "root"
        jdbc_password => "123456"
		jdbc_validate_connection => true
        jdbc_driver_library => "C:/maven-repository/mysql/mysql-connector-java/8.0.19/mysql-connector-java-8.0.19.jar"
        jdbc_driver_class => "com.mysql.cj.jdbc.Driver"
 		
		use_column_value => true
		tracking_column_type => timestamp
		tracking_column => "create_time"
		
		record_last_run => true
        last_run_metadata_path => "C:/logstash-7.8.1/config/station_parameter.txt"
		
        clean_run => false
		
		statement => "SELECT * FROM sys_user WHERE create_time > :sql_last_value"
        schedule => "/5 * * * * *"
        type => "kylin_user"
    }
	
}

filter {

    mutate {
		remove_field => ["@version","@timestamp"]
    }
}


output {

 if [type]=="kylin_user" {
    elasticsearch {
        hosts => ["127.0.0.1:9200"]
     	index => "kylin_user"
    }
  }
  
  stdout { codec => rubydebug }
}