This directory contains example applications utilizing librdkafka.
The examples are built by running make
and they will be be linked
statically or dynamically to librdkafka in the parent ../src
directory.
Begin with the following examples:
- consumer.c - a typical C high-level consumer application.
- producer.c - a typical C producer application.
- producer.cpp - a typical C++ producer application.
- idempotent_producer.c - Idempotent producer.
- transactions.c - Full exactly once semantics (EOS) transactional consumer-producer exammple. Requires Apache Kafka 2.5 or later.
- transactions-older-broker.c - Same as
transactions.c
but for Apache Kafka versions 2.4.x and older which lack KIP-447 support. - misc.c - a collection of miscellaneous usage examples.
For more complex uses, see:
- rdkafka_example.c - simple consumer, producer, metadata listing, kitchen sink, etc.
- rdkafka_example.cpp - simple consumer, producer, metadata listing in C++.
- rdkafka_complex_consumer_example.c - a more contrived high-level C consumer example.
- rdkafka_complex_consumer_example.cpp - a more contrived high-level C++ consumer example.
- rdkafka_consume_batch.cpp - batching high-level C++ consumer example.
- rdkafka_performance.c - performance, benchmark, latency producer and consumer tool.
- kafkatest_verifiable_client.cpp - for use with the official Apache Kafka client system tests.
- openssl_engine_example.cpp - metadata listing in C++ over SSL channel established using OpenSSL engine.