标签: apache-zookeeper

尝试在K8s集群的“CMAK”中添加新集群时，提示以下错误。

Yikes! KeeperErrorCode = Unimplemented for /kafka-manager/mutex Try again.

我的集群配置如下，

zookeeper: wurstmeister/zookeeper
kafka-manager: kafkamanager/kafka-manager:3.0.0.4
kafka: wurstmeister/kafka:2.12-2.4.1

这是我第一次使用Zookeeper,我使用Scala作为编程语言.Zookeeper是否支持Scala？如果没有,是否有任何解决方案？非常感谢你.

我有一个Java类,其主要方法需要参数.如果我运行没有参数的类,我会得到这样的错误,这意味着Java找到类,运行它,并生成运行时ArrayIndexOutOfBoundsException.

zookeeper@zookeeper-virtual-machine:~/zookeeper-3.4.5$ java -cp .:zookeeper-3.4.5.jar org.zookeeper.LsGroup
Exception in thread "main" java.lang.ArrayIndexOutOfBoundsException: 0
    at org.zookeeper.LsGroup.main(LsGroup.java:50)

但是当我用必要的命令行参数(zookeeper@zookeeper-virtual-machine:~/zookeeper-3.4.5$ java -cp .:zookeeper-3.4.5.jar org.zookeeper.LsGroup Test)尝试相同的语句时,我得到一个类找不到错误:

zookeeper@zookeeper-virtual-machine:~/zookeeper-3.4.5$ java -cp .:zookeeper-3.4.5.jar org.zookeeper.LsGroup Test
Exception in thread "main" java.lang.NoClassDefFoundError: org/slf4j/LoggerFactory
    at org.apache.zookeeper.ZooKeeper.<clinit>(ZooKeeper.java:94)
    at org.zookeeper.LsGroup.connect(LsGroup.java:19)
    at org.zookeeper.LsGroup.main(LsGroup.java:50)
Caused by: java.lang.ClassNotFoundException: org.slf4j.LoggerFactory
    at java.net.URLClassLoader$1.run(URLClassLoader.java:217)
    at java.security.AccessController.doPrivileged(Native Method)
    at java.net.URLClassLoader.findClass(URLClassLoader.java:205)
    at java.lang.ClassLoader.loadClass(ClassLoader.java:321)
    at sun.misc.Launcher$AppClassLoader.loadClass(Launcher.java:294)
    at java.lang.ClassLoader.loadClass(ClassLoader.java:266)
    ... 3 more
zookeeper@zookeeper-virtual-machine:~/zookeeper-3.4.5$ 

今天早上我遇到了类似的问题,但该线程上的特定问题已得到解决. 为什么java不能找到我的班级？

当我通过命令行参数时,为什么会出现类未找到错误？我怎样才能解决这个问题？

这是java代码:

package org.zookeeper;
import java.io.IOException;
import java.util.List;
import java.util.concurrent.CountDownLatch;

import org.apache.zookeeper.KeeperException;
import org.apache.zookeeper.WatchedEvent;
import org.apache.zookeeper.Watcher;
import …

我正在使用kafka_2.9.2-0.8.1.1和zookeeper 3.4.6.

有没有办法动态更改代理配置设置？具体来说,我想改变controlled.shutdown.enable

bin/kafka-topics.sh --zookeeper zookeeper01.mysite.com --config controlled.shutdown.enable=true --alter

但我得到了错误

Missing required argument "[topic]"

我在从任何远程计算机连接Apache Phoenix JDBC客户端(我将sqlline.py用于测试目的)连接到我的Hbase时遇到问题.

我正在测试的方式如下:

我ssh到另一台运行linux的机器,然后尝试连接到我的zookeeper仲裁(目前只有一台机器:christianwith-KP):

    hadoopuser@mike-iMac ~/phoenix-4.4.0-HBase-1.0-bin/bin $./sqlline.py christianwirth-KP
    Setting property: [isolation, TRANSACTION_READ_COMMITTED]
    issuing: !connect jdbc:phoenix:christianwirth-KP none none org.apache.phoenix.jdbc.PhoenixDriver
    Connecting to jdbc:phoenix:christianwirth-KP
    SLF4J: Failed to load class "org.slf4j.impl.StaticLoggerBinder".
    SLF4J: Defaulting to no-operation (NOP) logger implementation
    SLF4J: See http://www.slf4j.org/codes.html#StaticLoggerBinder for further details.
    15/08/06 14:11:36 WARN util.NativeCodeLoader: Unable to load native-hadoop library for your platform... using builtin-java classes where applicable

尝试连接命令行后什么也没做,几分钟后我得到了很多java错误信息.

这是来自日志文件zookeeper.out,似乎Zookeeper正在接受来自运行sqlline.py的远程客户端的连接,因为IP地址与我正在尝试连接的远程计算机匹配.

    2015-08-06 14:10:37,720 [myid:] - INFO  [NIOServerCxn.Factory:0.0.0.0/0.0.0.0:2181:NIOServerCnxnFactory@197] - Accepted socket connection from /192.168.59.148:39731
    2015-08-06 14:10:37,721 [myid:] - INFO  [NIOServerCxn.Factory:0.0.0.0/0.0.0.0:2181:ZooKeeperServer@868] - Client …

我试图在我们的项目中使用Zookeeper.可以运行服务器..即使使用zkcli.sh测试它..一切都很好..但是找不到一个很好的教程让我用Java连接到这个服务器!我在Java API中需要的只是一种方法

public String getServiceURL ( String serviceName ) 

我试过https://cwiki.apache.org/confluence/display/ZOOKEEPER/Index - >对我不好.

http://zookeeper.apache.org/doc/trunk/javaExample.html:排序好的; 但是不能清楚地理解概念!我觉得它没有得到很好的解释..

我必须执行以下操作：

1. 我必须在 2 个服务器/节点上部署 Solr。
2. 在另一台服务器上部署 Zookeeper。
3. 将自定义配置上传到 Zookeeper
4. 创建具有 2 个分片和 2 个副本的自定义集合

Solr 7.4.0 和 Zookeeper 版本： 3.4.12

我做了以下事情：

设置动物园管理员：

• 创建了一个 Zookeeper 数据文件夹并创建了一个 Zoo.conf 并将 dataDir 放在那里。
• 开始使用 Zookeeper./zkServer.sh start

设置 Solr：

• 使用以下命令启动 Solr：

  ./solr start -cloud -s /home/demo/LocalFolder/Downloads/SolrHome -p 8987 -z localhost:2181

• 尝试使用以下方式在 Zookeeper 中上传配置： ./solr create -c mycollection -d /media/sf_VM/Dump/conf

它给了我一个例外：

Caused by: javax.servlet.UnavailableException: Error processing the request. CoreContainer is either not initialized or shutting down.
    at org.apache.solr.servlet.SolrDispatchFilter.doFilter(SolrDispatchFilter.java:341)
    at org.apache.solr.servlet.SolrDispatchFilter.doFilter(SolrDispatchFilter.java:323)
    at org.eclipse.jetty.servlet.ServletHandler$CachedChain.doFilter(ServletHandler.java:1634)
    at org.eclipse.jetty.servlet.ServletHandler.doHandle(ServletHandler.java:533)
    at …

我正在尝试在 UNIX 上启动 kafka，但首先我需要运行 Zookpeer。我有来自https://www.apache.org/dyn/closer.cgi?path=/kafka/2.0.0/kafka_2.11-2.0.0.tgz的 kafka 2.12 版本 我运行命令bin/zookeeper-server-start.sh config/zookeeper.properties，但出现错误：

/kafka_2.12-2.0.0/bin/kafka-run-class.sh: line 306: /project/multiar/jdk1.7.0_17_x64/bin/java: No such file or directory
/kafka_2.12-2.0.0/bin/kafka-run-class.sh: line 306: exec: /project/multiar/jdk1.7.0_17_x64/bin/java: cannot execute: No such file or directory.

我的路径中有 Java 8 jdk：

openjdk version "1.8.0_161"
OpenJDK Runtime Environment (build 1.8.0_161-b14)
OpenJDK 64-Bit Server VM (build 25.161-b14, mixed mode)

为什么我无法运行zookeper服务器？我应该安装 jdk 7 还是更改.sh文件中的某些内容？

我正在开发 Spring Boot + Apache Kafka + Apache Zookeeper 示例。我已经在本地 Windows 机器上安装/设置了 Apache Zookeeper 和 Apache Kafka。我从链接中获取了参考：https : //www.tutorialspoint.com/spring_boot/spring_boot_apache_kafka.htm并按原样执行了代码：

设置：https : //medium.com/@shaaslam/installing-apache-kafka-on-windows-495f6f2fd3c8

错误：

org.springframework.context.ApplicationContextException: Failed to start bean 'org.springframework.kafka.config.internalKafkaListenerEndpointRegistry'; nested exception is org.apache.kafka.common.errors.TimeoutException: Timeout expired while fetching topic metadata
    at org.springframework.context.support.DefaultLifecycleProcessor.doStart(DefaultLifecycleProcessor.java:185) ~[spring-context-5.1.3.RELEASE.jar:5.1.3.RELEASE]
    at org.springframework.context.support.DefaultLifecycleProcessor.access$200(DefaultLifecycleProcessor.java:53) ~[spring-context-5.1.3.RELEASE.jar:5.1.3.RELEASE]
    at org.springframework.context.support.DefaultLifecycleProcessor$LifecycleGroup.start(DefaultLifecycleProcessor.java:360) ~[spring-context-5.1.3.RELEASE.jar:5.1.3.RELEASE]
    at org.springframework.context.support.DefaultLifecycleProcessor.startBeans(DefaultLifecycleProcessor.java:158) ~[spring-context-5.1.3.RELEASE.jar:5.1.3.RELEASE]
    at org.springframework.context.support.DefaultLifecycleProcessor.onRefresh(DefaultLifecycleProcessor.java:122) ~[spring-context-5.1.3.RELEASE.jar:5.1.3.RELEASE]
    at org.springframework.context.support.AbstractApplicationContext.finishRefresh(AbstractApplicationContext.java:879) ~[spring-context-5.1.3.RELEASE.jar:5.1.3.RELEASE]
    at org.springframework.context.support.AbstractApplicationContext.refresh(AbstractApplicationContext.java:549) ~[spring-context-5.1.3.RELEASE.jar:5.1.3.RELEASE]
    at org.springframework.boot.SpringApplication.refresh(SpringApplication.java:775) [spring-boot-2.1.1.RELEASE.jar:2.1.1.RELEASE]
    at org.springframework.boot.SpringApplication.refreshContext(SpringApplication.java:397) [spring-boot-2.1.1.RELEASE.jar:2.1.1.RELEASE]
    at org.springframework.boot.SpringApplication.run(SpringApplication.java:316) [spring-boot-2.1.1.RELEASE.jar:2.1.1.RELEASE]
    at org.springframework.boot.SpringApplication.run(SpringApplication.java:1260) [spring-boot-2.1.1.RELEASE.jar:2.1.1.RELEASE]
    at org.springframework.boot.SpringApplication.run(SpringApplication.java:1248) [spring-boot-2.1.1.RELEASE.jar:2.1.1.RELEASE]
    at com.tutorialspoint.SpringKafkaTutorialspointApplication.main(SpringKafkaTutorialspointApplication.java:21) …

按照Apache Kafka快速入门指南，我完成了以下步骤：

• 下载并解压缩 kafka_2.11-2.1.0.tgz
• cd kafka_2.11-2.1.0
• bin/zookeeper-server-start.sh config/zookeeper.properties
• 在另一个终端的相同目录下， bin/kafka-server-start.sh config/server.properties
• bin/kafka-topics.sh --create --zookeeper localhost:2181 --replication-factor 1 --partitions 1 --topic test。echo $?之后运行，表明该命令以状态退出0

现在是关键时刻。该指南说：

现在，如果我们运行list topic命令，便可以看到该主题：

bin/kafka-topics.sh --list --zookeeper localhost:2181
> test

但是，我没有从该命令获得任何输出，也没有正在测试的软件正在尝试在计算机上发送消息。 "test"主题崩溃，因为它找到该主题的0个分区。

我也有一个Ruby程序，可以将有关主题的消息发送到Kafka "test"。它失败并重试，并且我在Kafka日志中看到了此时创建的主题，并且可以向其发送消息。但是即使那样，列出主题的命令也不会返回任何内容。

为什么不能显式创建主题？为什么我不能列出按需创建的主题？我该如何解决？

日志

这是我在日志中看到的内容：https : //gist.github.com/nathanl/bea7a45a056b2d44146947ec88c29185

我目前有一个 3 节点 Kafka 集群，它连接到我的 Zookeeper 整体中的基本 chroot 路径。

zookeeper.connect=172.12.32.123:2181,172.11.43.211:2181,172.18.32.131:2181

现在，我想添加一个新的 5 节点 Kafka 集群，它将连接到同一个 Zookeeper 集合中的其他一些 chroot 路径。

zookeeper.connect=172.12.32.123:2181,172.11.43.211:2181,172.18.32.131:2181/cluster/2

这些配置是否会像两个 chroot 的相对路径一样工作？据我了解，原始 Kafka 集群应该连接到基本 chroot 路径以外的其他路径上，以实现更好的隔离。

另外，跨 Kafka 集群拥有相同的 Zookeeper 集合是否很好？该文档表示，通常最好为不同的集群提供隔离的 Zookeeper 集合。