Gregor 0.7.1-SNAPSHOT
Released under the Eclipse Public License
Lightweight Clojure bindings for Kafka 1.0+.
Installation
To install, add the following dependency to your project or build file:
[io.weft/gregor "0.7.1-SNAPSHOT"]
Namespaces
gregor.core
Public variables and functions:
- ->producer-record
- assign!
- assignment
- Closeable
- commit-offsets!
- commit-offsets-async!
- committed
- consumer
- consumer-record->map
- create-topic
- delete-topic
- flush
- offset-and-metadata
- pause
- poll
- position
- producer
- rack-aware-modes
- records
- resume
- seek!
- seek-to!
- send
- send-then
- subscribe
- subscription
- topic-exists?
- topic-partition
- topics
- unsubscribe
- wakeup
- with-zookeeper