/try-kafka-streams

Primary LanguageJava

Manually testing

Start the Docker composition and then start three sessions:

Producer

docker exec -it try-kafka-stream_kafka_1 \
  kafka-console-producer --broker-list localhost:9092 \
  --topic words

Consumer - uppercase

docker exec -it try-kafka-stream_kafka_1 \
  kafka-console-consumer --bootstrap-server localhost:9092 \
  --topic upper_words

Consumer - word count

docker exec -it try-kafka-stream_kafka_1 \
  kafka-console-consumer --bootstrap-server localhost:9092 \
  --topic word_counts --property print.key=true

Topics created by this application

  • try-kafka-streams-word-counts-changelog
  • try-kafka-streams-words-repartition
  • upper_words
  • word_counts
  • words