crux.kafka — juxt/crux-kafka 20.09-1.12.0-beta

->admin-client clj

(->admin-client {:keys [kafka-config]})

->consumer clj

(->consumer {:keys [kafka-config]})

->document-store clj

(->document-store {:keys [index-store local-document-store kafka-config
                          doc-topic-opts]
                   :as opts})

->ingest-only-document-store clj

(->ingest-only-document-store {:keys [kafka-config doc-topic-opts] :as opts})

->ingest-only-tx-log clj

(->ingest-only-tx-log {:keys [tx-topic-opts kafka-config]})

->kafka-config clj

(->kafka-config {:keys [bootstrap-servers properties-file properties-map]})

->producer clj

(->producer {:keys [kafka-config]})

->topic-opts clj

(->topic-opts opts)

->tx-log clj

(->tx-log {:keys [kafka-config tx-topic-opts poll-wait-duration] :as opts})

doc-record->id+doc clj

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

IngestOnlyDocumentStore clj

KafkaDocumentStore clj

KafkaTxLog clj