书接上回,想在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

弄了一个微信群欢迎正常学习elk的朋友扫码交流.

相关博文

• ELK|ES管理之又见 UNASSIGNED SHARD
• 苹果手机双击打开云闪付地铁付款码
• iOS快捷打开薪人薪事的N种方式
• ELK|kafka增加分区或调整副本数
• Python|把你喜欢的照片合成到微信头像