mirror of
https://github.com/apache/kafka.git
synced 2026-10-28 08:24:58 +08:00
## What changed - replace stale `topic1` references with the demo's actual `my-topic` topic name - correct the README wording from "to synchronous send" to "to synchronously send" - keep the Java example comments consistent with the README and `TOPIC_NAME` ## Why The producer/consumer example uses `my-topic`, but its documentation still referred to `topic1`. This mismatch could confuse users following the example. ## Validation - `./gradlew :examples:compileJava :examples:checkstyleMain spotlessCheck` - `git diff --check` Reviewers: Chia-Ping Tsai <chia7712@gmail.com>
611 B
611 B
Kafka client examples
This module contains some Kafka client examples.
- Start a local single-broker Kafka cluster with a plain listener configured on port 9092.
- Run
examples/bin/java-producer-consumer-demo.sh 10000to asynchronously send 10k records tomy-topicand consume them. - Run
examples/bin/java-producer-consumer-demo.sh 10000 syncto synchronously send 10k records tomy-topicand consume them. - Run
examples/bin/exactly-once-demo.sh 6 3 10000to create input-topic and output-topic with 6 partitions each, start 3 transactional application instances and process 10k records.