Skip to content

Instantly share code, notes, and snippets.

Embed
What would you like to do?
# terminal 1: establish an interactive session with the kstreams app container
KSTREAMS_CONTAINER=$(docker container ls --filter name=streaming-stack_kstreams.1 --format "{{.ID}}")
docker logs ${KSTREAMS_CONTAINER} --follow
# terminal 2: establish an interactive session with the kafka container
KAFKA_CONTAINER=$(docker container ls --filter name=streaming-stack_kafka.1 --format "{{.ID}}")
docker exec -it ${KAFKA_CONTAINER} bash
# set environment variables used by jobs
export BOOTSTRAP_SERVERS="localhost:9092"
export INPUT_TOPIC="demo.purchases"
export OUTPUT_TOPIC="demo.running.totals"
# read topics from beginning
kafka-console-consumer.sh \
--topic $INPUT_TOPIC --from-beginning \
--bootstrap-server $BOOTSTRAP_SERVERS
kafka-console-consumer.sh \
--topic $OUTPUT_TOPIC --from-beginning \
--bootstrap-server $BOOTSTRAP_SERVERS
Sign up for free to join this conversation on GitHub. Already have an account? Sign in to comment