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.cbut 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.
For Admin API examples see:
- delete_records.c - Delete records.
- list_consumer_groups.c - List consumer groups.
- describe_consumer_groups.c - Describe consumer groups.
- describe_topics.c - Describe topics.
- describe_cluster.c - Describe cluster.
- list_consumer_group_offsets.c - List offsets of a consumer group.
- alter_consumer_group_offsets.c - Alter offsets of a consumer group.
- incremental_alter_configs.c - Incrementally alter resource configurations.
- user_scram.c - Describe or alter user SCRAM credentials.