1.主题命令行操作，查看操作主题命令参数
bin/kafka-topics.sh
参数
描述
–bootstrap-server
连接的 Kafka Broker 主机名称和端口号。
–topic
操作的 topic 名称。
–create
创建主题。
–delete
删除主题。
–alter
修改主题。
–list
查看所有主题。
–describe
查看主题详细描述。
–partitions
设置分区数。
–replication-factor
设置分区副本。
–config
更新系统默认的配置。
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
Original: https://www.cnblogs.com/hz-Master/p/16272471.html
Author: hz15968199950
Title: Kafka 主题命令行操作
原创文章受到原创版权保护。转载请注明出处：https://www.johngo689.com/563054/
转载文章受原作者版权保护。转载请注明原作者出处！