Search for 'kafka'
For details on the search query syntax, see the guide.
Total results: 249, showing 217 - 240
Note: artifacts in italics are non-canonical forks. See the wiki for more details.
A Clojure library for the Apache Kafka distributed streaming platform.
The patched Metrics v3 core library (com.yammer.metrics:metrics-core) shipped with Apache Kafka 0.8-trunk as of April
2013.
For more information, have a look at:
* http://mail-archives.apache.org/mod_mbox/incubator-kafka-users/201211.mbox/%3CCAOeJiJhEdyFq2x9xDX+opV1uCmP+5Bd3xMwsUZy48O9Y3XBScA@mail.gmail.com%3E
* https://issues.apache.org/jira/browse/KAFKA-635
Clojure wrapper for Kafka's Java API
The patched Metrics v3 annotation library (com.yammer.metrics:metrics-annotation) shipped with Apache Kafka 0.8-trunk as of April
2013.
For more information, have a look at:
* http://mail-archives.apache.org/mod_mbox/incubator-kafka-users/201211.mbox/%3CCAOeJiJhEdyFq2x9xDX+opV1uCmP+5Bd3xMwsUZy48O9Y3XBScA@mail.gmail.com%3E
* https://issues.apache.org/jira/browse/KAFKA-635
Clojure wrapper for Kafka's Java API
kafka step functions for titanoboa.io
Conqueress is a basic implementation of CQRS. This library helps kickstarting a project with Kafka by providing some standard usage patterns.
A Kafka Clojure Admin client, with support for topic, partition, group, cluster management, and more.
Kafka consumer emitting messages as Storm tuples
A Clojure library for the Apache Kafka distributed streaming platform.
Storm module for kafka > 0.8
Clojure to Java Interop Bindings for com.amazonaws.services.kafka
Kafka client for Clojure.
Some helpers to make work with Avro Schemas and Kafka easier
Central store for Kafka topics
Clojure wrapper for Kafka's Java API
Clojure wrapper for Kafka Streams
Kafka and Zookeeper embedded for unit testing
Apache Kafka proxy in clojure
Kafka Streams integration with Clojure transducers.