crux.kafka

Liking cljdoc? Tell your friends :D

Clojure only.

admin-client^clj

consumer-seqs^clj

(consumer-seqs consumer poll-duration)

source

create-admin-client^clj

(create-admin-client config)

source

create-consumer^clj

(create-consumer config)

source

create-producer^clj

(create-producer config)

source

create-topic^clj

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

source

doc-record->id+doc^clj

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

source

doc-topic-config^clj

source

document-store^clj

source

KafkaDocumentStore^clj

source

KafkaTxLog^clj

source

latest-submitted-tx-consumer^clj

source

producer^clj

source

submit-docs^clj

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

source

(subscribe-consumer consumer topics tp-offsets)

source

topology^clj

source

tx-log^clj

source

tx-topic-config^clj

source

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

Keyboard shortcuts Report a problem cljdoc on GitHub

× close

crux.kafka

admin-clientclj

consumer-seqsclj

create-admin-clientclj

create-consumerclj

create-producerclj

create-topicclj

default-optionsclj

default-producer-configclj

default-topic-configclj

doc-record->id+docclj

doc-topic-configclj

document-storeclj

KafkaDocumentStoreclj

KafkaTxLogclj

latest-submitted-tx-consumerclj

producerclj

submit-docsclj

subscribe-consumerclj

topologyclj

tx-logclj

tx-topic-configclj

admin-client^clj

consumer-seqs^clj

create-admin-client^clj

create-consumer^clj

create-producer^clj

create-topic^clj

default-options^clj

default-producer-config^clj

default-topic-config^clj

doc-record->id+doc^clj

doc-topic-config^clj

document-store^clj

KafkaDocumentStore^clj

KafkaTxLog^clj

latest-submitted-tx-consumer^clj

producer^clj

submit-docs^clj

subscribe-consumer^clj

topology^clj

tx-log^clj

tx-topic-config^clj