kafka-utils

(->schema-registry config)

(assign-partition-0 consumer topic)

(assign-partitions consumer topic-partitions)

(committed-info consumer)

(normalize-kafka-config config)

Normalise configuration map into a format required by kafka.

(poll* consumer & {:keys [expected-msgs retries poll-timeout], :or {expected-msgs 1, retries 500, poll-timeout 20}})

(produce config topic schema val)(produce topic schema val)

(seek-to-beginning consumer)

(seek-to-end consumer)

(unsubscribe consumer)

(with-1-partition-consumer-from-end config topic f)(with-1-partition-consumer-from-end topic f)

(with-consumer config f)(with-consumer f)

(with-producer config schema f)

Generated by Codox