Kafka - dump all topics

dump-all-topics.sh

#!/usr/bin/env bash

TOPICS=$(kubectl exec kafka-0 --namespace kafka -- ./opt/bitnami/kafka/bin/kafka-topics.sh --list --zookeeper kafka-zookeeper:2181 --exclude-internal)

while IFS= read -r topic; do    
    kubectl exec kafka-0 --namespace kafka -- ./opt/bitnami/kafka/bin/kafka-console-consumer.sh --bootstrap-server kafka:9092 --topic $topic --from-beginning --timeout-ms 5000 > /tmp/$topic   
done <<< "$TOPICS"