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.
*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.
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 is a website building & hosting documentation for Clojure/Script libraries
× close