Categories
Development

How to send data from HTTP input to ElasticSearch using Logstash ans jdbc_streaming filter?

I want to send data from Http to elasticsearch using logstash and I want to enrich my data using jdbc_streaming filter plugin. This is my logstash config: input { http { id => “sensor_data_http_input” user => “sensor_data” password => “sensor_data” } } filter { jdbc_streaming { jdbc_driver_library => “E:\ElasticStack\mysql-connector-java-8.0.18\mysql-connector-java-8.0.18.jar” jdbc_driver_class => “com.mysql.jdbc.Driver” jdbc_connection_string => “jdbc:mysql://localhost:3306/sensor_metadata” […]