如何删除Zookeeper中的所有旧节点
删除Zookeeper中的所有旧节点可以通过以下步骤完成：
- 连接到Zookeeper集群：使用Zookeeper提供的客户端工具或编程语言的Zookeeper客户端库，连接到Zookeeper集群。例如，使用Java编程语言可以使用Apache Curator库来连接和操作Zookeeper。
- 获取所有旧节点：使用Zookeeper客户端库提供的API，获取Zookeeper中的所有节点信息。可以使用
getChildren方法获取指定节点的子节点列表，或者使用getAllChildren方法获取Zookeeper中的所有节点。 - 遍历并删除旧节点：遍历获取到的节点列表，逐个删除旧节点。使用Zookeeper客户端库提供的
delete方法可以删除指定节点。在删除节点时，可以选择是否递归删除节点及其子节点。 - 确认节点已删除：删除节点后，可以使用Zookeeper客户端库提供的API再次确认节点是否已成功删除。可以使用
exists方法检查指定节点是否存在。
总结：
Zookeeper是一个分布式协调服务，用于管理和协调分布式系统中的节点。删除Zookeeper中的所有旧节点可以通过连接到Zookeeper集群，获取所有节点信息，遍历并删除旧节点的方式完成。删除节点时需要注意是否递归删除节点及其子节点，并在删除后确认节点是否已成功删除。
腾讯云相关产品推荐：
- 腾讯云 ZooKeeper：腾讯云提供的ZooKeeper托管服务，可轻松创建和管理ZooKeeper集群。详情请参考：腾讯云 ZooKeeper
- 腾讯云云服务器（CVM）：提供高性能、可扩展的云服务器实例，可用于部署和运行Zookeeper集群。详情请参考：腾讯云云服务器
相关·内容
突然之间，web UI上就没有显示Ambari服务了。然而，我的YARN、HDFS、ZooKeeper、HBase服务运行得很好。有人知道为什么会这样吗？谢谢!
浏览 3提问于2016-08-09得票数 0
我一直在做一些研究，并阅读了ZooKeeper的文档。据说，ZooKeeper的每个节点都保存着其树的复制副本，而动物园管理员在这方面具有很强的一致性。这是否意味着ZooKeeper违反了妨碍可伸缩性的无共享原则？
附注：不共享任何体系结构--在这种架构中，每个节点都是独立的和自给自足的，并且在整个系统中没有单一的争用点。
浏览 4提问于2014-02-15得票数 0
回答已采纳
2回答
我们有一个监听ActiveMQ的后端模块，更改后端拱门后，我们使用Mesos，Marathon和Zookeeper，
现在我们想要监听zookeeper事件，如果Zookeeper有任何更新。
是否有任何客户端或任何东西，用于连接到Zookeeper并监听Zookeeper队列/事件。
提前谢谢。
浏览 0提问于2015-08-10得票数 0
1回答
正如我们在Java链接阻塞队列中看到的那样，take()方法在从队列中出队之前会锁定/锁定尾节点。所以没有两个线程会从尾部获取相同的节点。在zookeeper的情况下，所有监视队列根节点的进程都会收到通知，所有这些进程都可以抓取相同的节点集并开始处理相同的节点。
那么，我该如何将其称为分布式队列呢？我说的是Zookeeper的生产者消费者接收者。
浏览 1提问于2013-05-16得票数 2
回答已采纳
我正在使用一个由3个节点组成的动物园管理员集合，运行3.4.13。有时，在机器重新启动后，动物园管理员不会在其中一个节点启动，我在日志中看到下面的错误。
2019-08-19 04:18:36,906 [myid:2] - ERROR [main:QuorumPeer@692] - Unable to load database on disk
java.io.IOException: The current epoch, 7, is older than the last zxid, 34359738370
at org.apache.zookeeper.server.quorum.Quor
浏览 3提问于2019-08-20得票数 4
回答已采纳
我有一组资源，每个资源都有一个唯一的标识符，每个资源元素在使用之前必须被锁定，在使用后必须解锁。应用程序的逻辑是：
lock any one element;
if (none locked) then
exit with error;
else
get resource-id from lock
use resource
unlock resource
end
Zookeeper看起来像是管理这些锁的一个很好的候选者，它快速而有弹性，而且从客户端故障中恢复似乎非常简单。
有人能想到我如何使用Zookeeper来实现这一点吗？
浏览 0提问于2010-02-23得票数 1
回答已采纳
我在多个服务器上部署了一个微服务，它有两个主要的数据源：
事件持续接收(24/7/365)，高容量(100-1000事件/秒)
一天一次的手术，可能需要一段时间才能完成。
我想以独占模式运行这个每天一次的处理:暂停事件处理，运行一天一次的任务，然后继续事件处理。我已经有一种方法来正确地开始一天一次的操作，但我仍然必须实现1到2之间的锁定以确保独占性。
我发现的大多数ZooKeeper菜谱都需要对每个处理过的事件进行写操作，例如用获取读锁或用进行计数器增加。由于一天一次的评论很少发生，这种每次事件的开销似乎是浪费的。
是否有适合这种用例的动物园管理员/管理员收据？
我考虑过以下几
浏览 3提问于2020-01-24得票数 1
回答已采纳
3回答
当我们使用zookeeper来协调一组Hbase节点时，zookeeper可以与Hbase节点位于相同的节点上，还是必须位于单独的群集上？还有一件事我不太清楚，那就是Zookeeper znode是什么时候创建的，zookeeper znode的用途是什么？Zookeeper官方网站说，这些是zookeeper文件系统的一部分，那么zookeeper znode到底是用来存储的?是配置属性、应用程序数据还是什么内容？
浏览 2提问于2011-11-27得票数 2
回答已采纳
我已经在GCP上创建了一个Kubernetes集群(GKE)，并且正在尝试在这个集群上安装Kafka (参考链接- https://snourian.com/kafka-kubernetes-strimzi-part-1-creating-deploying-strimzi-kafka/)。 当我部署kafka集群时，Zookeeper没有启动： karan@cloudshell:~/strimzi-0.26.0 (versa-kafka-poc)$ kubectl get pv,pvc,pods -n kafka
NAME
浏览 63提问于2021-11-17得票数 0
我已经设置了kafka zookeeper分布式设置，使用3台机器，并且只使用kafka内置的zookeeper。我现在想为这个系统设置私有ips。
我已经在server.properties中设置了host.name=private_ip，设置后我的kafka服务器将在私有ips上运行。
但是不知道如何为zookeeper设置内网ip。我需要在zookeeper.properties中设置一些东西吗？
或者有没有其他的设置？
浏览 4提问于2016-03-13得票数 0
我可以不使用zookeeper创建一个cloudsolrclient吗？我不想添加对zookeeper的依赖，也不想直接与solrcloud对话。 这是我当前的代码..这里的端点是zookeeper的端点。我试着给solr的url，但它抛出异常说“无法初始化一个HttpClusterStateProvider (是/是Solr服务器(S)是/是关闭” CloudSolrClient.Builder builder = new Builder(Arrays.asList(endpoint)); return builder.build(); 更新： 使用HttpSolrClient创建客户端并
浏览 28提问于2019-05-23得票数 0
回答已采纳
1回答
我有一个完全分布的Hadoop和Hbase两个节点的实例。HDFS很好地工作在主和从上。但是HBase shell在节点名被格式化后只工作了一次，并且集群是新的，之后我得到了错误: org.apache.hadoop.hbase.PleaseHoldException: Master正在初始化hbase。
另外，我无法从从节点通过hbase连接，我总是被错误连接拒绝，并且在HBase网络用户界面中，我只能在地区服务器上看到，它是主节点。
Master hbase-site.xml：
<configuration>
<property>
<n
浏览 3提问于2016-09-28得票数 0
回答已采纳
我有两个进程在各自的JVM中运行(例如节点A和B)。它们连接到单个ZooKeeper服务器，以协调任务执行。任何一个节点(A或B)都应该一次执行一个scheduled task (freq 1 minute)，而不是同时执行。此外，如果A失败，则B应接管，在下一个预定时间执行任务。
以下是问题
节点A赢得竞争，并在ZooKeeper上创建一些临时节点，以指示它已经开始执行task.Once A，它开始执行任务，它失去了与ZooKeeper的连接，因此ZooKeeper在一段时间后删除了该临时节点。由于意外的大数据量，执行超过了1分钟的边界。现在，当B醒来时，它将不会看到A先前创建的任何临时节点
浏览 10提问于2015-07-23得票数 2
我使用动物园管理员，不能创建znode。
[root@server-1 bin]# sh zkCli.sh -server 127.0.0.1:2183
Connecting to 127.0.0.1:2183
Welcome to ZooKeeper!
JLine support is enabled
WATCHER::
WatchedEvent state:SyncConnected type:None path:null
[zk: 127.0.0.1:2183(CONNECTED) 0] ls /
[zookeeper]
[zk: 127.0.0.1:2183(CONNECTED)
浏览 0提问于2018-01-01得票数 0
如何使用Kerberos保护独立(非Solr-Cloud)配置上的Solr管理面板？我试过使用，但我不明白如何在没有Zookeeper/security.json的情况下设置认证。
浏览 0提问于2016-08-09得票数 0
1回答
Supervisor.log中的错误消息:风暴监控器猫不能同时创建stormClusterState，它在zk.The nimbus进程的/zk.The/zk.The目录中是空的，但是监督者不能start.why？
org.apache.storm.utils.Utils.handleUncaughtException(Utils.java:663)~storm-client-2.3.0.jar:2.3.0 at org.apache.storm.utils.Utils.handleUncaughtException(Utils.java:667)~storm-client-2.3.0.jar
浏览 12提问于2022-02-15得票数 0
1回答
我刚接触zookeeper编程。我正在尝试使用zookeeper.I实现产生消费者队列。我在初始化队列时遇到异常。在我的zookeeper中，只有一个根条目，即zookeeper。
我正在尝试执行给定的代码。 (不在这里粘贴代码以保持post的整洁)
例外：
org.apache.zookeeper.KeeperException$NoNodeException: KeeperErrorCode = NoNode for /app1
at org.apache.zookeeper.KeeperException.create(KeeperException.java:111)
at org.a
浏览 1提问于2014-06-02得票数 0
2回答
我使用卡夫卡，动物园管理员和卡夫卡-经理来管理集群。
我有3个节点集群。在我从一开始就设置的所有集群中，delete.topic.enable=true
现在，当我要删除一个主题时，它会显示以下错误。
topicxyz - marked for deletion
但它并没有被删除。
我也试着从卡夫卡经理那里删除，上面写着
Yikes! KeeperErrorCode = NodeExists for /admin/delete_topics/topicxyz
错误日志：
kafka-经理
[ESC[31merrorESC[0m] k.m.ApiError$ - error : KeeperEr
浏览 8提问于2017-05-18得票数 5
1回答
我有一个运行在Google Cloud平台上的Kubernetes集群。
我想要将一个postgres映像部署到我的集群。
在选择镜像和集群时，我得到错误信息：
insufficient OAuth scope
我已经读了几个小时了，就是不能让它工作。
我设法将vm的scope设置为允许API：
Cloud API access scopes
Allow full access to all Cloud APIs
但是从GKE集群的详细信息中，我看到除了stackdriver之外的所有东西都被禁用了。
为什么部署镜像或更改作用域会如此困难？
如何在不删除并重新创建集群权限的情况下修改集群权限？
浏览 0提问于2018-11-07得票数 0
我开始在docker上使用Spring Boot Kafka和kafka集群。当我开始检查容错时，我就遇到了这个问题。通常，我通过Spring Boot中的Kafka Admin创建一个主题(复制因子= 2)。我能够存储一些消息，并从Kafka消费它们。但是在停止了其中一个kafka容器(我有两个kafka实例和一个zookeeper)之后，我的消费者无法与剩下的那个进行通信。
我已经向bootstrap.servers属性提供了：
SPRING_KAFKA_BOOTSTRAP_SERVERS: kafka:9092,kafka2:9093
我创建主题的kafka admin bean看起来像
浏览 2提问于2019-07-19得票数 1
我现在正在读Apache ZooKeeper。我在互联网上看了很多文档和文章，但我越来越困惑于ZooKeeper到底是如何工作的？
目前，我知道ZooKeeper为跨节点同步提供了一个基础设施，应用程序可以使用它来确保跨集群的任务是序列化或同步的。它维护了一种由“znode”组成的树型文件系统。例如，我有一个集群，它是一个主服务器和两个从服务器，并且在所有服务器中，这种树文件系统结构总是相同的？如果我在其中一个追随者服务器上创建一个新的znode，整个集群会被同步吗？
另一个问题是，每个znode只能包含1M数据，因为ZooKeeper不是设计为容纳非常大的数据值的大型数据存储。但是，如果我需
浏览 0提问于2014-01-16得票数 0
我已经在谷歌上搜索了这些信息，但没有找到任何决定性的信息。我想清除我的zookeeper，如果我在所有根节点上运行rmr，可以吗？
谢谢
浏览 2提问于2016-03-09得票数 0
我的停靠撰写文件如下所示：
version: '3'
services:
zookeeper:
image: confluentinc/cp-zookeeper:latest
environment:
ZOOKEEPER_CLIENT_PORT: 2181
ZOOKEEPER_TICK_TIME: 2000
expose:
- "2181"
kafka:
build: .
depends_on:
- zookeeper
expose:
-
浏览 8提问于2020-06-13得票数 0
我现在很长一段时间都在使用分布式工具。我理解zookeeper和维护元数据的重要性。
想知道Zookeeper是否可以用作配置管理？我的意思是，我像在.properties中一样设置了一些键值对，可以从Kafka或Nifi或其他地方引用(在分布式环境中)。
简单地说，我可以使用zookeeper作为键值对映射吗？帮我理解一下。
浏览 1提问于2019-07-15得票数 0
1回答
在文件夹- /var/hadoop/zookeeper/version-2/下，我们可以看到，Zookeeper日志和快照文件非常频繁地被创建(每分钟有多个文件)，并且在很短的时间内填满了文件系统。
根源
一个或多个应用程序创建或修改more的频率过高，在短时间内导致太多事务。这导致创建了太多的事务日志文件和快照文件，因为它们在默认情况下在100000个条目之后被翻滚(如zookeeper属性‘snapCount’所定义)。
-rw-r--r-- 1 zookeeper hadoop 67108880 Jul 28 17:24 log.570021fa92
-rw-r--r-- 1 zook
浏览 1提问于2022-07-31得票数 0
回答已采纳
我对ZK并不熟悉，所以不确定这是否属实，但是在我的测试中，我发现了以下内容：
ZooKeeper zooKeeper1 = new ZooKeeper(
hosts, // ZooKeeper service hosts
5000, // Session timeout in milliseconds
// Anonymous Watcher Object
watcher);
其中，观察者是一个监视实例。
如果我这么做的话
zooKeeper1.exists("/test13",
浏览 3提问于2014-01-24得票数 1
回答已采纳
1回答
我正在尝试让YCSB-0.1.4在CDH 5.1.2上测试Hbase 0.98.1。我遵循了这里的说明，。当我运行YCSB测试时，它可以工作，但不会将数据加载到用户表中。在下面的日志files.see命令中看不到任何错误，并且操作为零。如何修复？
$ bin/ycsb load hbase -P workloads/workloada -p columnfamily=f1 -s | tee -a workloada.dat
YCSB Client 0.1
Command line: -db com.yahoo.ycsb.db.HBaseClient -P workloads/workload
浏览 2提问于2014-09-24得票数 2
我已发出命令，删除以下主题：
./bin/kafka-topics.sh --zookeeper localhost:2181 --delete --topic vip_ips_alerts
它似乎给出了一个愉快的答复：
[2014-05-31 20:58:10,112] INFO zookeeper state changed (SyncConnected) (org.I0Itec.zkclient.ZkClient)
Topic "vip_ips_alerts" queued for deletion.
但10分钟后，主题仍然出现在--list命令中：
./bin/kaf
浏览 3提问于2014-06-01得票数 84
回答已采纳
我正在尝试使用我的minikube集群中的kafka控制台生产者和消费者。
以下是我的服务：
NAME TYPE CLUSTER-IP EXTERNAL-IP PORT(S) AGE
java-api NodePort 10.108.162.108 <none> 8080:30141/TCP 8d
kafka-service NodePort 10.104.71.239 <none> 29092:32676/TCP 66m
浏览 0提问于2020-09-29得票数 0
我有one动物园管理员集群，并希望将其用于几种环境(分期、生产等)。
在这种情况下，如何配置recovery.zookeeper.path.*参数？
我认为有两种可能的方法：
recovery.zookeeper.path.root: /{{ env }}/flink
recovery.zookeeper.path.latch: /{{ env }}/leaderlatch
recovery.zookeeper.path.leader: /{{ env }}/leader
或
recovery.zookeeper.path.root: /{{ env }}/flink
recovery.zoo
浏览 2提问于2016-04-06得票数 1
回答已采纳
2回答
当我读动物园管理员的时，我感到很困惑。这个分布式锁的配方似乎不能保证“任何快照--没有两个客户认为他们持有相同锁”的。但是由于ZooKeeper被广泛采用，如果参考文档中存在这样的错误，那么很久以前就应该有人指出它，那么我误解了什么呢？
引用
锁
全分布式锁是全局同步的，意味着在任何时间快照时，没有两个客户机认为它们持有相同的锁。这些可以使用ZooKeeeper实现。与优先级队列一样，首先定义一个锁节点。
调用create( )，路径名为"locknode/guid-lock-“，并设置序列和临时标志。
在不设置监视标志的情况下调用锁节点上的getChildren( )
浏览 2提问于2013-01-11得票数 23
回答已采纳
我已经设置了一个外部zookeeper合奏，它工作得很好。但是我不能弄清楚zookeeper如何将集合分布在多个实例上?有没有什么方法可以让我们指定如何在多台机器上分布集合？
浏览 0提问于2019-05-06得票数 1
我想知道Hadoop重新格式化namenode后如何处理磁盘数据。namenode在HDFS数据中存储来自磁盘数据映射的群集元存储。在重新格式化namenode时，hadoop如何执行磁盘数据删除？我会很感激的！
浏览 1提问于2015-03-30得票数 0
我有一个用Zookeeper写的配置信息。我正在使用Apache Curator通过Curator Watcher读取配置(如果有更好的解决方案，我很乐意使用它)，所以如果Zookeeper中的配置发生更改，我将收到新的配置。我在Spark中使用这个配置。如何将其共享给同一应用程序的所有spark executors？
谢谢!
LE：
谢谢你，迪凯
在下面的代码中，您将在哪里实现观察器？我是spark的新手，我不太确定每个工人都能得到什么。
谢谢!
final JavaDStream<ElementMessage> nodeMessageStream = mapWithStateD
浏览 1提问于2016-07-05得票数 1
的示例展示了如何在从连接中排出节点之后，在不同的节点上重新调度豆荚，这通常是因为必须对其执行维护。
豆荚的重新调度具有与以前相同的标识，在本例中是myid ZooKeeper服务器，对应于每个荚zk-0、zk-1等的增量数量。
如果节点没有响应(可能是由于过载或网络问题)，那么Kubernetes是否有可能在原来的吊舱仍在运行时重新安排另一个节点上的吊舱？
它似乎是，但我不知道如何验证它，除非在云提供商上设置多个节点并尝试它。
浏览 0提问于2017-01-29得票数 3
回答已采纳
1回答
替换ZooKeeper服务器
、、、、
我想用3台新的ZooKeeper服务器取代当前的3台ZooKeeper服务器。我补充说：
新动物园到安巴里，
将新动物园添加到变量中：
hbase.zookeeper.quorum ha.zookeeper.quorum zookeeper.connect hadoop.registry.zk.quorum yarn.resourcemanager.zk-address
重新启动服务，重新启动RM，当我关闭所有旧的动物园服务器时，我仍然无法连接到任何新的动物园。
动物园管理员-客户端-server动物园-new1我得到以下错误：
“无法从服务器会话to 0x0读取其他数
浏览 3提问于2016-04-01得票数 1
回答已采纳
启动hbase集群时，我面临以下错误
2015-05-15 16:58:31,741 WARN [regionserver60020- SendThread(hbasenamenode:2181)] zookeeper.ClientCnxn: Session 0x0 for server null, unexpected error, closing socket connection and attempting reconnect
java.net.ConnectException: Connection refused
at sun.nio.ch.SocketCh
浏览 6提问于2015-05-07得票数 0
我想要创建节点组选择器，其中只包含主荚和排除备份荚在kubernates。如何使用舵机图表实现这一目标？
appVersion: version1
kind: StatefulSet
metadata:
name: statefulname
label:
....
....
....
spec:
replica: 2
.....
container:
.....
....
nodeselecor:
{{$nodegroup}}
这里的结果是
NAME READY STATUS
浏览 7提问于2022-03-04得票数 0
回答已采纳
如何更新父项或删除父项？最后，我想删除"Aufgabe1“和所有其他子元素。我还想更新父母"Aufgabe1“的名字，我希望有人能理解我的意思。我用javascript编写代码 ?
浏览 12提问于2021-04-20得票数 0
回答已采纳
至少需要3个ActiveMQ实例和3个ZooKeeper服务器来运行具有复制的LevelDB存储的主/从设置，这背后的理由是什么？如果ZooKeeper的使用要求至少需要3台服务器，那么ZooKeeper要求至少3台服务器提供可靠性的理由是什么？
它是为了保证在网络分区的情况下的一致性(通过牺牲较小的分区上的可用性)，就像在2节点的主备份配置中一样，不可能区分失败的对等节点还是处于不同网络分区中的两个节点？
它是为了提供对拜占庭式故障的容忍度吗?在这种情况下，需要2f+1节点来生存f个故障节点(考虑到崩溃故障只需要f+1节点才能生存f故障)吗？
或者还有其他原因？
谢谢!
浏览 4提问于2014-11-26得票数 0
我使用两台机器构建ZooKeeper集群。然后我有以下问题：
(1)配置完成后，在每台机器上分别启动Zookeeper，工作方式如下:机器A显示为追随者，机器B表示领导者。但是我将机器A设置为server1，将机器B设置为server2。我想知道ZooKeeper是如何选择领导者和追随者的
(2)然后我在机器B上运行"zkServer.sh stop“，然后在机器A上运行"zkServer.sh status”，发现了错误"Error contacting service. It B not running“。预期的行为应该是机器A将从追随者更改为领导者，对吗？而是为什
浏览 0提问于2018-03-03得票数 1
条件1-我在ECS中使用Apache NIFI集群作为docker，并在EC2实例中运行一个外部Zookeeper，一切正常。
但我也希望保持动物园管理员的高可用性，因此
条件2-我在ECS中使用Apache NIFI集群作为docker，并在不同的EC2实例中运行2个外部Zookeeper。当两个Zookeeper都启动时，一切正常，但当我关闭其中一个Zookeeper时，它会导致错误对话框显示“集群连接-此节点当前未连接到集群。此处对数据流所做的任何修改都不会在集群中复制”。我的期望是，当一个Zookeeper宕机时，应该有另一个人接手，这样才能保持高可用性。请指出我做错了什么。我对NIF
浏览 1提问于2020-09-16得票数 1
2回答
我刚刚遇到了Zookeeper，我想知道Zookeeper和一个可用的、一致的、持久的、分布式的、复制的数据库服务，比如亚马逊DynamoDB，甚至亚马逊S3(存储服务)有什么不同。配置管理、分布式同步等关键功能可以通过像亚马逊DynamoDB这样的数据库产品很好地实现。我知道Zookeeper和像DynamoDB这样的产品在架构上会有所不同。但是，从功能的角度来看，这两者之间有什么主要区别吗？有什么理由使用Zookeeper而不是其他的吗？
浏览 0提问于2018-05-21得票数 8
1回答
我在网上看到过一些关于使用Zookeeper在服务器联机时为服务器分配分片编号的帖子(假设您正在跨集群分片数据)-但在我的生活中，找不到一个Java代码示例来说明如何做到这一点。有没有人已经把它弄好了？谢谢。
浏览 1提问于2012-03-16得票数 3
回答已采纳
我刚接触apache zookeeper，我从一篇文章中读到
Zookeeper manages the entire workflow of starting and stopping various nodes in the Hadoop’s cluster.
如果是这样的话，谁能告诉我..
浏览 0提问于2014-08-08得票数 1
1回答
我遵循配置messos 3节点主节点和3节点从集群。但是，当我启动主动物园管理员时，我会得到以下错误日志
2017-07-05 09:46:18,568 - INFO [main:FileSnap@83] - Reading snapshot /var/lib/zookeeper/version-2/snapshot.100000016
2017-07-05 09:46:18,606 - ERROR [main:FileTxnSnapLog@210] - Parent /mesos/log_replicas missing for /mesos/log_replicas/0000000002
浏览 2提问于2017-07-05得票数 0
回答已采纳
我使用的是Dockerized static Kafka集群(0.11)，它有3个代理。这个集群的问题是，如果所有代理都在同一端口上运行，则控制器节点不允许我创建主题。
但是，如果所有代理都在不同的端口上运行，则可以正常工作。
我的问题是，尽管我在不同的节点上运行每个代理，但它为什么不能在相同的端口上工作？
以下是我的代理配置模板：
auto.leader.rebalance.enable=true
broker.id.generation.enable=false
broker.id={{KAFKA_BROKER_ID}}
auto.create.topics.enable=true
def
浏览 14提问于2018-02-19得票数 0
我使用Zookeeper作为集群的群组通信框架。在我的集群中，每当一个节点崩溃时，我都想要一个同样的事件。该怎么做呢？早些时候，我使用JGroup作为组通信框架，集群中的每个节点都用来连接到相同的通道，每当特定节点崩溃时，Jgroup都会生成一个事件。
浏览 3提问于2013-01-04得票数 2
2回答
嗨，我正在尝试从我的java程序连接到远程机器上的hbase。但我被拒绝了连接错误。在查看错误时，我认为它是试图连接到本地主机，而不是远程机器。
我的配置就像-
HBaseConfiguration conf = new HBaseConfiguration();
conf.set("hbase.master", "10.219.47.22:60010");
conf.set("hbase.zookeeper.quorum.", "10.219.47.22:60010");
conf.set("h
浏览 4提问于2013-11-15得票数 0
回答已采纳
我正试图按照的教程部署一个简单的动物园管理员集合。这个教程说我需要
具有至少四个节点和每个节点的集群至少需要2个CPU和4个GiB内存。
当我试图应用vCPU文件时，我忽略了这个事实，创建了一个具有n1标准1 (1 .yaml，3.73 GB内存)节点的集群。
apiVersion: v1
kind: Service
metadata:
name: zk-hs
labels:
app: zk
spec:
ports:
- port: 2888
name: server
- port: 3888
name: leader-ele
浏览 0提问于2020-07-11得票数 2
回答已采纳
扫码
添加站长 进交流群
领取专属 10元无门槛券
手把手带您无忧上云
相关资讯
热门标签
云服务器
ICP备案
对象存储
腾讯会议
实时音视频活动推荐
腾讯云开发者
