gregor.details.transform — novolabsoss/gregor 0.1.0

->event clj

(->event event)

(->event event data)

Adds event information to the specified data (map)

consumer-record->data clj

(consumer-record->data cr)

Yield a clojure representation of a consumer record

consumer-records->data clj

(consumer-records->data crs)

Yield the clojure representation of topic

data->producer-record clj

(data->producer-record {:keys [partition message-key message-value topic]
                        :as data})

Build a ProducerRecord object from a clojure map. No-Op if payload is already a ProducerRecord

data->topics clj

(data->topics topics)

Converts a topic or list of topics into a Collection of topics that KafkaConsumer understands

exception->data clj

(exception->data e)

Convert a known exception to a map

exception-type-name clj

(exception-type-name e)

node->data clj

(node->data n)

Convert an instance of Node into a map

opts->props clj

(opts->props opts)

Kafka configuration requres a map of string to string. This function converts a Clojure map into a Java Map, String to String

partition-info->data clj

(partition-info->data pi)

Convert an instance of PartitionInfo into a map

record-metadata->data clj

(record-metadata->data record-metadata)

Convert an instance of RecordMetadata to a map

timestamp-type->data clj

(timestamp-type->data tt)

Convert an instance of TimestampType to a map

topic-partition->data clj

(topic-partition->data tp)

Convert an instance of TopicPartition into a map

valid-events? clj