Name | Date | Size | #Lines | LOC | ||
---|---|---|---|---|---|---|
.. | 03-May-2022 | - | ||||
.gitignore | H A D | 10-Dec-2021 | 255 | 14 | 13 | |
Makefile | H A D | 10-Dec-2021 | 3.9 KiB | 113 | 87 | |
README.md | H A D | 10-Dec-2021 | 1.9 KiB | 30 | 24 | |
consumer.c | H A D | 10-Dec-2021 | 9.9 KiB | 263 | 117 | |
delete_records.c | H A D | 10-Dec-2021 | 8.8 KiB | 234 | 112 | |
globals.json | H A D | 10-Dec-2021 | 415 | 12 | 11 | |
idempotent_producer.c | H A D | 10-Dec-2021 | 13.7 KiB | 348 | 123 | |
kafkatest_verifiable_client.cpp | H A D | 10-Dec-2021 | 28 KiB | 960 | 670 | |
openssl_engine_example.cpp | H A D | 10-Dec-2021 | 8.2 KiB | 263 | 180 | |
producer.c | H A D | 10-Dec-2021 | 9.7 KiB | 249 | 91 | |
producer.cpp | H A D | 10-Dec-2021 | 7.6 KiB | 230 | 91 | |
rdkafka_complex_consumer_example.c | H A D | 10-Dec-2021 | 19.5 KiB | 629 | 467 | |
rdkafka_complex_consumer_example.cpp | H A D | 10-Dec-2021 | 12.8 KiB | 471 | 334 | |
rdkafka_consume_batch.cpp | H A D | 10-Dec-2021 | 6.9 KiB | 261 | 158 | |
rdkafka_example.c | H A D | 10-Dec-2021 | 25.7 KiB | 859 | 626 | |
rdkafka_example.cpp | H A D | 10-Dec-2021 | 19.5 KiB | 692 | 489 | |
rdkafka_performance.c | H A D | 10-Dec-2021 | 53.4 KiB | 1,724 | 1,324 | |
transactions-older-broker.c | H A D | 10-Dec-2021 | 26.1 KiB | 671 | 369 | |
transactions.c | H A D | 10-Dec-2021 | 25.7 KiB | 670 | 379 | |
win_ssl_cert_store.cpp | H A D | 10-Dec-2021 | 16.8 KiB | 425 | 283 |
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