Kafka入门系列—1. 安装、配置和运行

一. 下载安装

• 官网下载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中获取消息。

1. 创建topic

   创建名称为topicExample的topic。

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

2. 使用命令行工具启动生产者

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

3. 启动消费者

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

生产者和消费者都需要通过参数--topic topicExample来指定topic。

4. 在生产者命令行窗口中输入一些信息，然后在消费者窗口中查看。

生产者

消费者