kafka常用命令

Kafka

查看kafka集群的所有topic

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

创建名称为topic_test的topic，partitions为1个，副本为1个

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

为topic_test添加partition为10

./bin/kafka-topics.sh --zookeeper localhost:2181 --alter --topic topic_test --partitions 10

删除名称为topic_test的topic(只删除zookeeper内的元数据，消息文件须手动删除)

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

查看topic为topic_test的详细信息

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

查看group为group_test消费的机器以及partition

./bin/kafka-consumer-groups.sh --describe --group group_test --bootstrap-server localhost:9092

控制台向topic_test发送数据

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

控制台接收topic_test数据

./bin/kafka-console-consumer.sh --bootstrap-server localhost:9092 --topic topic_test --from-beginning

启动zookeeper服务

./bin/zookeeper-server-start.sh -daemon ./config/zookeeper.properties

启动kafka服务

./bin/zookeeper-server-start.sh -daemon ../config/zookeeper.properties

查看服务启动

ps -ef | grep kafka

参考

https://kafka.apache.org