How we can chnage logstash config, so that when any updated record found in mysql database, logstash fetch only that. Is it possible.
my config. file is like this...
input {
jdbc {
jdbc_driver_library => "/root/mysql-connector-java-5.1.44/mysql-connector-java-5.1.44-bin.jar"
jdbc_driver_class => "com.mysql.jdbc.Driver"
jdbc_connection_string => "jdbc:mysql://localhost:3306/database"
jdbc_user => ""
jdbc_password => "*"
statement => "SELECT * FROM testing"
jdbc_paging_enabled => "true"
jdbc_page_size => "26000"
}
}
output {
elasticsearch {
action => "index"
hosts => ["localhost:9200"]
index => "test"
document_type => "product"
document_id => "%{id}"
}
stdout{
codec => json_lines
}
}