topic

#!/bin/bash

if [[ "$KAFKAS" == '' ]]; then
    echo 'KAFKAS env var not set'
    exit 1
fi

# topic list
# topic create hithere
# topic delete hithere
# topic write hithere
#   key
#   value
#   ^D
# topic read hithere

operation="$1"
topic="$2"

set -x
case "$operation" in
    list | ls)
        kafka-topics.sh --bootstrap-server $KAFKAS --list
        ;;

    create | add | mk | new)
        kafka-topics.sh --bootstrap-server $KAFKAS --create --topic "$topic" --partitions 3 --replication-factor 3
        ;;

    delete | remove | rm | del)
        kafka-topics.sh --bootstrap-server $KAFKAS --delete --topic "$topic"
        ;;

    describe | desc | show )
        kafka-topics.sh --bootstrap-server $KAFKAS --describe --topic "$topic"
        ;;

    write)
        kafka-console-producer.sh --bootstrap-server $KAFKAS --topic $topic
        ;;

    read)
        kafka-console-consumer.sh --bootstrap-server $KAFKAS --topic $topic --from-beginning --property print.timestamp=true
        ;;

    *)
        ;;

esac