root
/
kafka
mirror of https://github.com/apache/kafka.git
1
0
Fork 0
Code Issues Actions 2 Packages Projects Releases Wiki Activity
kafka/examples
History
Divij Vaidya 6250049e10
KAFKA-13950: Fix resource leak in error scenarios (#12228) 
We are not properly closing Closeable resources in the code base at multiple places especially when we have an exception. This code change fixes multiple of these leaks.

Reviewers: Ismael Juma <ismael@juma.me.uk>, Luke Chen <showuon@gmail.com>, Mickael Maison <mickael.maison@gmail.com>
 		2023-12-21 13:47:22 +01: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-13950: Fix resource leak in error scenarios (#12228) 2023-12-21 13:47:22 +01: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.

  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.