Running PQ utilitiesedit
In the event of persistent queue corruption, the pqcheck and pqrepair tools are available for troubleshooting.
Run pqcheck to identify corrupted files:
kubectl exec logstash-0 -it -- /usr/share/logstash/bin/pqcheck /usr/share/logstash/data/queue/pipeline_id
Run pqrepair to repair the queue:
kubectl exec logstash-0 -it -- /usr/share/logstash/bin/pqrepair /usr/share/logstash/data/queue/pipeline_id