shorinji

    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