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

Question

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

Answer 1

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

要运行它，我们在开始处编写 EmbeddedKafka.start() ，在末尾编写 EmbeddedKafka.stop() 。