Jackdaw 0.6.0
Released under the BSD 3-clause
A Clojure library for the Apache Kafka distributed streaming platform.
Installation
To install, add the following dependency to your project or build file:
[fundingcircle/jackdaw "0.6.0"]
Topics
Namespaces
jackdaw.admin
Tools for administering or just interacting with a Kafka cluster.
jackdaw.client
Clojure wrapper to Kafka's consumer and producer APIs.
jackdaw.client.log
Extras for `jackdaw.client` for treating topics as seqs of records.
Public variables and functions:
jackdaw.client.partitioning
Extras for `jackdaw.client` which help you define record partitioning schemes as part of a topic's configuration.
Public variables and functions:
jackdaw.data
This namespace aims to provide `->T`, `(datafy T)`, and `data->T` as a round-tripping of Katka's (client) record types.
Public variables and functions:
- +broker-config-resource-type+
- +create-type-timestamp+
- +log-append-type-timestamp+
- +no-type-timestamp+
- +topic-config-resource-type+
- +unknown-config-resource-type+
- ->broker-resource
- ->topic-resource
- as-OffsetAndTimestamp
- as-TopicPartition
- Config->data
- ConfigEntry->data
- ConfigResource->data
- ConfigResourceType->data
- ConsumerRecord->data
- datafy
- DescribeClusterResult->data
- Node->data
- OffsetAndTimestamp->data
- PartitionInfo->data
- ProducerRecord->data
- Properties->data
- RecordMetadata->data
- TimestampType->data
- TopicDescription->data
- TopicPartition->data
- TopicPartitionInfo->data
jackdaw.serdes.avro
DEPRECATION NOTICE:
jackdaw.serdes.avro.schema-registry
Helpers for talking to one of Confluent's Avro schema registries.
Public variables and functions:
jackdaw.serdes.edn
Implements an EDN SerDes (Serializer/Deserializer).
Public variables and functions:
jackdaw.serdes.json
Implements a JSON SerDes (Serializer/Deserializer).
Public variables and functions:
jackdaw.streams
Kafka streams protocols.
Public variables and functions:
- aggregate
- branch
- close
- count
- filter
- filter-not
- flat-map
- flat-map-values
- for-each!
- global-ktable
- global-ktable*
- group-by
- group-by-key
- join
- join-global
- join-windowed
- kafka-streams
- kgroupedstream*
- kgroupedtable*
- kstream
- kstream*
- kstreams
- ktable
- ktable*
- left-join
- left-join-global
- left-join-windowed
- map
- map-values
- merge
- outer-join
- outer-join-windowed
- peek
- print!
- process!
- reduce
- select-key
- source-topics
- start
- state
- state->keyword
- streams-builder
- streams-builder*
- through
- to
- to-kstream
- transform
- transform-values
- window-by-session
- window-by-time
jackdaw.streams.configured
Clojure wrapper to kafka streams.
jackdaw.streams.interop
Clojure wrapper to kafka streams.
jackdaw.streams.lambdas
Wrappers for the Java 'lambda' functions.
jackdaw.test.middleware
A test machine executor can be built by composing execution wrappers defined in here
Public variables and functions: