kafka-event-processor.processor.consumer — b-social/kafka-event-processor 0.1.7

assignments clj

(assignments kafka-consumer)

Gets assignment from a KafkaConsumer

commit-offset clj

(commit-offset {:keys [handle]})

Commit the offset to a KafkaConsumer

get-new-events clj

(get-new-events {:keys [handle topics]} timeout event-handler)

Reads events from kafka.

seek-to-beginning clj

(seek-to-beginning kafka-consumer topic-partitions)

Seek to the beginning of a Kafka topic

seek-to-offset clj

(seek-to-offset kafka-consumer event)

Seek to the offset of a specific event in a Kafka topic

with-consumer clj macro

(with-consumer binding-details & body)