Liking cljdoc? Tell your friends :D

fr33m0nk/clj-alpakka-kafka

clj-alpakka-kafka is a a simple library that wraps over Alpakka Kafka and offers convenience methods for easy implementation in Clojure code. For further documentation, do refer Alpakka Kafka official docs.

Clojars Project

Usage

Functions are divided in following namespaces:

Add the following to your project dependencies:

  • CLI/deps.edn dependency information
net.clojars.fr33m0nk/clj-alpakka-kafka {:mvn/version "0.1.4"}
  • Leningen/Boot
[net.clojars.fr33m0nk/clj-alpakka-kafka "0.1.4"]
  • Maven
<dependency>
  <groupId>net.clojars.fr33m0nk</groupId>
  <artifactId>clj-alpakka-kafka</artifactId>
  <version>0.1.4</version>
</dependency>
  • Gradle
implementation("net.clojars.fr33m0nk:clj-alpakka-kafka:0.1.4")

Additional dependencies:

org.apache.kafka/kafka-clients {:mvn/version "3.3.2"} 
  • SLF4J implentation based logger
    • Needed for Akka logging
com.taoensso/timbre {:mvn/version "6.1.0"}
com.fzakaria/slf4j-timbre {:mvn/version "0.3.21"}

Examples

  1. Using Alpakka Kafka stream with a sink
  2. Using Alpakka Kafka stream with a Kafka Producer

License

Copyright © 2023 Prashant Sinha

Distributed under the MIT License.

Can you improve this documentation?Edit on GitHub

cljdoc is a website building & hosting documentation for Clojure/Script libraries

× close