Kafka常用主题操作包括 create、list、descript、alter、delete
使用方法:./kafka-topics.sh --create --zookeeper <host>:<port>[,<host>:<port>,...] --topic <topic-name>
命令用途:链接zookeeper创建指定的主题
示例:
./kafka-topics.sh --create --zookeeper hdp01:2181 --if-not-exists --partitions 5 --replication-factor 1 --topic liumm-topic --config min.insync.replicas=1
描述:
创建一个不存在的指定分区为5,副本数为1,名称为liumm-topic,最小ISR为1的主题
使用方法:./kafka-topics.sh --list --zookeeper <host>:<port>[,<host>:<port>,...]
命令用途:链接zookeeper查看主题
示例:
./kafka-topics.sh --list --zookeeper hdp01:2181
描述:
列出当前所有主题
示例:
./kafka-topics.sh --list --zookeeper hdp01:2181 --topic liumm-topic
描述:
列出指定主题的信息,用于查看某个主题是否存在
使用命令:./kafka-topics.sh --describe --zookeeper <host>:<port>[,<host>:<port>,...]
命令用途:链接zookeeper查看主题消息
示例:
./kafka-topics.sh --describe --zookeeper hdp01:2181
描述:
查看所有主题详情
示例:
./kafka-topics.sh --describe --zookeeper hdp01:2181 --topic liumm-topic
描述:
查看指定主题详情
使用命令:./kafka-topics.sh --alter --zookeeper <host>:<port>[,<host>:<port>,...] --topic <topic-name>
命令用途:修改主题信息,这个脚本将会被过时,未来将被删除。新版本s使用./kafka-configs.sh进行修改
示例:
./kafka-topics.sh --alter --zookeeper hdp01:2181 --topic liumm-topic --partitions 6
描述:
修改主题分区数目,只能增多,不能减少
示例:
./kafka-topics.sh --alter --zookeeper hdp01:2181 --topic liumm-topic --config flush.messages=1000
描述:
新增主题配置
示例:
./kafka-topics.sh --alter --zookeeper hdp01:2181 --topic liumm-topic --delete-config flush.messages
描述:
删除指定主题配置
使用命令:./kafka-topics.sh --describe --zookeeper <host>:<port>[,<host>:<port>,...] --delete --topic <topic-name>
命令用途:链接zookeeper删除主题
示例:
./kafka-topics.sh --zookeeper hdp01:2181 --delete --topic liumm-topic
描述:
删除的主题只能被标记,不是立马删除,需要等下一次压缩才能真正删除,但是需要配置delete.topic.enable=true,压缩时才会删除,否则不起作用
内容来源于网络,如有侵权,请联系作者删除!