search

logstash-plugins / logstash-input-kinesis

Logstash Plugin for AWS Kinesis Input
Apache License 2.0
45 stars 57 forks source link

logstash inflight events handling in case of logstash stopped #72

Open burghategaurao opened 5 years ago

burghategaurao commented 5 years ago

We are using logstash distributed pattern as below

main.conf input {kinesis } output { if condition 1 then pipeline 1 else if condition 2 then pipeline 2 }

pipeline1.conf input {pipeline1} filter {} output {amazonES}

We are using persistent queue with queue size as more than 64MB. We have almost 100 pipelines in main.conf.We are running this config in docker on ec2 linux instance. Now our question is if our ec2 terminated, then Will we loose inflight events which are read by kinesis input plugin but not pushed to amazon es.

infa-ddeore commented 4 years ago

i need answer for the same, asked in https://discuss.elastic.co/t/is-pq-needed-for-logstash-kinesis-input-plugin/225970, no reply yet on this