|
|
|
@ -87,7 +87,7 @@ $ bin/zkServer.sh stop
|
|
|
|
|
现在你已经在你的机器上成功安装了 ZooKeeper 。 让我们看看安装 Apache Kafka 的步骤。
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
要在您的机器上安装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 将下载到您的计算机上。
|
|
|
|
|
|
|
|
|
|
使用以下命令提取tar文件
|
|
|
|
@ -95,7 +95,7 @@ https://www.apache.org/dyn/closer.cgi?path=/kafka/0.9.0.0/kafka_2.11-0.9.0.0.tgz
|
|
|
|
|
$ tar -zxf kafka_2.11.0.9.0.0 tar.gz
|
|
|
|
|
$ cd kafka_2.11.0.9.0.0
|
|
|
|
|
```
|
|
|
|
|
现在您已经在你的机器上下载了最新版本的 Kafka。
|
|
|
|
|
现在你已经在你的机器上下载了最新版本的 Kafka。
|
|
|
|
|
|
|
|
|
|
你可以通过给出以下命令来启动服务器
|
|
|
|
|
```
|
|
|
|
@ -105,7 +105,7 @@ $ bin/kafka-server-start.sh config/server.properties &
|
|
|
|
|
```
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
服务器启动后,您会在屏幕上看到以下响应:
|
|
|
|
|
服务器启动后,你会在屏幕上看到以下响应:
|
|
|
|
|
|
|
|
|
|
```
|
|
|
|
|
$ bin/kafka-server-start.sh config/server.properties
|
|
|
|
@ -312,7 +312,8 @@ if __name__ == '__main__':
|
|
|
|
|
[Stage 226:====================================================>(197 + 2) / 200]
|
|
|
|
|
```
|
|
|
|
|
|
|
|
|
|
因为结果存储到 Kafka , 控制台上没有明显结果输出,接下来我们可以订阅 Kafka Topic 为 `topic1` 的消息来获取数据。
|
|
|
|
|
因为结果存储到 Kafka , 控制台上没有明显结果输出,接下来我们可以订阅 Kafka Topic 为 `jun` 的消息来获取数据。
|
|
|
|
|
|
|
|
|
|
```
|
|
|
|
|
from kafka import KafkaConsumer
|
|
|
|
|
|
|
|
|
|