com.flocktory.kafka-consumer — com.flocktory/kafka-consumer 0.0.6

commit-sync! clj

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

ConsumerRecord->map clj

(ConsumerRecord->map record)

create-consumer clj

(create-consumer bootstrap-servers running? consumer)

filter-consumers clj

(filter-consumers coll)

get-kafka-consumer-config clj

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

get-new-offsets clj

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

get-partitions-to-pause clj

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

get-partitions-to-resume clj

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

get-paused-partitions clj

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

get-pending-records clj

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

kafka-offsets clj

(kafka-offsets offsets)

make-consume-fn clj

(make-consume-fn consumer)

make-transform-record-fn clj

(make-transform-record-fn consumer)

make-transform-record-key-fn clj

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

make-transform-record-value-fn clj

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

manual-consume-fn clj

(manual-consume-fn consumer)

map-keys clj

(map-keys f m)

map-vals clj

(map-vals f m)

partition-process-fail clj

(partition-process-fail records)

partition-process-success clj

pause-partitions! clj

(pause-partitions! consumer topic-partitions)

poll-loop clj

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

resume-partitions! clj

(resume-partitions! consumer topic-partitions)

safe-consume-fn clj

(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-thread clj

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

start-consumers clj

(start-consumers bootstrap-servers consumers)

stop-consumers clj

(stop-consumers kafka-system)

TopicPartition->map clj

(TopicPartition->map topic-partition)

update-consumer-state! clj

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

update-current-offsets! clj

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