- +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.data
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.
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.
+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.
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.
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.
A timestamp type associated with... not having a timestamp type.
as-OffsetAndTimestampclj
(as-OffsetAndTimestamp ot)ConsumerRecord->dataclj
(ConsumerRecord->data r)datafyclj
(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.
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.
OffsetAndTimestamp->dataclj
(OffsetAndTimestamp->data ots)PartitionInfo->dataclj
(PartitionInfo->data pi)ProducerRecord->dataclj
(ProducerRecord->data pr)Properties->dataclj
(Properties->data o)Consume a Properties instance, keywordizing the keys and returning
a Clojure mapping of the resulting keys to unmodified values.
Consume a `Properties` instance, keywordizing the keys and returning a Clojure mapping of the resulting keys to unmodified values.
RecordMetadata->dataclj
(RecordMetadata->data rm)TimestampType->dataclj
(TimestampType->data tt)TopicPartition->dataclj
(TopicPartition->data tp)cljdoc is a website building & hosting documentation for Clojure/Script libraries
× close