Liking cljdoc? Tell your friends :D

com.flocktory.kafka-consumer


commit-sync!clj

(commit-sync! {:keys [:com.flocktory.kafka-consumer/kafka-consumer
                      :com.flocktory.kafka-consumer/current-offsets]
               :as consumer})

ConsumerRecord->mapclj

(ConsumerRecord->map record)

create-consumerclj

(create-consumer bootstrap-servers running? consumer)

filter-consumersclj

(filter-consumers coll)

get-kafka-consumer-configclj

(get-kafka-consumer-config consumer bootstrap-servers)

get-new-offsetsclj

(get-new-offsets {:keys [results]})

get-partitions-to-pauseclj

(get-partitions-to-pause
  {:keys [:com.flocktory.kafka-consumer/assigned-partitions] :as consumer}
  {:keys [results pause-assigned-partitions]})

get-partitions-to-resumeclj

(get-partitions-to-resume
  {:keys [:com.flocktory.kafka-consumer/assigned-partitions]}
  {:keys [results resume-assigned-partitions]})

get-paused-partitionsclj

(get-paused-partitions paused-partitions
                       partitions-to-resume
                       new-paused-partitions)

get-pending-recordsclj

(get-pending-records {:keys [results]})

kafka-offsetsclj

(kafka-offsets offsets)

make-consume-fnclj

(make-consume-fn consumer)

make-transform-record-fnclj

(make-transform-record-fn consumer)

make-transform-record-key-fnclj

(make-transform-record-key-fn consumer)

make-transform-record-value-fnclj

(make-transform-record-value-fn consumer)

manual-consume-fnclj

(manual-consume-fn consumer)

map-keysclj

(map-keys f m)

map-valsclj

(map-vals f m)

partition-process-failclj

(partition-process-fail records)

partition-process-successclj


pause-partitions!clj

(pause-partitions! consumer topic-partitions)

poll-loopclj

(poll-loop {:keys [:com.flocktory.kafka-consumer/consume-fn] :as consumer})

resume-partitions!clj

(resume-partitions! consumer topic-partitions)

safe-consume-fnclj

(safe-consume-fn consumer)

should-commit?clj

(should-commit? {:keys [:com.flocktory.kafka-consumer/last-commit-timestamp
                        :com.flocktory.kafka-consumer/optional-config]})

start-consumer-threadclj

(start-consumer-thread {:keys [:com.flocktory.kafka-consumer/kafka-consumer]
                        :as consumer})

start-consumersclj

(start-consumers bootstrap-servers consumers)

stop-consumersclj

(stop-consumers kafka-system)

TopicPartition->mapclj

(TopicPartition->map topic-partition)

tracer-protocolsclj

(tracer-protocols consumer)

update-consumer-state!clj

(update-consumer-state! consumer offsets pending-records)

update-current-offsets!clj

(update-current-offsets! consumer new-offsets)

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

× close