Liking cljdoc? Tell your friends :D

crux.kafka


admin-clientclj

source

admin-wrapperclj

source

consume-and-index-entitiesclj

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

consumer-record->valueclj

(consumer-record->value record)
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-consumer-configclj

source

default-producer-configclj

source

default-topic-configclj

source

doc-topic-configclj

source

indexing-consumerclj

source

node-configclj

source

producerclj

source

seek-to-stored-offsetsclj

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

subscribe-from-stored-offsetsclj

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

tx-logclj

source

tx-record->tx-log-entryclj

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

tx-topic-configclj

source

zk-statusclj

(zk-status consumer-config)
source

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

× close