Liking cljdoc? Tell your friends :D
Clojure only.

crux.kafka.embedded

Embedded Kafka for self-contained Crux deployments.

Embedded Kafka for self-contained Crux deployments.
raw docstring

*broker-id*clj

*host*clj

default-kafka-broker-configclj

default-kafka-portclj

default-zookeeper-portclj

EmbeddedKafkaclj

start-embedded-kafkaclj

(start-embedded-kafka options)

Starts ZooKeeper and Kafka locally. This can be used to run Crux in a self-contained single node mode. The options zookeeper-data-dir and kafka-log-dir are required.

Returns a crux.kafka.embedded_kafka.EmbeddedKafka component that implements java.io.Closeable, which allows ZooKeeper and Kafka to be stopped by calling close.

Starts ZooKeeper and Kafka locally. This can be used to run Crux in a
self-contained single node mode. The options zookeeper-data-dir and
kafka-log-dir are required.

Returns a crux.kafka.embedded_kafka.EmbeddedKafka component that
implements java.io.Closeable, which allows ZooKeeper and Kafka to be
stopped by calling close.
raw docstring

start-kafka-brokerclj

(start-kafka-broker config)

start-zookeeperclj

(start-zookeeper data-dir)
(start-zookeeper data-dir port)

stop-kafka-brokerclj

(stop-kafka-broker broker)

stop-zookeeperclj

(stop-zookeeper server-cnxn-factory)

cljdoc builds & hosts documentation for Clojure/Script libraries

Keyboard shortcuts
Ctrl+kJump to recent docs
←Move to previous article
→Move to next article
Ctrl+/Jump to the search field
Raise an issueBrowse cljdoc sourceChat on Slack
× close