一、下载KAFKA安装包
Apache官网 http://kafka.apache.org/downloads.html
二、上传并且解压KAFKA安装包
tar -xzf kafka_2.10-0.8.2.2.tgz
cd kafka_2.10-0.8.2.2
三、启动服务
KAFKA需要启动两个服务:
1,启动zookeeper:bin/zookeeper-server-start.sh config/zookeeper.properties & (&能在执行指令时退出操作)
2,启动kafka:bin/kafka-server-start.sh config/server.properties &
四、测试
1,创建topic
bin/kafka-topics.sh --create --zookeeper 10.202.4.179:2181 --replication-factor 1 --partitions 1 --topic test
创建一个名为test的topic,只有一个副本,一个分区。
2,创建生产者,启动producer
bin/kafka-console-producer.sh --broker-list localhost:9092 --topic test
topic要对应之前创建的topic
之后便可以发送消息
3,创建消费者,启动consumer
bin/kafka-console-consumer.sh --zookeeper 10.202.4.179:2181 --topic test --from-beginning
topic要对应之前创建的topic
在生产者发送消息后,消费者便可以收到对应的消息了