clj-kafka.offset
Offset operations.
Offset operations.
fetch-consumer-offsetsclj
(fetch-consumer-offsets broker-config zk-config topic group-id)Fetches the current offsets for a topic and a given consumer group.
Parameters: broker-config - a comma separated list of host:port pairs zk-config - a map that has at least one entry "zookeeper.connect" "host:port" topic - the topic name group-id - consumer group id
Return: {topic:partition offset, .... }
Fetches the current offsets for a topic and a given consumer group.
Parameters:
broker-config - a comma separated list of host:port pairs
zk-config - a map that has at least one entry "zookeeper.connect" "host:port"
topic - the topic name
group-id - consumer group id
Return:
{<topic:partition> offset, .... }
reset-consumer-offsetsclj
(reset-consumer-offsets broker-config zk-config topic group-id offset-position)Resets the current offsets for a topic and a given consumer group.
Parameters: broker-config - a comma separated list of "host:port" pairs zk-config - a map that has at least one entry "zookeeper.connect" "host:port" topic - the topic name group-id - consumer group id offset-position - supported values are :earliest|:latest
Return: {:has-error true|false, :errors {topic:partition error_code, .... } }
Resets the current offsets for a topic and a given consumer group.
Parameters:
broker-config - a comma separated list of "host:port" pairs
zk-config - a map that has at least one entry "zookeeper.connect" "host:port"
topic - the topic name
group-id - consumer group id
offset-position - supported values are :earliest|:latest
Return:
{:has-error true|false, :errors {<topic:partition> error_code, .... } }cljdoc is a website building & hosting documentation for Clojure/Script libraries
× close