bin\logstash-plugin.bat install logstash-input-jdbc
Move the
mysql-connector-java.jar
file to thelib
folder
# Sample Logstash configuration for creating a simple
# Beats -> Logstash -> Elasticsearch pipeline.
input {
jdbc {
jdbc_driver_library => "D:/app/tool/logstash-8.14.1/lib/mysql-connector-java-5.1.49.jar"
jdbc_driver_class => "com.mysql.jdbc.Driver"
jdbc_connection_string => "jdbc:mysql://127.0.0.1:3306/pet"
jdbc_user => "root"
jdbc_password => "root"
schedule => "* * * * *"
statement => "SELECT id, menu_name FROM top_menu"
}
beats {
port => 5044
}
}
output {
elasticsearch {
hosts => ["http://localhost:9200"]
index => "%{[@metadata][beat]}-%{[@metadata][version]}-%{+YYYY.MM.dd}"
document_id => "%{id}"
#user => "elastic"
#password => "changeme"
}
}
logstash.bat -f \app\tool\logstash-8.14.1\config\logstash.conf
curl http://localhost:9200/tb_publishings/_search?pretty