Tag: apache zookeeper

连接外部Accumulo实例和java: 我正在尝试使用Accumulo连接到VM。问题是，我无法将它与Java连接起来。我可以看到Apache推出的网页，但我无法使用代码。我认为这是一个缺乏知识问题而不是一个真正的问题，但我无法找到它的文档。所有示例都使用localhost作为zooServer名称，这显然不适用于我。所以，这是我的代码： String instanceName = “accumulo-02” String zooServers = “192.168.56.5, accumulo-02.localdomain:9997” ZooKeeperInstance inst = new ZooKeeperInstance(instanceName, zooServers) …. 其余的并不重要，因为我无法连接到服务器。这也是用Groovy编写的。我刚刚为Java人员改变了我的代码。编辑：程序驻留在我的计算机上。 Accumulo，Hadoop和Zookeeper都在VM上。它的IP是IP和isntance名称是该名称。在accumulo的配置中，’accumulo-02’是主人，奴隶等的领域……

在zookeeper中创建路径的最有效方法，路径的根元素可能存在也可能不存在？: 想象一下路径“/ root / child1 / child2 / child3” 想象一下，在动物园管理员中，可能有一部分存在，比如“/ root / child1” 在zookeeper中没有“mkdir -p”的等价物; 此外，如果任何一个操作失败，ZooKeeper.multi（）将失败，因此“make path”无法真正被烘焙到多次调用中。另外，你可以让其他一些客户尝试制作相同的路径…… 这就是我为创建路径而想出的。我想知道是否值得检查一个部件是否存在，以保存exists（）调用的往返行程。 //String[] pathParts new String[] { “root”, “child1”, “child2”, “child3” }; public void savePath(String[] pathParts) { if (zooKeeper.exists(pathString, false) != null) return; StringBuilder path = new StringBuilder(); for (String pathElement : pathParts) { path.append(UNIX_FILE_SEPARATOR).append(pathElement); String pathString = […]

Kafurn in Kubernetes – 将协调员标记为团体死亡: 我对Kubernetes很新，并想用它来设置Kafka和zookeeper。我能够使用StatefulSets在Kubernetes中设置Apache Kafka和Zookeeper。我按照这个来构建我的清单文件。我制作了1张kafka和zookeeper的复制品，并且还使用了持久卷。所有pod都在运行并准备就绪。我尝试通过指定nodePort（30010）来公开kafka并使用Service 。看起来这会将kafka暴露给外界，在那里他们可以向kafka经纪人发送消息并从中消费。但是在我的Java应用程序中，我创建了一个使用者并将bootstrapServer添加为:30010 ，显示了以下日志： INFO oakcciAbstractCoordinator – Discovered coordinator kafka-0.kafka-hs.default.svc.cluster.local:9093 (id: 2147483647 rack: null) for group workerListener. INFO oakcciAbstractCoordinator – Marking the coordinator kafka-0.kafka-hs.default.svc.cluster.local:9093 (id: 2147483647 rack: null) dead for group workerListener 有趣的是，当我使用kubectl命令测试集群时，我能够生成和使用消息： kubectl run -ti –image=gcr.io/google_containers/kubernetes-kafka:1.0-10.2.1 produce –restart=Never –rm \ — kafka-console-producer.sh –topic test –broker-list kafka-0.kafka-hs.default.svc.cluster.local:9093 done; […]

ZooKeeper for Java / Spring Config？: 是否有任何记录良好的Apache ZooKeeper用例用于分发Java应用程序的配置，特别是Spring服务？像许多云服务用户一样，我需要更改可变数量的Java服务的配置，最好是在运行时，而不需要重新启动服务。 UPDATE 最后，我最终编写了一些将ZooKeeper节点作为属性文件加载的东西，并创建了一个ResourcePropertySource并将其插入到Spring上下文中。请注意，这不会反映上下文启动后ZooKeeper节点的更改。 public class ZooKeeperPropertiesApplicationContextInitializer implements ApplicationContextInitializer { private static final Logger logger = LoggerFactory.getLogger(ZooKeeperPropertiesApplicationContextInitializer.class); private final CuratorFramework curator; private String projectName; private String projectVersion; public ZooKeeperPropertiesApplicationContextInitializer() throws IOException { logger.trace(“Attempting to construct CuratorFramework instance”); RetryPolicy retryPolicy = new ExponentialBackoffRetry(10, 100); curator = CuratorFrameworkFactory.newClient(“zookeeper”, retryPolicy); curator.start(); } /** * Add a […]

构建Storm时Zookeeper的ClassNotFoundException: 我是java和Storm的新手所以请原谅任何明显的错误。我正在尝试使用水槽连接器运行风暴，但它崩溃时出现以下错误： java.lang.reflect.InvocationTargetException at sun.reflect.NativeMethodAccessorImpl.invoke0(Native Method) at sun.reflect.NativeMethodAccessorImpl.invoke(NativeMethodAccessorImpl.java:57) at sun.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:43) at java.lang.reflect.Method.invoke(Method.java:606) at org.codehaus.mojo.exec.ExecJavaMojo$1.run(ExecJavaMojo.java:297) at java.lang.Thread.run(Thread.java:744) Caused by: java.lang.ExceptionInInitializerError at java.lang.Class.forName0(Native Method) at java.lang.Class.forName(Class.java:270) at clojure.lang.RT.loadClassForName(RT.java:2056) at clojure.lang.RT.load(RT.java:419) at clojure.lang.RT.load(RT.java:400) at clojure.core$load$fn__4890.invoke(core.clj:5415) at clojure.core$load.doInvoke(core.clj:5414) at clojure.lang.RestFn.invoke(RestFn.java:408) at clojure.core$load_one.invoke(core.clj:5227) at clojure.core$load_lib.doInvoke(core.clj:5264) at clojure.lang.RestFn.applyTo(RestFn.java:142) at clojure.core$apply.invoke(core.clj:603) at clojure.core$load_libs.doInvoke(core.clj:5302) at clojure.lang.RestFn.applyTo(RestFn.java:137) at clojure.core$apply.invoke(core.clj:603) at clojure.core$require.doInvoke(core.clj:5381) at clojure.lang.RestFn.invoke(RestFn.java:408) at […]

我需要我的Spring Boot WebApplication在JUnit中重启: 在没有进入令人难以忍受的细节的情况下，当我同时运行Junit测试时，我遇到了一个问题。如果我一个接一个地运行它们，一切都很棒！否则我遇到麻烦，因为我无法在junit-test-class之间重启我的WebApplication。这导致我在我的WebApplication中拥有Zookeeper服务器客户端，在我完成关闭并启动Zookeeper服务器之间的类之后。那些Zookeeper服务器客户端可能需要一段时间才能与服务器重新同步，这会导致不可预测的行为…… 有没有办法通过调用JUnit测试的@BeforeClass和@AfterClass方法来重新启动我的SpringBootServletInitializer类？ WebApplication.java @ComponentScan @EnableAutoConfiguration @EnableWebMvc @EnableHyperMediaSupport(…) @PropertySources(…) public class WebApplication extends SpringBootServletInitializer { @Override protected SpringApplicationBuilder configure(SpringApplicationBuilder builder) { return builder.sources(WebApplication.class); } @Override protected WebApplicationContext run(SpringApplication application) { application.getSources().remove(ErrorPageFilter.class); return (WebApplicationContext) application.run(); } public static void main(String[] args) { SpringApplication.run(WebApplication.class, args); } }

hbase-site.xml中的zookeeper仲裁设置究竟是什么？: hbase-site.xml中的zookeeper仲裁设置究竟是什么？

Zookeeper错误：无法在选举地址打开通道X.: 我在3个不同的aws服务器上安装了zookeeper。以下是所有服务器中的配置 tickTime=2000 initLimit=10 syncLimit=5 dataDir=/var/zookeeper clientPort=2181 server.1=xxxx:2888:3888 server.2=xxxx:2888:3888 server.3=xxxx:2888:3888 所有这三个实例都在var/zookeeper上有一个myid文件，其中包含相应的id。所有三台服务器都从aws控制台打开了所有端口。但是当我运行zookeeper服务器时，我在所有实例中都收到以下错误。 2015-06-19 12:09:22,989 [myid:1] – WARN [QuorumPeer[myid=1]/0:0:0:0:0:0:0:0:2181:QuorumCnxManager@382] – Cannot open channel to 2 at election address /xxxx:3888 java.net.ConnectException: Connection refused at java.net.PlainSocketImpl.socketConnect(Native Method) at java.net.AbstractPlainSocketImpl.doConnect(AbstractPlainSocketImpl.java:339) at java.net.AbstractPlainSocketImpl.connectToAddress(AbstractPlainSocketImpl.java:200) at java.net.AbstractPlainSocketImpl.connect(AbstractPlainSocketImpl.java:182) at java.net.SocksSocketImpl.connect(SocksSocketImpl.java:392) at java.net.Socket.connect(Socket.java:579) at org.apache.zookeeper.server.quorum.QuorumCnxManager.connectOne(QuorumCnxManager.java:368) at org.apache.zookeeper.server.quorum.QuorumCnxManager.connectAll(QuorumCnxManager.java:402) at org.apache.zookeeper.server.quorum.FastLeaderElection.lookForLeader(FastLeaderElection.java:840) at org.apache.zookeeper.server.quorum.QuorumPeer.run(QuorumPeer.java:762) 2015-06-19 12:09:23,170 […]

为什么我们在Hadoop堆栈中需要ZooKeeper？: 我是Hadoop / ZooKeeper的新手。我无法理解将ZooKeeper与Hadoop一起使用的目的，是ZooKeeper在Hadoop中编写数据吗？如果没有，那么我们为什么要使用ZooKeeper和Hadoop？

连接到远程HBase实例: 我有一个在ubuntu VM上运行的HBase-0.98.3-hadoop2实例，我无法使用以下代码连接到它（创建HTable实例时主线程卡住了）： Configuration config = HBaseConfiguration.create(); config.set(“hbase.zookeeper.quorum”, “192.168.56.101”); HTableInterface usersTable = new HTable(config, “users”); 这是我在控制台中得到的 SLF4J: The requested version 1.5.8 by your slf4j binding is not compatible with [1.6, 1.7] SLF4J: See http://www.slf4j.org/codes.html#version_mismatch for further details. 14/06/14 12:40:05 INFO zookeeper.ZooKeeper: Client environment:zookeeper.version=3.4.3-1240972, built on 02/06/2012 10:48 GMT 14/06/14 12:40:05 INFO zookeeper.ZooKeeper: Client environment:host.name=EL-OUED 14/06/14 12:40:05 […]