We are running logstash as statefulset over k8s. I am looking for a way to stop logstash only after it finish process all in-flight events.
We already use:
enable_auto_commit => "false"
for kafka input so I guess that cover kafka, what can we do as general scenario?
Apache, Apache Lucene, Apache Hadoop, Hadoop, HDFS and the yellow elephant
logo are trademarks of the
Apache Software Foundation
in the United States and/or other countries.