diff --git a/chapter3/3.2对飞机的点击次数实时统计.md b/chapter3/3.2对飞机的点击次数实时统计.md index 771cad6..97ce93b 100644 --- a/chapter3/3.2对飞机的点击次数实时统计.md +++ b/chapter3/3.2对飞机的点击次数实时统计.md @@ -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