crux.kafka.embedded — juxt/crux-kafka-embedded 20.06-1.8.5-alpha

Embedded Kafka for self-contained Crux deployments.

*broker-id* clj

*host* clj

default-kafka-broker-config clj

default-kafka-port clj

default-zookeeper-port clj

EmbeddedKafka clj

start-embedded-kafka clj

(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.

start-kafka-broker clj

(start-kafka-broker config)

start-zookeeper clj

(start-zookeeper data-dir)

(start-zookeeper data-dir port)

stop-kafka-broker clj

(stop-kafka-broker broker)

stop-zookeeper clj

(stop-zookeeper server-cnxn-factory)