clj-kafka.consumer.simple documentation

clj-kafka.consumer.simple

(consumer host port client-id & {:keys [timeout buffer-size], :or {timeout 100000, buffer-size 10000}})

Create a consumer to connect to host and port. Port will normally be 9092.

(fetch-request client-id topic partition offset fetch-size)

(latest-topic-offset consumer topic partition)

(messages consumer client-id topic partition offset fetch-size)

(topic-meta-data consumer topics)

(topic-offset consumer topic partition offset-position)