franzy.admin.codec — clj-kafka.franzy/admin 2.0.7

Codec and supporting functionality for managing Kafka property-based configuration.

config-types clj

decode-xform clj

Transducer, applied on decode of collections that may be overriden using alter-var-root for example.

encode-config-type clj

(encode-config-type config-type)

encode-security-protocol clj

(encode-security-protocol security-protocol)

Encodes a security protocol given either as a keyword, string, or SecurityProtocol value.

ex: :security-protocol/plaintext, :plaintext, plaintext, SecurityProtocol/PLAINTEXT

error-code->keywords clj

Maps Kafka Error codes to error keywords so you better know what's going on.

FranzyScalaCodec clj protocol

decode clj

(decode v)

Decodes Kafka Scala admin client values to Clojure.

encode clj

(encode v)

Encodes Clojure values into Kafka Scala admin client values.

map->topic-and-partition clj

(map->topic-and-partition {:keys [topic partition] :or {partition 0}})

Converts a map to a Topic and Partition.

Note: This is different from the Java APIs TopicPartition. Reusing the Java type would make too much sense, so the opposite has happened. Sponge left in the patient.

sequential->topic-and-partitions clj

(sequential->topic-and-partitions topic-and-partitions)