jackdaw.data — com.github.parkside-securities/jackdaw 0.8.1-rc7

This namespace aims to provide ->T, (datafy T), and data->T as a round-tripping of Katka's (client) record types.

Note that for some types, particularly Kafka's -Result types no ->T constructors are provided as there are no consumers within the Kafka API for these records they are merely packed results.

For compatibility with Clojure before 1.10.0, a datafy function is provided. On 1.10 or after, it simply defers to clojure.datafy/datafy but before 1.10 it acts as a backport thereof.

+broker-config-resource-type+ clj

+create-type-timestamp+ clj

A timestamp type associated with the timestamp being from the record's creation. That is, the record timestamp was user supplied.

+log-append-type-timestamp+ clj

A timestamp type associated with the timestamp having been generated by Kafka when the record was produced, not having been specified by the user when the record was created.

+no-type-timestamp+ clj

A timestamp type associated with... not having a timestamp type.

+topic-config-resource-type+ clj

+unknown-config-resource-type+ clj

->broker-resource clj

(->broker-resource name)

->topic-resource clj

(->topic-resource name)

as-OffsetAndTimestamp clj

(as-OffsetAndTimestamp ot)

as-TopicPartition clj

(as-TopicPartition o)

Config clj

Config->data clj

(Config->data c)

ConfigEntry->data clj

(ConfigEntry->data e)

ConfigResource->data clj

(ConfigResource->data cr)

ConfigResourceType->data clj

(ConfigResourceType->data crt)

ConsumerRecord clj

ConsumerRecord->data clj

(ConsumerRecord->data r)

datafy clj

(datafy x)

Attempts to return x as data.

datafy will return the value of #'clojure.core.protocols/datafy.

If the value has been transformed and the result supports metadata, :clojure.datafy/obj will be set on the metadata to the original value of x, and :clojure.datafy/class to the name of the class of x, as a symbol.

DescribeClusterResult->data clj

(DescribeClusterResult->data dcr)

NewTopic clj

Node->data clj

(Node->data node)

OffsetAndTimestamp clj

OffsetAndTimestamp->data clj

(OffsetAndTimestamp->data ots)

PartitionInfo->data clj

(PartitionInfo->data pi)

ProducerRecord clj

ProducerRecord->data clj

(ProducerRecord->data pr)

Properties clj

Properties->data clj

(Properties->data o)

Consume a Properties instance, keywordizing the keys and returning a Clojure mapping of the resulting keys to unmodified values.

RecordMetadata clj

RecordMetadata->data clj

(RecordMetadata->data rm)

TimestampType->data clj

(TimestampType->data tt)

TopicDescription->data clj

(TopicDescription->data td)

TopicPartition clj

TopicPartition->data clj

(TopicPartition->data tp)

TopicPartitionInfo->data clj

(TopicPartitionInfo->data tpi)