librdkafka - Apache Kafka C/C++ client library

Copyright (c) 2012-2015, Magnus Edenhill.

https://github.com/edenhill/librdkafka

librdkafka is a C library implementation of the Apache Kafka protocol, containing both Producer and Consumer support. It was designed with message delivery reliability and high performance in mind, current figures exceed 800000 msgs/second for the producer and 3 million msgs/second for the consumer.

librdkafka is licensed under the 2-clause BSD license.

For an introduction to the performance and usage of librdkafka, see INTRODUCTION.md

See the wiki for a FAQ.

NOTE: The master branch is actively developed, use latest release for production use.

Apache Kafka 0.9 support:

• Branch: master
• Producer: supported
• High-level balanced KafkaConsumer: supported
• Simple Consumer: supported
• Compression: snappy and gzip
• Broker version support: >=0.8
• Debian package: librdkafka1 and librdkafka-dev in Debian and Ubuntu
• ZooKeeper: not supported
• C API: Stable, ABI safe, backwards compatible with 0.8
• C++ API: Stable
• Tests: Regression tests in tests/ directory.
• Statistics: JSON formatted, see rd_kafka_conf_set_stats_cb in rdkafka.h.
• Status: Testing

Apache Kafka 0.8 support:

• Branch: 0.8
• Producer: supported
• High-level Consumer: not supported
• Simple Consumer: supported
• Compression: snappy and gzip
• Broker version support: >=0.8
• Debian package: librdkafka1 and librdkafka-dev in Debian and Ubuntu
• ZooKeeper: not supported
• C API: Stable, ABI safe, not backwards compatible with 0.7
• C++ API: Testing
• Tests: Regression tests in tests/ directory.
• Statistics: JSON formatted, see rd_kafka_conf_set_stats_cb in rdkafka.h.
• Status: Stable

Apache Kafka 0.7 support:

• Branch: 0.7
• Producer: supported
• High-level Consumer: not supported
• Simple Consumer: supported
• Compression: not supported
• Broker version support: 0.7.x
• ZooKeeper: not supported
• Status: Stable, Deprecated, Unsupported

#Language bindings#

• Haskell: haskakafka
• Haskell: haskell-kafka
• Node.js: node-kafka
• Lua: luardkafka
• OCaml: ocaml-kafka
• PHP: phpkafka
• PHP: php-rdkafka
• Python: python-librdkafka
• Python: PyKafka
• Ruby: Hermann
• Tcl: KafkaTcl

#Users of librdkafka#

• kafkacat - Apache Kafka swiss army knife
• Wikimedia's varnishkafka - Varnish cache web log producer
• Wikimedia's kafkatee - Kafka multi consumer with filtering and fanout
• rsyslog
• syslog-ng
• collectd
• logkafka - Collect logs and send to Kafka
• redBorder
• Headweb
• Produban's log2kafka - Web log producer
• fuse_kafka - FUSE file system layer
• node-kafkacat
• OVH - AntiDDOS
• otto.de's trackdrd - Varnish log reader
• large unnamed financial institution
• Let me know if you are using librdkafka

Usage

Requirements

The GNU toolchain
GNU make
pthreads
zlib (optional, for gzip compression support)
libssl-dev (optional, for SSL support)
libsasl2-dev (optional, for SASL support)

Instructions

Building

  ./configure
  make
  sudo make install

NOTE: See README.win32 for instructions how to build on Windows with Microsoft Visual Studio.

Usage in code

See examples/rdkafka_example.c for an example producer and consumer.

Link your program with -lrdkafka -lz -lpthread -lrt.

Documentation

The public APIs are documented in their respective header files:

• The C API is documented in src/rdkafka.h
• The C++ API is documented in src-cpp/rdkafkacpp.h

To generate Doxygen documents for the API, type:

make docs

Configuration properties are documented in CONFIGURATION.md

For a librdkafka introduction, see INTRODUCTION.md

Examples

See the examples/sub-directory.

Tests

See the tests/sub-directory.

Support

File bug reports, feature requests and questions using GitHub Issues

Questions and discussions are also welcome on irc.freenode.org, #apache-kafka, nickname Snaps.

Commercial support

Commercial support is available from Edenhill services