Embedded Kafka for self-contained Crux deployments.
Embedded Kafka for self-contained Crux deployments.
(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.
cljdoc is a website building & hosting documentation for Clojure/Script libraries
× close