如果在CDH中安装过Kafka后,后面需要重新安装则可以参考此篇博文。

一、删除Kafka产生的data

重新安装kafka,后面重新分配的kafka一直安装不成功,是因为停用时不会删除已经有点数据。所以需要注意删除  /var/local/kafka/data   下的数据文件,可以看这个路径下的文件:

注意:

如果搭建的分布式,则各个结点的这个路径中的数据都需要删除,不然会导致只有删除  /var/local/kafka/data  数据的结点可以启动kafka,其他均会启动失败。

二、删除 Kafka 在 Zookeeper 中产生的主题数据

首先先连接 Zookeeper:

zookeeper-client

 

然后因为我们CDH中配置 ZooKeeper Root 时候填写过 “/” 与下图的 “/kafka” 两个路径,所以需要分别对应删除掉 zookeeper 中的  “/brokers/topic” 与 “/kafka/brokers/topics” 的主题数据:


删除掉 zookeeper 中的  “/brokers/topic” 的主题数据:

rmr /brokers/topics

删除掉 zookeeper 中的  “/kafka/brokers/topics” 的主题数据:

rmr /kafka/brokers/topics

这样之前安装的Kafka基本清理干净了,可以再试着重新安装。

Logo

Kafka开源项目指南提供详尽教程,助开发者掌握其架构、配置和使用,实现高效数据流管理和实时处理。它高性能、可扩展,适合日志收集和实时数据处理,通过持久化保障数据安全,是企业大数据生态系统的核心。

更多推荐