一:检查kafka是否成功:
创建topic,如能成功创建topic则表示集群安装完成,
也可以用jps命令查看kafka进程是否存在
bin/kafka-topics.sh \
--create \
--zookeeper 172.17.4.16:2181,172.17.4.17:2181,172.17.217.124:2181/kafka \
--replication-factor 3 \
--partitions 3 \
--topic test
bin/kafka-topics.sh \
--list \
--zookeeper 172.17.4.16:2181,172.17.4.17:2181,172.17.217.124:2181/kafka
二:topic 解析:
bin/kafka-topics.sh \
--describe \
--zookeeper 172.17.4.16:2181,172.17.4.17:2181,172.17.217.124:2181/kafka \
--topic kunming
三:删除topic
delete.topic.enable=ture
bin/kafka-topics.sh --delete \
--zookeeper 172.17.4.16:2181,172.17.4.17:2181,172.17.217.124:2181/kafka \
--topic test
kill -9 $(pgrep -f kafka)
虽然进行了设备,并进行了删除,但是只做了个标记:
将进行原数据的删除,直到整个topic删除掉:
1:linux磁盘文件夹
2:zk的/kafka的
ls /kafka/brokers/topics
ls /kafka/config/topics
rmr /kafka/brokers/topics/test