Kafka 主题命令行操作

1.主题命令行操作，查看操作主题命令参数

bin/kafka-topics.sh

参数	描述
--bootstrap-server <String: server toconnect to>	连接的 Kafka Broker 主机名称和端口号。
--topic <String: topic>	操作的 topic 名称。
--create	创建主题。
--delete	删除主题。
--alter	修改主题。
--list	查看所有主题。
--describe	查看主题详细描述。
--partitions <Integer: # of partitions>	设置分区数。
--replication-factor<Integer: replication factor>	设置分区副本。
--config <String: name=value>	更新系统默认的配置。

2.创建 first topic 

bin/kafka-topics.sh --bootstrap-server hadoop102:9092 --topic first --create --partitions 1 --replication-factor 3 

3.查看 first 主题的详情

bin/kafka-topics.sh --bootstrap-server hadoop102:9092 --topic first --describe 

4.修改分区数（注意：分区数只能增加，不能减少） 

bin/kafka-topics.sh --bootstrap-server hadoop102:9092 --alter --topic first --partitions 3

5.再次查看 first 主题的详情

bin/kafka-topics.sh --bootstrap-server hadoop102:9092 --topic first --describe

 

标签：--,topics,主题,Kafka,topic,命令行,kafka,first
来源： https://www.cnblogs.com/hz-Master/p/16272471.html