we have ambari cluster with 3 kafka brokers
we noticed from server.log about many corrupted files
actually we can capture the corrupted files PATH from the server.log and try to removed/delete them
but there are many of corrupted files ,
so maybe other way that show/print all the kafka corrupted files
so then we can capture them and delete them from /var/kafka/kafka-logs/..../....