Franzy 0.0.1
Clojure Kafka client with support for Kafka producer, consumer, rebalancing, administration, and validation.
Installation
To install, add the following dependency to your project or build file:
[ymilky/franzy "0.0.1"]
Topics
Namespaces
franzy.clients.codec
Encodes and decodes Java and Clojure types used with org.apache.kafka.common
Public variables and functions:
- consumer-record->map
- consumer-records->map
- decode-xf
- FranzCodec
- keyword->offset-reset-strategy
- lazy-consumer-records
- map->consumer-record
- map->node
- map->offset-metadata
- map->partition-info
- map->producer-record
- map->topic-partition
- map->topic-partition-offset-number
- map->topic-partition-offsets-map
- maps->topic-partition-array
- maps->topic-partitions
- node-maps->node-array
franzy.clients.consumer.results
Kafka result set (ConsumerRecords) implementations.
Public variables and functions:
franzy.clients.consumer.schema
Schemas for Kafka Consumers and related types.
franzy.clients.producer.partitioners
Partitioners used to partition topic partitions.
Public variables and functions:
franzy.clients.producer.schema
Schemas for Kafka Producers and related types.
Public variables and functions:
franzy.serialization.deserializers
Implementations of core Apache Kafka and Franzy deserializers. For more serializers, see Franzy docs.
franzy.serialization.serializers
Implementations of core Apache Kafka and Franzy serializers. For more serializers, see Franzy docs.