Liking cljdoc? Tell your friends :D
Clojure only.
crux.kafka
->admin-clientclj
(->admin-client {:keys [kafka-config]})->consumerclj
(->consumer {:keys [kafka-config]})->document-storeclj
(->document-store {:keys [index-store local-document-store kafka-config
doc-topic-opts]
:as opts})->ingest-only-document-storeclj
(->ingest-only-document-store {:keys [kafka-config doc-topic-opts] :as opts})->ingest-only-tx-logclj
(->ingest-only-tx-log {:keys [tx-topic-opts kafka-config]})->kafka-configclj
(->kafka-config {:keys [bootstrap-servers properties-file properties-map]})->producerclj
(->producer {:keys [kafka-config]})->topic-optsclj
(->topic-opts opts)->tx-logclj
(->tx-log {:keys [kafka-config tx-topic-opts poll-wait-duration] :as opts})doc-record->id+docclj
(doc-record->id+doc doc-record)IngestOnlyDocumentStoreclj
KafkaDocumentStoreclj
KafkaTxLogclj
cljdoc is a website building & hosting documentation for Clojure/Script libraries
× close