一. 下载安装
官网下载Kafka 1.0.0版本，Kafka是依赖于ZooKeeper来管理各种数据与元数据，因此也需要下载ZooKeeper。
-
解压ZooKeeper后，进入
config目录，并将zoo_sample.cfg重命名为zoo.cfg。它是ZooKeeper默认寻找的配置文件名。修改zoo.cfg文件，dataDir表示ZooKeeper数据存放的目录，这里使用上层目录新建的data文件夹。同时，可以看出ZooKeeper默认的端口号是2181。dataDir=../data
zoo.cfg
二. 运行
-
首先运行ZooKeeper，进入
bin目录，执行./zkServer.sh start-foreground
表示以前台的方式启动，关闭命令行窗口后，ZooKeeper也会停止。
-
然后启动Kafka，进入
bin目录，执行./kafka-server-start.sh config/server.properties
三. 实例：生产者—Kafka—消费者
这个小例子使用Kafka自带的命令行工具来实现生产者将消息发送到Kafka中，同时消费者从Kafka中获取消息。
-
创建topic
创建名称为
topicExample的topic。./kafka-topics.sh --create --zookeeper localhost:2181 --replication-factor 1 --partitions 1 --topic topicExample -
使用命令行工具启动生产者
./kafka-console-producer.sh --broker-list localhost:9092 --topic topicExample -
启动消费者
./kafka-console-consumer.sh --bootstrap-server localhost:9092 --topic topicExample --from-beginning
生产者和消费者都需要通过参数--topic topicExample来指定topic。
- 在生产者命令行窗口中输入一些信息，然后在消费者窗口中查看。
生产者
消费者
