kafka-clj-test-utils.consumer — ovotech/kafka-clj-test-utils 2.0.1-3

assign-partition-0 clj

(assign-partition-0 consumer topic)

assign-partitions clj

(assign-partitions consumer topic-partitions)

committed-info clj

(committed-info consumer)

consume clj

(consume config topic & args)

consume* clj

(consume* config value-deserializer topic & args)

poll* clj

(poll* consumer
       &
       {:keys [expected-msgs retries poll-timeout]
        :or {expected-msgs 1 retries 200 poll-timeout 25}})

seek-to-beginning clj

(seek-to-beginning consumer)

seek-to-end clj

(seek-to-end consumer)

subscribe clj

(subscribe consumer & topics)

unsubscribe clj

(unsubscribe consumer)

with-1-partition-consumer-from-end clj

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

with-consumer clj

(with-consumer config f)

(with-consumer kafka-config kafka-serde-config f)

with-consumer* clj

(with-consumer* kafka-config value-deserializer f)