網站首頁 編程語言 正文
1. 停止所有節點的kafka服務
2.連接Zookeeper,刪除kafka注冊的數據,比如:
/*******/zookeeper/bin> sh set-env.sh zkCli.sh -server 1.1.1.1:*
[zk: 1.1.1.1:*(CONNECTED) 3] rmr /dmq
3.清理目錄 /*******/kafka-logs 下除 meta.properties 之外的所有文件
4.重啟所有節點的kafka服務
注意:此種清理會清空kafka上的所有數據和消費信息,請慎重, 清理后,之前的topic需要重建
kafka服務如果需要卸載,請一起卸載Zookeeper,否則Zookeeper殘存的數據對新安裝的kafka服務可能會產生不利影響。
原文鏈接:https://blog.csdn.net/wht_0217/article/details/125555582
相關推薦
- 2022-08-15 springboot的熱部署配置
- 2023-11-16 當pytorch找不到 CUDA 時,如何修復錯誤:版本 libcublasLt.so.11 未在帶
- 2023-07-05 React 簡單實現 v-if和v-show的元素控制效果
- 2023-05-24 pytorch中retain_graph==True的作用說明_python
- 2023-10-11 Mybatis-Plus條件構造器的select
- 2022-04-10 python中的單向鏈表實現_python
- 2022-10-21 C++調用matlab函數的實例_C 語言
- 2022-05-09 .Net?Core創建Api進行文件上傳功能_實用技巧
- 最近更新
-
- window11 系統安裝 yarn
- 超詳細win安裝深度學習環境2025年最新版(
- Linux 中運行的top命令 怎么退出?
- MySQL 中decimal 的用法? 存儲小
- get 、set 、toString 方法的使
- @Resource和 @Autowired注解
- Java基礎操作-- 運算符,流程控制 Flo
- 1. Int 和Integer 的區別,Jav
- spring @retryable不生效的一種
- Spring Security之認證信息的處理
- Spring Security之認證過濾器
- Spring Security概述快速入門
- Spring Security之配置體系
- 【SpringBoot】SpringCache
- Spring Security之基于方法配置權
- redisson分布式鎖中waittime的設
- maven:解決release錯誤:Artif
- restTemplate使用總結
- Spring Security之安全異常處理
- MybatisPlus優雅實現加密?
- Spring ioc容器與Bean的生命周期。
- 【探索SpringCloud】服務發現-Nac
- Spring Security之基于HttpR
- Redis 底層數據結構-簡單動態字符串(SD
- arthas操作spring被代理目標對象命令
- Spring中的單例模式應用詳解
- 聊聊消息隊列,發送消息的4種方式
- bootspring第三方資源配置管理
- GIT同步修改后的遠程分支