• Home
  • History
  • Annotate
Name Date Size #Lines LOC

..03-May-2022-

.gitignoreH A D10-Dec-2021255 1413

MakefileH A D10-Dec-20213.9 KiB11387

README.mdH A D10-Dec-20211.9 KiB3024

consumer.cH A D10-Dec-20219.9 KiB263117

delete_records.cH A D10-Dec-20218.8 KiB234112

globals.jsonH A D10-Dec-2021415 1211

idempotent_producer.cH A D10-Dec-202113.7 KiB348123

kafkatest_verifiable_client.cppH A D10-Dec-202128 KiB960670

openssl_engine_example.cppH A D10-Dec-20218.2 KiB263180

producer.cH A D10-Dec-20219.7 KiB24991

producer.cppH A D10-Dec-20217.6 KiB23091

rdkafka_complex_consumer_example.cH A D10-Dec-202119.5 KiB629467

rdkafka_complex_consumer_example.cppH A D10-Dec-202112.8 KiB471334

rdkafka_consume_batch.cppH A D10-Dec-20216.9 KiB261158

rdkafka_example.cH A D10-Dec-202125.7 KiB859626

rdkafka_example.cppH A D10-Dec-202119.5 KiB692489

rdkafka_performance.cH A D10-Dec-202153.4 KiB1,7241,324

transactions-older-broker.cH A D10-Dec-202126.1 KiB671369

transactions.cH A D10-Dec-202125.7 KiB670379

win_ssl_cert_store.cppH A D10-Dec-202116.8 KiB425283

README.md

1# librdkafka examples
2
3This directory contains example applications utilizing librdkafka.
4The examples are built by running `make` and they will be be linked
5statically or dynamically to librdkafka in the parent `../src` directory.
6
7Begin with the following examples:
8
9 * [consumer.c](consumer.c) - a typical C high-level consumer application.
10 * [producer.c](producer.c) - a typical C producer application.
11 * [producer.cpp](producer.cpp) - a typical C++ producer application.
12 * [idempotent_producer.c](idempotent_producer.c) - Idempotent producer.
13 * [transactions.c](transactions.c) - Full exactly once semantics (EOS)
14                                      transactional consumer-producer exammple.
15                                      Requires Apache Kafka 2.5 or later.
16 * [transactions-older-broker.c](transactions-older-broker.c) - Same as
17   `transactions.c` but for Apache Kafka versions 2.4.x and older which
18   lack KIP-447 support.
19
20
21For more complex uses, see:
22 * [rdkafka_example.c](rdkafka_example.c) - simple consumer, producer, metadata listing, kitchen sink, etc.
23 * [rdkafka_example.cpp](rdkafka_example.cpp) - simple consumer, producer, metadata listing in C++.
24 * [rdkafka_complex_consumer_example.c](rdkafka_complex_consumer_example.c) - a more contrived high-level C consumer example.
25 * [rdkafka_complex_consumer_example.cpp](rdkafka_complex_consumer_example.cpp) - a more contrived high-level C++ consumer example.
26 * [rdkafka_consume_batch.cpp](rdkafka_consume_batch.cpp) - batching high-level C++ consumer example.
27 * [rdkafka_performance.c](rdkafka_performance.c) - performance, benchmark, latency producer and consumer tool.
28 * [kafkatest_verifiable_client.cpp](kafkatest_verifiable_client.cpp) - for use with the official Apache Kafka client system tests.
29 * [openssl_engine_example.cpp](openssl_engine_example.cpp) - metadata listing in C++ over SSL channel established using OpenSSL engine.
30