How to stop logstash gracefully when using kubernetes


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?

I would imagine a script that monitor logstash activtity ( redirected into a file or something ) to check for newlines ?

I don't really know if there is a built in way to check for logstash activity.

Good luck

This topic was automatically closed 28 days after the last reply. New replies are no longer allowed.