从Java应用程序启动Zookeeper和Kafka服务器
我使用的是一个Java应用程序，它让消费者开始阅读Kafka主题。每次我需要启动消费者应用程序时，我都必须使用cmd中的命令启动Zookeeper和Kafka服务器。是否可以用小型Java程序启动/停止它们？非常感谢。
共有3个答案
要为测试启动Kafka群集，可以使用以下包装器：https://www.testcontainers.org/modules/kafka/
另请参见在Spring应用程序中进一步集成Kafka的项目：https://github.com/vspiliop/embedded-kafka-cluster
如果您需要它来测试我认为更好的方法是使用提供KafkaCluster嵌入式实现的Debezium库。您可以在此处查看我们如何在Vert. x Kafka Client项目中使用它进行单元测试：
https://github.com/vert-x3/vertx-kafka-client/blob/master/src/test/java/io/vertx/kafka/client/tests/KafkaClusterTestBase.java
看看周围；）
-
我有两个问题，我找不到任何流行/广泛接受的解决方案： > 使用Java程序启动zookeeper服务器最简单的方法是什么？ 而且，是否可以将服务器添加到zookeeper集群，而无需手动转到每台机器并使用新节点的id和ip：端口条目更新其配置文件？ 有人能帮忙吗？谢谢。
-
我是Kafka的初学者 1/我下载了Kafka的1.0.0版本 2/I更改了bith server.properties和zookeeper.properties中的数据目录位置属性 你能帮帮我吗？
-
我有一个带有的Spring Boot应用程序，我正在从中配置和其他必需的应用程序。 我的应用程序中有制作人和消费者（）。我从（不是从文件）获得了和JPA存储库配置。 我正在为生产者和消费者编写一个junit测试，但我想使用应用程序定义的（在中定义）。 所以在我的我有目标，首先启动应用程序，然后运行测试收集报告，最后停止应用程序。 有人能帮我用应用程序定义的Kafka为Kafka制作人和消费者编写J
-
我正在尝试将bash脚本转换为java程序。在此脚本中，我运行了Hadoop、Zoomaster和Accumulo的开始脚本： 这在脚本中很容易做到。如果程序已经在运行，我可以再次调用这些启动脚本，没有问题，程序只会输出它们已经在运行和它们的PID。 我想知道是否有一种方法可以在java程序中实现这一点。Hadoop/ZooKeeper/Accumulo API中是否有一些隐藏的命令，我可以在其中
-
当我的应用程序启动时，将创建一个executor服务（在java.util.concurrent中使用Executors.NewFixedThreadPool（maxThreadNum））对象。当请求到来时，executor服务将创建线程来处理它们。 当应用程序启动时，它将在executorService池中创建200个线程。 只是想知道当应用程序启动时，这是一种正确的创建线程的方法吗？还是有更好
-
问题内容： 我有一个GUI应用程序，需要在后台静默运行并继续收集信息。它首先需要显示UI以输入凭据，然后偶尔显示错误。 我了解我无法将GUI应用程序作为服务运行，因此我想创建服务只是为了启动GUI应用程序。因此，第一个程序作为服务运行，它仅启动GUI应用程序，然后继续监听来自GUI应用程序的任何信息。以下是启动GUI应用程序的第一个应用程序的代码。 当我运行此程序时，将启动GUI应用程序，但在5-