早上好我是ZooKeeper及其协议(protocol)的新手，我对它的广播协议(protocol)Zab很感兴趣。能否提供一个使用Zookeeper的Zab协议(protocol)的简单java代码？我一直在搜索，但没有成功找到显示如何使用Zab的代码。事实上，我需要的很简单，我有一个MapReduce代码，我希望所有映射器在成功找到更好的X值(即更大的值)时更新一个变量(比如说X)。在这种情况下，领导者必须比较旧值和新值，然后将实际最佳值广播给所有映射器。我怎样才能在Java中做这样的事情？提前致谢，问候 最佳答案 您不需要使用

1前言本文主要介绍了操作Zookeeper的几种客户端的基础使用，希望对老铁们会有所帮助。可以去操作zookeeper创建、删除、查询、修改znode节点2Zookeeper服务器客户端分类目前，Zookeeper服务器有三种Java客户端：Zookeeper、Zkclient和CuratorZookeeper：Zookeeper是官方提供的原生java客户端Zkclient：是在原生zookeeper客户端基础上进行扩展的开源第三方Java客户端Curator：Netflix公司在原生zookeeper客户端基础上开源的第三方Java客户端3Java客户端Zookeeper的使用（官方）使用

我想通过java在Kafka(kafka_2.8.0-0.8.1.1)中创建一个主题。如果我在命令提示符中创建一个主题，并且如果我通过javaapi推送消息，它工作正常。但我想通过javaapi创建一个主题。经过长时间的搜索，我找到了下面的代码，ZkClientzkClient=newZkClient("localhost:2181",10000,10000);AdminUtils.createTopic(zkClient,myTopic,10,1,newProperties());我尝试了上面的代码，它显示主题已创建，但我无法在主题中推送消息。我的代码有什么问题吗？或者任何其他方式来

我想通过java在Kafka(kafka_2.8.0-0.8.1.1)中创建一个主题。如果我在命令提示符中创建一个主题，并且如果我通过javaapi推送消息，它工作正常。但我想通过javaapi创建一个主题。经过长时间的搜索，我找到了下面的代码，ZkClientzkClient=newZkClient("localhost:2181",10000,10000);AdminUtils.createTopic(zkClient,myTopic,10,1,newProperties());我尝试了上面的代码，它显示主题已创建，但我无法在主题中推送消息。我的代码有什么问题吗？或者任何其他方式来