码迷,mamicode.com
首页 > 其他好文 > 详细

kafka常用命令(cdh5.10.0+kafka)

时间:2018-06-08 17:22:46      阅读:201      评论:0      收藏:0      [点我收藏+]

标签:arc   cal   清除   kafka   http   console   font   oca   gravity   

参考资料:http://kafka.apache.org/quickstart

进入kafka安装目录(CDH安装路径为:/opt/cloudera/parcels/KAFKA):
进入bin目录:

  1. cd /opt/cloudera/parcels/CDH-5.10.0-1.cdh5.10.0.p0.41/bin  


创建topic,一个备份,6个分区

  1. kafka-topics --create --zookeeper personas1:2181 --replication-factor 1 --partitions 6 --topic TP_LABEL  

查看所有topic

  1. kafka-topics --list --zookeeper personas1:2181  

增加分区

  1. kafka-topics --zookeeper personas1:2181 --alter --topic TP_LABEL --partitions 8  

消费者

 

 
  1. kafka-console-consumer --zookeeper personas1:2181,personas2:2181,personas4:2181 --topic TP_LABEL  

删除kafka topic(1、删除topic,2、删除zk注册信息,3、删除源数据)

 

 
  1. kafka-topics --delete --zookeeper personas1:2181 --topic TP_LABEL  

进入CDH bin目录

 

 

  1. cd /opt/cloudera/parcels/CDH-5.10.0-1.cdh5.10.0.p0.41/bin  
  2. zookeeper-client  
  3. rmr /brokers/topics/TP_LABEL  

删除源数据,删除分区源数据(如果只有一个topic,直接把data删掉)

 

 
  1. cd /var/local/kafka/data  
  2. rm -rf TP_LABEL-*  

彻底清除zk中的注册信息,把kafka停掉,只保留箭头所指的配置,把其他kafka的信息全部删除

技术分享图片



kafka常用命令(cdh5.10.0+kafka)

标签:arc   cal   清除   kafka   http   console   font   oca   gravity   

原文地址:https://www.cnblogs.com/lenmom/p/9156510.html

(0)
(0)
   
举报
评论 一句话评论(0
登录后才能评论!
© 2014 mamicode.com 版权所有  联系我们:gaon5@hotmail.com
迷上了代码!