Google Git
Sign in
apache / kafka / 6b128d7e30cb654f26f11ae650465aa3caa38185 / . / examples
tree: 58e17e8cddd3689856aff5bd45410cc2d7a3e659 [path history] [tgz]
  1. bin/
  2. src/
  3. README.md
examples/README.md

Kafka client examples

This module contains some Kafka client examples.

  1. Start a Kafka 2.5+ local cluster with a plain listener configured on port 9092.
  2. Run examples/bin/java-producer-consumer-demo.sh 10000 to asynchronously send 10k records to topic1 and consume them.
  3. Run examples/bin/java-producer-consumer-demo.sh 10000 sync to synchronous send 10k records to topic1 and consume them.
  4. Run examples/bin/exactly-once-demo.sh 6 3 10000 to create input-topic and output-topic with 6 partitions each, start 3 transactional application instances and process 10k records.