Starts a new consumer on the specified topic from the specified point. The ‘from’ parameter can be any of :start, :end, a numeric offset. All partitions are consumed from the specified point. Alternatively, ‘from’ can be used to focus the consumer on specific partitions on the topic - in which case it will be a collection of partition/from pairs e.g. [0 :start 1 1412].

Gets the offsets for the specified consumer group on the given topic.

Returns the configuration map that will be used in cljka operations for the specified environment and topic. Useful for diagnosing problems.

Gets the lag for the specified consumer group on the given topic.

Gets the offset for the specified partition of a topic at a particular point in time.

at can either be :start, :end or an epoch millis long (representing an epoch time). If epoch millis are specified then the offset will be the first one with a timestamp after the specified point in time - -1 will be returned if such offset can be found.

Gets the offsets for the partitions of a topic at a particular point in time.

at can either be :start, :end or an epoch millis long (representing an epoch time). If epoch millis are specified then the offset for each partition will be the first one with a timestamp after the specified point in time - -1 will be returned if such offset can be found.

Gets a vector of partitions available for the given topic.

Lists all topics in alphabetical order.

Sets the group offset on a single partition to the specified value.

offset can either be :start, :end or a number representing a specific offset

Sets the group offset on all partitions to the specified value.

partition-offsets is a vector of partition->offset pairs where each offset is a numeric offset.