empty-kafka-queues.sh

    local TOPICS=($(cat "${DIR}/../../env/broker/kafka/docker-mounts/topics.txt" | awk 'BEGIN { FS="," } !/^$/{ print $1 }' | xargs))
    local OFFSET_FILE=/tmp/delete-offsets.json
    local NUM_TOPICS=${#TOPICS[@]}
    local TOPIC_INDEX=1

    echo -n "{\"partitions\":[" > $OFFSET_FILE
    for TOPIC in $TOPICS; do
      echo -n "{\"topic\":\"${TOPIC}\",\"partition\":0,\"offset\":-1}" >> $OFFSET_FILE
      if [[ $((TOPIC_INDEX + 1)) < $NUM_TOPICS ]]; then
        echo -n "," >> $OFFSET_FILE
      fi
      TOPIC_INDEX=$((TOPIC_INDEX + 1))
    done
    echo "],\"version\":1}" >> $OFFSET_FILE

    docker exec -t kafkalocal \
      /opt/kafka/bin/kafka-delete-records.sh \
      --bootstrap-server localhost:9092 \
      --offset-json-file $OFFSET_FILE