mirrors/kafka

0 Fork 0

mirror of https://github.com/apache/kafka.git synced 2026-10-28 08:24:58 +08:00

Files

T

History

Aditya Kousik 6f3116b55d KAFKA-20684 [2/N]: Migrate examples to RebalanceListener (#23103 )

Switches the two example listeners to RebalanceListener and registers
them via setRebalanceListener. Comments now point at the
RebalanceConsumer parameter, which makes the operations they describe
actually reachable.

Reviewers: Chia-Ping Tsai <chia7712@gmail.com>

2026-08-11 11:59:09 +08:00

bin

KAFKA-9922: Update demo instructions in examples README (#8559 )

2020-04-29 19:31:26 -07:00

src/main/java/kafka/examples

KAFKA-20684 [2/N]: Migrate examples to RebalanceListener (#23103 )

2026-08-11 11:59:09 +08:00

README.md

KAFKA-18951 Correct topic name in client example docs (#22812 )

2026-07-17 06:08:30 +08:00

README.md

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 10000 to asynchronously send 10k records to my-topic and consume them.
Run examples/bin/java-producer-consumer-demo.sh 10000 sync to synchronously send 10k records to my-topic and consume them.
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.