Centos安装zookeeper、kafka

一、zookeeeper

二、kafaka

安装测试

一、创建test消息队列：

kafka-topics.sh --create --bootstrap-server localhost:9092 --replication-factor 1 --partitions 1 --topic test

二、查看创建的消息队列

kafka-topics.sh --list --bootstrap-server localhost:9092

三、创建生产者-消费者队列

创建生产者：

kafka-console-producer.sh --broker-list localhost:9092 --topic test

创建消费者<在新窗口打开>:

kafka-console-consumer.sh --bootstrap-server localhost:9092 --topic test --from-beginning