木子李-博客

https://blog.csdn.net/LXDOS/article/details/113737789

https://blog.csdn.net/LXDOS/article/details/113737789

启动 zookeeper: ./bin/zkServer.sh

启动 客户端: ./bin/zkCli.sh

启动kafka :  ./bin/kafka-server-start.sh config/server.properties

创建主题： bin/kafka-topics.sh --bootstrap-server localhost:9092 --create --topic heima --partitions 2 --replication-factor 1

查看所有的主题： bin/kafka-topics.sh --list --bootstrap-server localhost:9092

创建producer:  ./bin/kafka-console-producer.sh --broker-list localhost:9092 --topic test1

消费者：  ./bin/kafka-console-consumer.sh --bootstrap-server localhost:9092 --topic test1 --from-beginning