kafka如何清理topic数据

IT
IT
IT
335
文章
1
评论
2020年5月15日14:19:47 评论 2,209 400字阅读1分20秒

先查看有哪些topic

[root@kafka kafka]# pwd
/usr/local/kafka
[root@kafka kafka]# bin/kafka-topics.sh --list --zookeeper 192.168.1.60:2181
__consumer_offsets
api-cost-topic
api-profit-topic

删除

[root@kafka bin]# pwd
/usr/local/kafka/bin

[root@kafka bin]# bash kafka-topics.sh --delete --zookeeper 192.168.1.58:2181 --topic api-cost-topic
Topic api-cost-topic is marked for deletion.
Note: This will have no impact if delete.topic.enable is not set to true.
  • 我的QQ
  • QQ扫一扫
  • weinxin
  • 我的头条
  • 头条扫一扫
  • weinxin
IT
  • 本文由 发表于 2020年5月15日14:19:47
  • 除非特殊声明,本站文章均为原创,转载请务必保留本文链接
kafka集群 kafka

kafka集群

系统环境 1、操作系统:64位CentOS Linux release 7.2.1511 (Core) 2、jdk版本:1.8.0_121 3、zookeeper版本:zookeeper-3.4.9....
kafka-web kafka

kafka-web

简述 官网的包得需要编译,太过于麻烦,本次提供编译好的包,直接修改配置文件即可 下载 root@localhost ~># git clone https://github.com/cncentosc...
单机版kafka kafka

单机版kafka

下载 安装zookeeper # wget http://mirrors.hust.edu.cn/apache/zookeeper/zookeeper-3.4.10/zookeeper-3.4.10....
kafka集群 kafka

kafka集群

系统环境 1、操作系统:64位CentOS Linux release 7.2.1511 (Core) 2、jdk版本:1.8.0_121 3、zookeeper版本:zookeeper-3.4.9....