crux.kafka

Liking cljdoc? Tell your friends :D

Clojure only.

admin-client^clj

admin-wrapper^clj

consume-and-index-entities^clj

(consume-and-index-entities {:keys [indexer consumer pending-txs-state timeout
                                    tx-topic doc-topic]
                             :or {timeout 5000}})

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

seek-to-stored-offsets^clj

(seek-to-stored-offsets indexer consumer partitions)

source

(subscribe-from-stored-offsets indexer consumer topics)

source

topology^clj

source

tx-log^clj

source

tx-record->tx-log-entry^clj

(tx-record->tx-log-entry record)

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

admin-wrapperclj

consume-and-index-entitiesclj

create-admin-clientclj

create-consumerclj

create-producerclj

create-topicclj

default-consumer-configclj

default-optionsclj

default-producer-configclj

default-topic-configclj

doc-topic-configclj

indexing-consumerclj

producerclj

seek-to-stored-offsetsclj

subscribe-from-stored-offsetsclj

topologyclj

tx-logclj

tx-record->tx-log-entryclj

tx-topic-configclj

admin-client^clj

admin-wrapper^clj

consume-and-index-entities^clj

create-admin-client^clj

create-consumer^clj

create-producer^clj

create-topic^clj

default-consumer-config^clj

default-options^clj

default-producer-config^clj

default-topic-config^clj

doc-topic-config^clj

indexing-consumer^clj

producer^clj

seek-to-stored-offsets^clj

subscribe-from-stored-offsets^clj

topology^clj

tx-log^clj

tx-record->tx-log-entry^clj

tx-topic-config^clj