Kafka 简介
作为一个消息中间件,Kafka 以高扩展性、高吞吐量等特点,在互联网项目中被广泛采用。
不清楚 Kafka 的同学,可以先看看这篇文章:
http://blog.csdn.net/suifeng3051/article/details/48053965
部署 Kafka
为了方便初学者能快速试用 Kafka ,本文演示了如何用 Docker 快速部署一个简单的 Kafka 服务。
下载 kafka 的 docker 镜像:
docker pull spotify/kafka
注意: kafka 依赖 zookeeper 服务,而 spotify/kafka 里面集成好了 zookeeper 与 kafka,实现了一键启动。在 docker 中启动 kafka 服务:
docker run -p 2181:2181 -p 9092:9092 –env ADVERTISED_HOST=127.0.0.1 –env ADVERTISED_PORT=9092 spotify/kafka执行 kafka 的生产端、消费端程序,查看运行效果:
下载 kafka 安装包:
http://kafka.apache.org/downloads
下载完后解压缩,进入目录中。
生产端发消息,命令行演示如下:
bin/kafka-console-producer.sh –broker-list 127.0.0.1:9092 –topic test
消息端收消息,命令行演示如下:
bin/kafka-console-consumer.sh –zookeeper 127.0.0.1:2181 –topic test –from-beginning