Kafka常用命令

Posted on

Kafka常用命令

启动命令

1
2
3
4
5
bin/kafka-server-start.sh  config/server.properties

#后台启动
bin/kafka-server-start.sh -daemon config/server.properties
bin/kafka-server-start.sh config/server.properties 1>/dev/null 2>&1 &

创建topic

1
bin/kafka-topics.sh --create --zookeeper localhost:2181 --replication-factor 2 --partitions 10 --topic testTopic

查看所有的topic

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

查看topic的详细信息

1
bin/kafka-topics.sh --zookeeper 127.0.0.1:2181 --describe --topic testTopic

为topic增加partition

1
bin/kafka-topics.sh --zookeeper 127.0.0.1:2181 --alter --partitions 20 --topic testTopic

删除topic

1
bin/kafka-topics.sh --delete --zookeeper 127.0.0.1:2181 --topic testTopic  #要配置允许删除topic，delete.topic.enable=true

kafka生产者客户端命令

1
2
bin/kafka-console-producer.sh --broker-list localhost:9092 --topic testTopic
bin/kafka-console-producer.sh --broker-list localhost:9092 --topic testTopic --producer.config config/producer.properties

kafka消费者客户端命令

1
2
bin/kafka-console-consumer.sh --zookeeper localhost:2181 --from-beginning --topic testTopic
bin/kafka-console-consumer.sh --zookeeper localhost:2181 --from-beginning --topic testTopic --consumer.config config/consumer.properties

新消费者列表查询（支持0.9版本+）

1
bin/kafka-consumer-groups.sh --new-consumer --bootstrap-server localhost:9092 --list

显示某个消费组的消费详情（支持0.9版本+）

1
bin/kafka-consumer-groups.sh --new-consumer --bootstrap-server localhost:9092 --describe --group testGroup001