ketu.clients.consumer — com.appsflyer/ketu 0.6.0

assign! clj

(assign! consumer partitions)

Manually assign specific partitions to the consumer without group coordination.

assignment clj

(assignment consumer)

Get the set of partitions currently assigned to this consumer.

beginning-offsets clj

(beginning-offsets consumer partitions)

(beginning-offsets consumer partitions timeout)

Get the first offset for the given partitions.

byte-array-deserializer clj

(byte-array-deserializer)

close! clj

(close! consumer timeout-ms)

Will block at most timeout-ms milliseconds. Will commit offsets of last poll (when auto-commit enabled). Should be called after poll returns or wakes up.

commit-async! clj

(commit-async! consumer offsets callback)

commit-callback clj

(commit-callback f)

Construct a callback object for commit!

consumer clj

(consumer config)

(consumer config key-deserializer value-deserializer)

Construct the java KafkaConsumer.

deprecated-poll! clj

(deprecated-poll! consumer timeout-ms)

end-offsets clj

(end-offsets consumer partitions)

(end-offsets consumer partitions timeout)

Get the end offsets for the given partitions.

partitions-for clj

(partitions-for consumer topic)

(partitions-for consumer topic timeout)

Get metadata about the partitions for a given topic.

poll! clj

(poll! consumer timeout)

Fetch records. This is where auto-commit and partition reassignment happen.

position clj

(position consumer partition)

(position consumer partition timeout)

Get the offset of the next record that will be fetched (if a record with that offset exists).

rebalance-listener clj

(rebalance-listener assigned revoked)

(rebalance-listener assigned revoked lost)

Create a ConsumerRebalanceListener. Provide either 2 functions for assigned and revoked, or 3 for assigned, revoked and lost events. Each of assigned, revoked and lost functions receive a single parameter of type Collection<TopicPartition>.

seek! clj

(seek! consumer partition offset)

Overrides the fetch offsets that the consumer will use on the next poll.

seek-to-beginning! clj

(seek-to-beginning! consumer partitions)

Seek to the first offset for each of the given partitions (Collection<TopicPartition>)

seek-to-end! clj

(seek-to-end! consumer partitions)

Seek to the last offset for each of the given partitions (Collection<TopicPartition>).

string-deserializer clj

(string-deserializer)

subscribe-to-list! clj

(subscribe-to-list! consumer topics)

(subscribe-to-list! consumer topics rebalance-listener)

subscribe-to-pattern! clj

(subscribe-to-pattern! consumer topics)

(subscribe-to-pattern! consumer topics rebalance-listener)

subscribe-to-topic! clj

(subscribe-to-topic! consumer topic)

(subscribe-to-topic! consumer topic rebalance-listener)

topic-partition clj

(topic-partition topic partition)

Create a TopicPartition object, to be used with e.g seek!

topic-partitions clj

(topic-partitions topic partition-numbers)

Create a TopicPartition collection for a single topic, to be used with e.g assign!.

wakeup! clj

(wakeup! consumer)

Call from any thread to release consumer from a long poll before closing.