mirrors/kafka

0 Fork 0

mirror of https://github.com/apache/kafka.git synced 2026-10-28 16:35:34 +08:00

Files

T

Maros Orsak 4e18307c2b MINOR: Update collections with Java 11 equivalents in generator, examples, and jmh-benchmarks (#21620 )

This PR is one of the upcoming trying to modernise the code of the
Kafka. I have started with smaller modules.

Reviewers: Christo Lolov <lolovc@amazon.com>, Chia-Ping Tsai
 <chia7712@gmail.com>, Ken Huang <s7133700@gmail.com>

2026-03-06 02:36:44 +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

MINOR: Update collections with Java 11 equivalents in generator, examples, and jmh-benchmarks (#21620 )

2026-03-06 02:36:44 +08:00

README.md

KAFKA-14752: Kafka examples improvements - demo changes (#13517 )

2023-05-12 10:39:12 +08:00

README.md

Kafka client examples

This module contains some Kafka client examples.

Start a Kafka 2.5+ local cluster with a plain listener configured on port 9092.
Run examples/bin/java-producer-consumer-demo.sh 10000 to asynchronously send 10k records to topic1 and consume them.
Run examples/bin/java-producer-consumer-demo.sh 10000 sync to synchronous send 10k records to topic1 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.