(after-beginning-offsets this group-id offsets)
(after-consume-partition this group-id topic-partition records-count)
(after-consume-record this group-id record)
(after-partitions-paused this group-id topic-partitions)
(after-partitions-resumed this group-id topic-partitions)
(before-beginning-offsets this group-id)
(before-consume-partition this group-id topic-partition records-count)
(before-consume-record this group-id record)
(before-partitions-paused this group-id topic-partitions)
(before-partitions-resumed this group-id topic-partitions)
(on-consume-error this group-id exception records-count)
(on-consume-partition-error this
group-id
topic-partition
records-count
exception)
(on-consume-record-error this group-id record exception)
(on-consumer-fail-loop this group-id failed-ago)
(on-partitions-assigned this group-id topic-partitions)
(on-partitions-revoked this group-id topic-partitions)
cljdoc is a website building & hosting documentation for Clojure/Script libraries
× close