(一)、zookeeper下载

(二)、kafaka下载

(三)、启动zookeeper

./zkServer.sh start

(四)、启动kafka

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

(五)、创建主题

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

• replication-factor 服务个数,集群数
• partition 分区数
• list 查看主题

(六)、测试生产者

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

• broker-list 消息代理服务器,ip端口在server.properties中

(七)、测试消费者

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

• bootstrap-server 引导消息服务器,ip端口在server.properties中
• from-beginning 获取所有消息,不设置则只接受当前的