Liking cljdoc? Tell your friends :D

crux.kafka


admin-clientclj

source

consumer-seqsclj

(consumer-seqs consumer poll-duration)
source

create-admin-clientclj

(create-admin-client config)
source

create-consumerclj

(create-consumer config)
source

create-producerclj

(create-producer config)
source

create-topicclj

(create-topic admin-client topic num-partitions replication-factor config)
source

default-optionsclj

source

default-producer-configclj

source

default-topic-configclj

source

doc-record->id+docclj

(doc-record->id+doc doc-record)
source

doc-topic-configclj

source

document-storeclj

source

KafkaDocumentStoreclj

source

KafkaTxLogclj

source

latest-submitted-tx-consumerclj

source

producerclj

source

submit-docsclj

(submit-docs id-and-docs {:keys [producer doc-topic]})
source

subscribe-consumerclj

(subscribe-consumer consumer topics tp-offsets)
source

topologyclj

source

tx-logclj

source

tx-topic-configclj

source

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

× close