|
|
|
|
@ -14,68 +14,6 @@ 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 将下载到您的计算机上。
|
|
|
|
|
|
