kafka 和 zookeeper 常用命令记录

启动zookeeper

zkServer.sh start

启动kafka服务器

kafka-server-start.sh /software/kafka_2.10-0.10.2.1/config/server.properties

后台启动

kafka-server-start.sh -daemon /software/kafka_2.10-0.10.2.1/config/server.propertie

创建 topic

kafka-topics.sh --create --zookeeper master:2181 --replication-factor 2 --partitions 1 --topic test

查看topic

kafka-topics.sh --list --zookeeper localhost:2181

Send messages

kafka-console-producer.sh --broker-list master:9092 --topic test

启动客户端

kafka-console-consumer.sh --zookeeper master:2181 --topic test --from-beginning

删除topic

kafka-topics  --delete --zookeeper 【zookeeper server】  --topic 【topic name】

如果kafaka启动时加载的配置文件中server.properties没有配置delete.topic.enable=true,那么此时的删除并不是真正的删除,而是把topic标记为:marked for deletion

来查看所有topic

kafka-topics --zookeeper 【zookeeper server】 --list

查看topic明细:

kafka-topics.sh --describe --zookeeper master:2181 --topic test

修改topic参数:

kafka-topics.sh --zookeeper master:2181 --partition 4 --topic test --alter

永久删除topic

kafka-topics.sh --zookeeper master:2181 --delete --topic test

删除kafka存储目录(server.properties文件log.dirs配置,默认为"/tmp/kafka-logs")相关topic目录

删除zookeeper "/brokers/topics/"目录下相关topic节点

cd /usr/lib/zookeeper,或 cd <zookeeper安装目录>

zkCli.sh

ls /brokers/topics/

rmr /brokers/topics/test

rmr /admin/delete_topics/

另外被标记为marked for deletion的topic你可以在zookeeper客户端中通过命令获得:

  ls /admin/delete_topics/【topic name】,

  如果你删除了此处的topic,那么marked for deletion 标记消失

zookeeper 的config中也有有关topic的信息:

ls /config/topics/【topic name】暂时不知道有什么用

总结:

彻底删除topic:

1、删除kafka存储目录(server.properties文件log.dirs配置,默认为"/tmp/kafka-logs")相关topic目录

2、如果配置了delete.topic.enable=true直接通过命令删除,如果命令删除不掉,直接通过zookeeper-client 删除掉broker下的topic即可。

时间: 2024-12-19 18:01:26

kafka 和 zookeeper 常用命令记录的相关文章

AIX LVM 常用命令记录

针对物理卷的操作指令 lsdev--列出ODM中的设备 chdev--修改一个AIX设备的属性 mkdev--创建一个AIX设备 chpv--修改物理卷的状态和属性 lspv--查看AIX中物理卷的相关信息 migratepv--将一个物理卷中的物理分区(数据)迁移到另一个物理卷   针对卷组的操作指令 mkvg--创建新卷组 extendvg--扩展vg reducevg--缩小vg chvg--修改卷组的属性 lsvg--查看卷组的相关信息 importvg--导入vg到AIX系统中 exp

ZooKeeper系列之二:Zookeeper常用命令

ZooKeeper系列之二:Zookeeper常用命令 http://blog.csdn.net/xiaolang85/article/details/13021339 ZooKeeper服务命令: 在准备好相应的配置之后,可以直接通过zkServer.sh 这个脚本进行服务的相关操作 1. 启动ZK服务:       sh bin/zkServer.sh start 2. 查看ZK服务状态: sh bin/zkServer.sh status 3. 停止ZK服务:       sh bin/z

Zookeeper常用命令 (转)

原文链接:ZooKeeper系列之二:Zookeeper常用命令 ZooKeeper服务命令: 在准备好相应的配置之后,可以直接通过zkServer.sh 这个脚本进行服务的相关操作 1. 启动ZK服务:       sh bin/zkServer.sh start 2. 查看ZK服务状态: sh bin/zkServer.sh status 3. 停止ZK服务:       sh bin/zkServer.sh stop 4. 重启ZK服务:       sh bin/zkServer.sh

mysql-mmm常用命令记录

常用命令记录: vim /etc/mysql-mmm/mmm_common.conf vim /var/log/mysql-mmm/mmm_mond.log monitor: service mysql-mmm-monitor start/stop/restart agent: service mysql-mmm-agent start/stop/restart mysql-mmm有6种状态 1.online 2.admin_offline 3.hard_offline 4.awaiting_r

kafka安装及常用命令

kafka是一个开源的分布式消息队列 他提供可靠的集群容错机制,并保证故障切换时的数据完整性. 无论从性能.可靠性.易用性都强过ActiveMQ(client的API感觉还是不如ActiveMQ好用,文档也没有更新到最新版) 下面简单记录一下安装步骤和常用命令. 1.安装 http://kafka.apache.org/documentation.html 下载压缩包并解压 可以解压到 /usr/local/kafka 2.配置 vim conf/server.properties #设置bro

flume、kafka、storm常用命令

出自:http://my.oschina.net/jinp/blog/350293 一些常用命令: storm相关: storm nimbus >/dev/null 2>&1 & storm supervisor >/dev/null 2>&1 & storm ui >/dev/null 2>&1 & 关闭storm ps -ef|grep apache-storm-0.9.2-incubating|grep -v gre

常用命令记录

主要记录Docker工作中,常使用命令: 常用命令: ------------------------------------------------------------------------------- docker build -t name ./path(dockerfile)  #通过dockerfile来创建镜像    --rm=true  表示构建成功后,移除所有中间容器    --no-cache=false 表示在构建过程中不使用缓存 docker run  -it -p

ZooKeeper系列之一:Zookeeper常用命令大神必备

ZooKeeper服务命令: 在准备好相应的配置之后,可以直接通过zkServer.sh 这个脚本进行服务的相关操作 启动ZK服务: sh bin/zkServer.sh start 查看ZK服务状态: sh bin/zkServer.sh status 停止ZK服务: sh bin/zkServer.sh stop 重启ZK服务: sh bin/zkServer.sh restart5.QQ:2606230996可以加我一起交流zk客户端命令 ZooKeeper命令行工具类似于Linux的sh

Zookeeper常用命令

3 常用命令3.1. 启动ZK服务:        bin/zkServer.sh start3.2. 查看ZK服务状态:  bin/zkServer.sh status3.3  停止ZK服务:        bin/zkServer.sh stop3.4. 重启ZK服务:        bin/zkServer.sh restart 3.5  连接服务器          zkCli.sh -server 127.0.0.1:21813.6  查看根目录 ls /3.7  创建 testnod