Liking cljdoc? Tell your friends :D
Clojure only.

com.flocktory.protocol.tracer

IAfterBeginningOffsetscljprotocol

after-beginning-offsetsclj

(after-beginning-offsets this group-id opts offsets)
source

IAfterCommitcljprotocol

after-commitclj

(after-commit this group-id opts offsets)
source

IAfterConsumecljprotocol

after-consumeclj

(after-consume this group-id opts records-count)
source

IAfterConsumePartitioncljprotocol

after-consume-partitionclj

(after-consume-partition this group-id opts topic-partition records-count)
source

IAfterConsumeRecordcljprotocol

after-consume-recordclj

(after-consume-record this group-id opts record)
source

IAfterEndOffsetscljprotocol

after-end-offsetsclj

(after-end-offsets this group-id opts offsets)
source

IAfterPartitionsPausedcljprotocol

after-partitions-pausedclj

(after-partitions-paused this group-id opts topic-partitions)
source

IAfterPartitionsResumedcljprotocol

after-partitions-resumedclj

(after-partitions-resumed this group-id opts topic-partitions)
source

IAfterPollcljprotocol

after-pollclj

(after-poll this group-id opts records-count)
source

IBeforeBeginningOffsetscljprotocol

before-beginning-offsetsclj

(before-beginning-offsets this group-id opts)
source

IBeforeCommitcljprotocol

before-commitclj

(before-commit this group-id opts offsets)
source

IBeforeConsumecljprotocol

before-consumeclj

(before-consume this group-id opts records-count)
source

IBeforeConsumePartitioncljprotocol

before-consume-partitionclj

(before-consume-partition this group-id opts topic-partition records-count)
source

IBeforeConsumeRecordcljprotocol

before-consume-recordclj

(before-consume-record this group-id opts record)
source

IBeforeEndOffsetscljprotocol

before-end-offsetsclj

(before-end-offsets this group-id opts)
source

IBeforePartitionsPausedcljprotocol

before-partitions-pausedclj

(before-partitions-paused this group-id opts topic-partitions)
source

IBeforePartitionsResumedcljprotocol

before-partitions-resumedclj

(before-partitions-resumed this group-id opts topic-partitions)
source

IBeforePollcljprotocol

before-pollclj

(before-poll this group-id opts)
source

ICurrentOffsetscljprotocol

current-offsetsclj

(current-offsets this group-id opts offsets)
source

IOnConsumeErrorcljprotocol

on-consume-errorclj

(on-consume-error this group-id opts exception records-count)
source

IOnConsumePartitionErrorcljprotocol

on-consume-partition-errorclj

(on-consume-partition-error this
                            group-id
                            opts
                            topic-partition
                            records-count
                            exception)
source

IOnConsumeRecordErrorcljprotocol

on-consume-record-errorclj

(on-consume-record-error this group-id opts record exception)
source

IOnConsumerFailcljprotocol

on-consumer-failclj

(on-consumer-fail this group-id opts error)
source

IOnConsumerFailLoopcljprotocol

on-consumer-fail-loopclj

(on-consumer-fail-loop this group-id opts failed-ago)
source

IOnConsumerStartcljprotocol

on-consumer-startclj

(on-consumer-start this group-id opts)
source

IOnConsumerStopcljprotocol

on-consumer-stopclj

(on-consumer-stop this group-id opts)
source

IOnPartitionsAssignedcljprotocol

on-partitions-assignedclj

(on-partitions-assigned this group-id opts topic-partitions)
source

IOnPartitionsRevokedcljprotocol

on-partitions-revokedclj

(on-partitions-revoked this group-id opts topic-partitions)
source

ITracerNamecljprotocol

tracer-nameclj

(tracer-name this)
source

cljdoc is a website building & hosting documentation for Clojure/Script libraries

Keyboard shortcutsReport a problemcljdoc on GitHub
× close