com.flocktory.protocol.tracer — com.flocktory/kafka-consumer 0.0.8

IAfterBeginningOffsets clj protocol

after-beginning-offsets clj

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

IAfterCommit clj protocol

after-commit clj

(after-commit this group-id opts offsets)

IAfterConsume clj protocol

after-consume clj

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

IAfterConsumePartition clj protocol

after-consume-partition clj

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

IAfterConsumeRecord clj protocol

after-consume-record clj

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

IAfterEndOffsets clj protocol

after-end-offsets clj

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

IAfterPartitionsPaused clj protocol

after-partitions-paused clj

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

IAfterPartitionsResumed clj protocol

after-partitions-resumed clj

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

IAfterPoll clj protocol

after-poll clj

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

IBeforeBeginningOffsets clj protocol

before-beginning-offsets clj

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

IBeforeCommit clj protocol

before-commit clj

(before-commit this group-id opts offsets)

IBeforeConsume clj protocol

before-consume clj

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

IBeforeConsumePartition clj protocol

before-consume-partition clj

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

IBeforeConsumeRecord clj protocol

before-consume-record clj

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

IBeforeEndOffsets clj protocol

before-end-offsets clj

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

IBeforePartitionsPaused clj protocol

before-partitions-paused clj

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

IBeforePartitionsResumed clj protocol

before-partitions-resumed clj

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

IBeforePoll clj protocol

before-poll clj

(before-poll this group-id opts)

ICurrentOffsets clj protocol

current-offsets clj

(current-offsets this group-id opts offsets)

IOnConsumeError clj protocol

on-consume-error clj

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

IOnConsumePartitionError clj protocol

on-consume-partition-error clj

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

IOnConsumeRecordError clj protocol

on-consume-record-error clj

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

IOnConsumerFail clj protocol

on-consumer-fail clj

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

IOnConsumerFailLoop clj protocol

on-consumer-fail-loop clj

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

IOnConsumerStart clj protocol

on-consumer-start clj

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

IOnConsumerStop clj protocol

on-consumer-stop clj

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

IOnPartitionsAssigned clj protocol

on-partitions-assigned clj

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

IOnPartitionsRevoked clj protocol

on-partitions-revoked clj

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

ITracerName clj protocol

tracer-name clj

(tracer-name this)