Kinsky 0.1.23
Kafka clojure client library
Installation
To install, add the following dependency to your project file:
[spootnik/kinsky "0.1.23"]
Namespaces
kinsky.async
Clojure core.async support in kinsky. See https://github.com/pyr/kinsky for example usage.
kinsky.client
Small clojure shim on top of the Kafka client API See https://github.com/pyr/kinsky for example usage.
Public variables and functions:
- ->deserializer
- ->offset-metadata
- ->record
- ->serializer
- ->topic-partition
- ->topics
- consumer
- consumer->driver
- consumer-records->data
- ConsumerDriver
- cr->data
- deserializer
- deserializers
- edn-deserializer
- edn-serializer
- GenericDriver
- json-deserializer
- json-serializer
- keyword-deserializer
- keyword-serializer
- MetadataDriver
- node->data
- opts->props
- partition-info->data
- producer
- producer->driver
- ProducerDriver
- rebalance-listener
- record-xform
- safe-poll!
- serializer
- serializers
- string-deserializer
- string-serializer
- topic-partition->data