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.
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.