Fully native Apache Kafka client offering synchronous and asynchronous messaging, leveraging coroutines and native memory model for high performance. Supports polling, headers enrichment, and error handling.
Fully Native Apache Kafka client for Kotlin Native. Uses native c-interop with highly performant and reliable librdkafka C client library. This library contains no JVM dependencies, no jvm runtime required. It uses Kotlin Native memory model and for non-blocking interaction with native callbacks and asynchronous workers.
We will be glad if you will test kafka-kotlin-native or contribute to this project.
In case you don't have much time for this - at least spend 5 seconds to give us a star to attract other contributors!
Thanks! :pray: :partying_face:
Special thanks to those awesome developers who give us great suggestions, help us to maintain and improve this project: @olonho, @akuleshov7.
The code has both common and native parts. It can be built for each platform for which librdkafka has support. Currently, this is Linux, Windows and Mac OSX.
For more information about platforms and how to install librdkafka see librdkafka installation
The library is hosted on the Maven Central.
To import kafka-kotlin-native library you need to add following dependency to your code:
<dependency>
<groupId>com.icemachined</groupId>
<artifactId>kafka-client</artifactId>
<version>0.2.0</version>
</dependency>
implementation 'com.icemachined:kafka-client:0.2.0'
implementation("com.icemachined:kafka-client:0.2.0")
See example of usage in example project This example shows how to start/stop producer and consumer and how to configure it.
Surfaced from shared tags and platforms — no rankings paid for.