Liking cljdoc? Tell your friends :D

crux.kafka.embedded

Embedded Kafka for self-contained Crux deployments.

Embedded Kafka for self-contained Crux deployments.
raw docstring

*broker-id*clj

source

*host*clj

source

default-kafka-broker-configclj

source

default-kafka-portclj

source

default-zookeeper-portclj

source

start-embedded-kafkaclj

(start-embedded-kafka
  {:crux.kafka.embedded/keys [zookeeper-data-dir zookeeper-port kafka-log-dir
                              kafka-port broker-config]
   :or {zookeeper-port default-zookeeper-port kafka-port default-kafka-port}
   :as 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.

NOTE: requires org.apache.kafka/kafka_2.11 and org.apache.zookeeper/zookeeper on the classpath.

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.

NOTE: requires org.apache.kafka/kafka_2.11 and
org.apache.zookeeper/zookeeper on the classpath.
sourceraw docstring

start-kafka-brokerclj

(start-kafka-broker config)
source

start-zookeeperclj

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

stop-kafka-brokerclj

(stop-kafka-broker broker)
source

stop-zookeeperclj

(stop-zookeeper server-cnxn-factory)
source

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

× close