kafka常用指令

开启集群：

bin/kafka-server-start.sh config/server.properties &

关闭集群：

bin/kafka-server-stop.sh stop

查看当前服务器中所有的topic：

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

创建topic：

bin/kafka-topics.sh --zookeeper hadoop101:2181 \ --create --replication-factor 3 --partitions 1 --topic first 说明： –topic 定义topic名–replication 定义副本数–partitions 定义分区数

删除topic：

bin/kafka-topics.sh --zookeeper hadoop101:2181 \ --delete --topic first

发送消息：

[kgg@hadoop101 kafka]$ bin/kafka-console-producer.sh \ --broker-list hadoop101:9092 --topic first >hello world >kgg kgg

消费消息：

bin/kafka-console-consumer.sh \ --zookeeper hadoop101:2181 --from-beginning --topic first

查看某个topic的详情：

bin/kafka-topics.sh --zookeeper hadoop101:2181 \ --describe --topic first