kafka-event-processor.processor.consumer

(assignments kafka-consumer)

Gets assignment from a KafkaConsumer

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

Commit the offset to a KafkaConsumer

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

Reads events from kafka.

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

Seek to the beginning of a Kafka topic

(seek-to-offset kafka-consumer event)

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

(with-consumer binding-details & body)

Generated by Codox