diff --git a/chapter3/3.2对飞机的点击次数实时统计.md b/chapter3/3.2对飞机的点击次数实时统计.md index 01cf84b..dd77f16 100644 --- a/chapter3/3.2对飞机的点击次数实时统计.md +++ b/chapter3/3.2对飞机的点击次数实时统计.md @@ -14,6 +14,68 @@ Kafka 中发布订阅的对象是 Topic。我们可以为每类数据创建一 ### 3.1.2 Kafka安装 +首先需要在你的计算机上安装 ZooKeeper 框架,请访问以下链接下载 ZooKeeper。 + +https://archive.apache.org/dist/zookeeper/ + +选择 ZooKeeper 3.4.6 版本(ZooKeeper-3.4.6.tar.gz)。 + +使用以下命令提取tar文件 +``` +$ cd opt/ +$ tar -zxf zookeeper-3.4.6.tar.gz +$ cd zookeeper-3.4.6 +$ mkdir data +``` + +使用 vi 命令打开名为 conf/zoo.cfg 的配置文件,并将所有以下参数设置为起点。 +``` +$ vi conf/zoo.cfg +tickTime=2000 +dataDir=/path/to/zookeeper/data +clientPort=2181 +initLimit=5 +syncLimit=2 +``` +一旦配置文件成功保存并再次返回终端,你可以启动 zookeeper 服务器。 + +可以使用如下命令启动 ZooKeeper 服务器: +``` +$ bin/zkServer.sh start +``` + +执行此命令后,你将得到如下所示的响应 + +``` +$ JMX enabled by default +$ Using config: /Users/../zookeeper-3.4.6/bin/../conf/zoo.cfg +$ Starting zookeeper ... STARTED +``` + + +``` +$ bin/zkCli.sh +``` +输入上面的命令后,你将被连接到zookeeper服务器,并将获得以下响应。 + +``` +Connecting to localhost:2181 +................ +................ +................ +Welcome to ZooKeeper! +................ +................ +WATCHER:: +WatchedEvent state:SyncConnected type: None path:null +[zk: localhost:2181(CONNECTED) 0] +``` +连接服务器并执行所有操作后,可以使用以下命令停止 zookeeper 服务器 - +``` +$ bin/zkServer.sh stop +``` +现在你已经在你的机器上成功安装了 Java 和 ZooKeeper 。 让我们看看安装 Apache Kafka 的步骤。 + 要在您的机器上安装Kafka, https://www.apache.org/dyn/closer.cgi?path=/kafka/0.9.0.0/kafka_2.11-0.9.0.0.tgz 把 kafka_2.11_0.9.0.0.tgz 将下载到您的计算机上。