網站首頁 編程語言 正文
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-02-16 mac 使用launchctl 開機時加速vim、emacs
- 2023-02-15 Nginx如何根據前綴路徑轉發到不同的Flask服務_nginx
- 2022-06-08 Golang原生rpc(rpc服務端源碼解讀)_Golang
- 2022-05-20 Spring注入bean的常用的六種方式
- 2022-09-16 Pandas數據形狀df.shape的實現_python
- 2022-04-07 C#異步編程async/await用法詳解_C#教程
- 2022-05-24 Flutter實現滾動選擇數字_Android
- 2022-09-09 Python中Timedelta轉換為Int或Float方式_python
- 最近更新
-
- 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同步修改后的遠程分支