kafka producer / listener

kafka_producer_listener.sh

#! /bin/sh

if [ $# -lt 2 ]; then
  echo "$0 container topic"
  exit 1
fi

# listener
CONTAINER="$1"
TOPIC="$2"

docker exec -it "$CONTAINER" kafka-console-consumer.sh --topic "$TOPIC" --bootstrap-server localhost:`docker port "$CONTAINER" | cut -d ':' -f 2`

# producer
CONTAINER="$1"
TOPIC="$2"

docker exec -it "$CONTAINER" kafka-console-producer.sh --topic "$TOPIC" --property parse.key=true --property key.separator=, --broker-list localhost:`docker port "$CONTAINER" | cut -d ':' -f 2`