onyx.plugin.kafka — org.onyxplatform/onyx-kafka 0.13.2.0

all-partitions-paused? clj

(all-partitions-paused? consumer kpartitions)

assign-partitions-to-slot! clj

(assign-partitions-to-slot! consumer* task-map topic n-partitions slot)

check-num-peers-equals-partitions clj

(check-num-peers-equals-partitions {:keys [onyx/min-peers onyx/max-peers
                                           onyx/n-peers kafka/partition]
                                    :as task-map}
                                   n-partitions)

clear-write-futures! clj

(clear-write-futures! fs)

close-read-messages clj

(close-read-messages event lifecycle)

close-write-resources clj

(close-write-resources event lifecycle)

current-partition-statuses clj

(current-partition-statuses checkpoint consumer target-offsets kpartitions)

defaults clj

find-brokers clj

(find-brokers task-map)

inject-write-messages clj

(inject-write-messages event lifecycle)

paused? clj

(paused? consumer part)

PluginMeta clj protocol

metadata clj

(metadata this)

read-handle-exception clj

(read-handle-exception event lifecycle lf-kw exception)

read-messages clj

(read-messages {:keys [onyx.core/task-map onyx.core/log-prefix
                       onyx.core/monitoring]})

read-messages-calls clj

seek-offset! clj

(seek-offset! log-prefix consumer kpartitions task-map topic checkpoint)

set-lag! clj

(set-lag! lag-gauge consumer)

start-kafka-consumer clj

(start-kafka-consumer event lifecycle)

write-defaults clj

write-handle-exception clj

(write-handle-exception event lifecycle lf-kw exception)

write-messages clj

(write-messages {:keys [onyx.core/task-map onyx.core/log-prefix]})

write-messages-calls clj