我有两个问题,我找不到任何流行/广泛接受的解决方案:
>
使用Java程序启动zookeeper服务器最简单的方法是什么?
而且,是否可以将服务器添加到zookeeper集群,而无需手动转到每台机器并使用新节点的id和ip:端口条目更新其配置文件?
有人能帮忙吗?谢谢。
如果您想从Java代码启动一个新的ZooKeeper服务器进程,您可以像从Java启动任何其他外部进程一样,例如使用ProcessBuilder。对于ZooKeeper,这里没有什么特别的。您可以查看官方文档了解实际命令的外观。如果您想监督生产使用的过程,情况会变得复杂,因此在这种情况下,最好使用操作系统上提供的东西(例如upstart、runit等...),或者查看Exhibitor以获取代码示例:https://github.com/Netflix/exhibitor.
如果您想从Java程序启动ZooKeeper集群,那么您将使事情更加复杂,因为您基本上需要在不同的主机上监控多个ZooKeeper JVM进程。还可以看看参展商。
如果您的问题是关于在与Java代码(嵌入式)相同的JVM进程内启动ZooKeeper服务器实例,那么这也是可能的。有几个重要的细节需要记住,看看这个答案:有没有可能在过程中启动zookeeper服务器实例,比如单元测试?
关于您的第二个问题,最近在3.5.0:http://zookeeper.apache.org/doc/trunk/zookeeperReconfig.html.中添加了对动态集群重新配置的真正支持
在此之前,您仍然可以“将服务器添加到zookeeper集群,而无需手动转到每台机器并更新其配置”,但您必须使用配置管理工具,如Chef、Puppet或类似工具,在这种情况下,您还需要重新启动集群以获取新配置。
我使用的是一个Java应用程序,它让消费者开始阅读Kafka主题。每次我需要启动消费者应用程序时,我都必须使用cmd中的命令启动Zookeeper和Kafka服务器。是否可以用小型Java程序启动/停止它们?非常感谢。
我正在亚马逊EC2和ubuntu上运行Kafka。首先,我尝试运行zookeeper服务器并创建一个测试主题。最终目的是将spark与Kafka结合起来进行情感分析。 当我尝试启动zookeeper服务器时,我收到以下警告,并且进程似乎没有结束,即键入此命令后,我没有看到shell提示:bin/zookeeper服务器启动。sh配置/zookeeper。属性 警告配置中未定义配置或未定义仲裁,以独
我使用的是Kafka版本Kafka2.12-2.4.1 我已验证不存在防火墙问题 已验证端口可用 我只需下载tar,解压缩它并修改配置中zookeeper.properties文件中的dataDir属性,以指向自定义zookeeper文件夹 将kafka2.12-2.4.1/bin/windows添加到环境变量 使用与Kafka打包的zookeeper 使用windows 7 我知道连接还没有建立
我正在尝试将bash脚本转换为java程序。在此脚本中,我运行了Hadoop、Zoomaster和Accumulo的开始脚本: 这在脚本中很容易做到。如果程序已经在运行,我可以再次调用这些启动脚本,没有问题,程序只会输出它们已经在运行和它们的PID。 我想知道是否有一种方法可以在java程序中实现这一点。Hadoop/ZooKeeper/Accumulo API中是否有一些隐藏的命令,我可以在其中
我正在编写一个服务器端应用程序,它将管理来自以下位置的请求: 游戏客户端 网站(HTTP请求) API 到目前为止,我只对每种类型的请求使用一个(NodeJS)应用程序,问题是随着用户群的增长,这种方法将产生瓶颈。 我想要一些关于如何开发服务器端架构的建议,以便它具有可扩展性。 我知道的唯一解决方案是使用运行相同应用程序的多台服务器,它们将共享相同的内存(Redis服务器)。 在nodeJS中,是
问题内容: 我想使用socket.io将数据从服务器推送到浏览器,但是该项目是java tomcat之一,并且 Github中 有许多实现的服务器实现。他们中的大多数人都说 过时了, 或者有更好的版本可用。谁能建议我一个好的实现。 而且,我看到了许多有关使用广播的演示和示例代码。我的要求是将不同的消息推送到不同的客户端。有人可以指出一些有关此类内容的优秀演示或教程吗? 谢谢 问题答案: 作为作者,