官方文档指南
https://kafka.apache.org/documentation/#operations
//创建topic
bin/kafka-topics.sh --bootstrap-server localhost:9092 --create --topic heima --partitions 2 --replication-factor 1
//生产消息
bin/kafka-console-producer.sh --broker-list localhost:9092 --topic test111111
//消费消息
bin/kafka-console-consumer.sh --bootstrap-server localhost:9092 --from-beginning --topic test111111
网友评论