2022-04-09
执行Kafka Topic 删除操作删除
10M使用 FusionInsight R2C50 版本安装集群，主要安装 Zookeeper、Kafka。
在使用 Kafka 客户端命令删除 Topic 时，发现 Topic 无法被删除。
报错
ARN Can not get the principle name from server
(org.apache.zookeeper.ClientCnxn)
Exception in thread "main" org.I0Itec.zkclient.exception.ZkTimeoutException:
at org.I0Itec.zkclient.ZkClient.connect(ZkClient.java:881)
at org.I0Itec.zkclient.ZkClient.<init>(ZkClient.java:95)
at org.I0Itec.zkclient.ZkClient.<init>(ZkClient.java:74)
at kafka.admin.TopicCommand$.main(TopicCommand.scala:51)
at kafka.admin.TopicCommand.main(TopicCommand.scala)
我来答
添加附件
收藏
分享
问题补充
1条回答
默认
最新
评论
回答交流
Markdown
请输入正文
提交
相关推荐
无法从Kafka中获取指定topic 消息
回答 1
已采纳
没有日志不好判断具体原因，可能原因如下1、Kafka服务异常2、Consumer中Zookeeper相关连接地址配置错误，导致无法消费3、Consumer发生ConsumerRebalanceFail
OGG同步ERROR:OGG-01163
回答 6
oggbug很多的，这种只能初始化
从postgresql 到kafka的实时逻辑同步，有哪些比较稳定的工具吗？
回答 2
开源方案Debezium可以了解一下。可以稳定运行在生产环境。
新安装集群启动 Kafka 失败显示认证失败
回答 4
已采纳
先断开对Kafka的认证。等待5分钟，就会被解锁。
执行 Kafka Topic 删除操作报错KAFKA-30001
回答 1
已采纳
可能原因1、客户端命令连接zookeeper地址错误2、Kafka服务异常Kafka部分节点处于停止状态3、Kafka服务端配置禁止删除4、Kafka配置自动创建，且Producer未停止
ogg同步数据到kafka，topic中查不到
回答 2
topic名称不正确。检查kafka.props配置文件中定义的topicMappingTemplate是否正确。topic名称必须与目标端Kafka集群中存在的topic名称一致。数据格式不正确。检
多个平台MySQL数据库到单套kafka集群通过canal做同步，这个架构怎么搭建比较好?
回答 3
已采纳
kafka至少三节点的集群，硬盘要速度快，容量大，kafka里java相关的参数肯定要调整。另外最好考虑增量模式，全量模式可能会浪费磁盘空间。
大佬们 说说Kafka 有啥使用场景了 对这个东西定位不好啊
回答 1
当消息队列使用较为多，可以用作应用解耦。异步处理。消峰填谷。但是一般业务量不大的话，直接读写数据库更加好。否则进他是一个步骤，出他又是一个步骤。然后再写库。中间也有消耗。
Flume可以正常连接kafka但是发送消息失败
回答 1
已采纳
1、查看Kafka服务是否正常。2、Flume连接Kafka地址是否正常。3、Flume发送超过Kafka大小限制。
kafka过来的topic类似a-a a-b a-c 这个格式,如何能不用一个个加入到logstash.conf 就能进行分类筛选?
回答 1
不会路过
问题信息
请登录之后查看
邀请回答
暂无人订阅该标签，敬请期待~~
