Zookeeper客户端无法rmr/brokers/topics/MY_TOPIC
我试图删除一个包含8个分区和2个复制的Kafka主题。首先，我使用Kafka主题删除该主题。sh——删除命令。然后我使用了zkCli。sh-服务器从属1。。。。。slave3和rmr/brokers/topics/MY_主题。
然而我仍然看到这个话题在 /brokers/topics/.我试着重启Kafka，一切都一样。
顺便说一句，具有1个分区和1个副本的主题可以成功删除。
共有1个答案
您可以设置服务器属性以启用kafka主题的删除
在服务中添加下面提到的行。性质
delete.topic.enable = true
如果您使用rmr/brokers/topics/MY_topic手动删除，那么您还需要从zookeeper ex-consumer信息中的其他节点删除与主题相关的元数据。还需要删除kafka服务器上的kafka主题控制器。
更干净的是启用主题删除属性并执行kafka-topics.sh
-
主要内容：1.概述,2.接口描述1.概述 在 dubbo-remoting-zookeeper 模块，实现了 Dubbo 对 Zookeeper 客户端的封装。在该模块中，抽象了通用的 Zookeeper Client API 接口，实现了两种 Zookeeper Client 库的接入： 基于 Apache Curator 实现： <dubbo:registry address=“zookeeper://127.0.0.1:2
-
我编写了一个简单的HBase客户端程序来在我的HBase集群（1个主服务器和3个区域服务器）中执行CRUD操作。Zookeeper实例仅在主服务器中运行，仲裁包括所有4台服务器。集群运行良好，可以使用YCSB客户端执行读/写操作（意味着服务器/Zookeeper端没有任何错误）。 现在，在eclipse类路径中，我添加了所有HBase库和hbase-0.94.7.jar（包含hbase-defau
-
一、基本依赖 Curator 是 Netflix 公司开源的一个 Zookeeper 客户端，目前由 Apache 进行维护。与 Zookeeper 原生客户端相比，Curator 的抽象层次更高，功能也更加丰富，是目前 Zookeeper 使用范围最广的 Java 客户端。本篇文章主要讲解其基本使用，项目采用 Maven 构建，以单元测试的方法进行讲解，相关依赖如下： <dependencies
-
主要内容：实例,实例本教程使用的 IDE 为 IntelliJ IDEA，创建一个 maven 工程，命名为 zookeeper-demo，并且引入如下依赖，可以自行在maven中央仓库选择合适的版本，介绍原生 API 和 Curator 两种方式。 IntelliJ IDEA 相关介绍： Intellij IDEA 使用教程 Maven IntelliJ <dependency> <groupId>junit</g
-
URI 方法 URI() string 返回当前客户端使用的服务器地址。 SetURI 方法 SetURI(uri string) 设置当前客户端使用的服务器地址。如果你想要设置多个服务器地址，请使用 SetURIList 方法代替该方法。 URIList 方法 URIList() []string 返回当前客户端可使用的服务器地址列表。 SetURIList 方法 SetURIList(uriL
-
zookeeper 命令用于在 zookeeper 服务上执行操作。 首先执行命令，打开新的 session 会话，进入终端。 下面开始讲解基本常用命令使用，其中 acl 权限内容在后面章节详细阐述。 ls 命令 ls 命令用于查看某个路径下目录列表。 格式： path：代表路径。 以下实例查看 /runoob 节点： ls2 命令 ls2 命令用于查看某个路径下目录列表，它比 ls 命令列出更多