参考资料:http://kafka.apache.org/quickstart
进入kafka安装目录(CDH安装路径为:/opt/cloudera/parcels/KAFKA):
进入bin目录:
- cd /opt/cloudera/parcels/CDH-5.10.0-1.cdh5.10.0.p0.41/bin
创建topic,一个备份,6个分区
- kafka-topics --create --zookeeper personas1:2181 --replication-factor 1 --partitions 6 --topic TP_LABEL
查看所有topic
- kafka-topics --list --zookeeper personas1:2181
增加分区
- kafka-topics --zookeeper personas1:2181 --alter --topic TP_LABEL --partitions 8
消费者
- kafka-console-consumer --zookeeper personas1:2181,personas2:2181,personas4:2181 --topic TP_LABEL
删除kafka topic(1、删除topic,2、删除zk注册信息,3、删除源数据)
- kafka-topics --delete --zookeeper personas1:2181 --topic TP_LABEL
进入CDH bin目录
- cd /opt/cloudera/parcels/CDH-5.10.0-1.cdh5.10.0.p0.41/bin
- zookeeper-client
- rmr /brokers/topics/TP_LABEL
删除源数据,删除分区源数据(如果只有一个topic,直接把data删掉)
- cd /var/local/kafka/data
- rm -rf TP_LABEL-*
彻底清除zk中的注册信息,把kafka停掉,只保留箭头所指的配置,把其他kafka的信息全部删除
原文地址:https://www.cnblogs.com/lenmom/p/9156510.html
时间: 2024-11-05 22:56:45