如何以编程方式启动kafka服务器

Question

我们正在尝试在我们的应用程序中以编程方式启动kafka服务器（zookeeper和broker）。有可用的 api/库吗？

Answer 1

是的，您可以使用嵌入式 Kafka，它将为您运行 Zookeeper 和 kafka 服务器。它通常用于测试 kafka 生产者/消费者，无需显式运行它们。欲了解更多详细信息，请参阅

为了运行它，我们EmbeddedKafka.start()在开头和 EmbeddedKafka.stop()结尾编写。