franzy.admin.codec
Codec and supporting functionality for managing Kafka property-based configuration.
config-types
decode-xform
Transducer, applied on decode of collections that may be overriden using alter-var-root for example.
encode-config-type
(encode-config-type config-type)encode-security-protocol
(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
Maps Kafka Error codes to error keywords so you better know what’s going on.
FranzyScalaCodec
protocol
members
decode
(decode v)Decodes Kafka Scala admin client values to Clojure.
encode
(encode v)Encodes Clojure values into Kafka Scala admin client values.
map->topic-and-partition
(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
(sequential->topic-and-partitions topic-and-partitions)