Kafka常用命令总结_kafka alter

环境

linux系统
/opt/moudle/kafka 目录下
topic名称：first
本机的host：localhost

命令

后台启动

bin/kafka-server-start.sh -daemon config/server.properties
1

关闭

bin/kafka-server-stop.sh stop
1

查看所有topic

bin/kafka-topics.sh --zookeeper localhost:2181 --list
1

创建topic (副本3 分区1)

bin/kafka-topics.sh --zookeeper localhost:2181 --create --replication-factor 3 --partitions 1 --topic first
1

删除topic

bin/kafka-topics.sh --zookeeper localhost:2181 --delete --topic first
1

发送消息

bin/kafka-console-producer.sh --broker-list localhost:9092 --topic first
1

消费消息

bin/kafka-console-consumer.sh  --bootstrap-server localhost:9092 [--from-beginning] --topic first
1

查看topic详情

bin/kafka-topics.sh --zookeeper localhost:2181 --describe --topic first
1

修改分区数为6

bin/kafka-topics.sh --zookeeper localhost:2181 --alter --topic first --partitions 6
1