书接上回,想在kafka执行命令,其实是为删除一个无用的topic,但是在不知道正确删除姿势的情况下,只能先创建,顺道练习了一下命令行调整分区数和副本数,也是去年的经验了,今年用的时候又翻半天,记录一下
创建topic
用的命令是kafka-topics.sh,我是在容器里运行的,应该是kafka命令都加到PATH路径了,可以任意位置执行
查看所有topic列表
kafka-topics.sh --zookeeper 192.168.0.1:2181 -list
创建topic
此处创建了三个分区一个副本的主题,一般有几个节点最好创建整数倍的分区,副本话,我们是日志,因为是量很大,倒没考虑多个副本,毕竟1T的日志量,多存一份就是直接存储空间的翻倍,还是要根据实际情况来的.
bash-4.3# kafka-topics.sh --create \
--zookeeper 192.168.0.1:2181 \
--topic test-topic \
--partitions 3 \
--replication-factor 1
Created topic "test-topic".
查看指定topic
bash-4.3# kafka-topics.sh --describe \
--zookeeper 192.168.0.1:2181 \
--topic test-topic
Topic:test-topic PartitionCount:3 ReplicationFactor:1 Configs:
Topic: test-topic Partition: 0 Leader: 3 Replicas: 3 Isr: 3
Topic: test-topic Partition: 1 Leader: 1 Replicas: 1 Isr: 1
Topic: test-topic Partition: 2 Leader: 2 Replicas: 2 Isr: 2
删除topic
删除的话,需要要在kafka和zookeeper同时操作,只操作kafka的话,通过kakfa-manager等工具查看时,topic还会存在
kafka-topics.sh --delete \
--zookeeper 192.168.0.1:2181 \
--topic test-topic
zk操作
cd /usr/lib/zookeeper/bin
zkCli.sh -server 127.0.0.1:2181
rmr /brokers/topics/test-topic
转载请注明: 转自Rainbird的个人博客 本文链接: ELK|kafka增加及删除topic