《数据采集与处理技术》课件——4.5 Kafka的安装和使用.pptxVIP

第4章分布式消息系统Kafka

目录4.1Kafka简介4.2Kafka在大数据生态系统中的作用4.3Kafka与Flume的区别与联系4.4Kafka相关概念4.5Kafka的安装和使用4.6使用Python操作Kafka4.7Kafka与MySQL的组合使用

4.5Kafka的安装和使用

4.5Kafka的安装和使用4.5.1安装Kafka4.5.2使用Kafka

4.5.1安装KafkaKafka的运行需要Java环境的支持，因此，需要在Windows系统中安装JDK。请参照第2章内容完成JDK的安装。访问Kafka官网（/downloads），下载Kafka2.4.0版本的安装文件kafka_2.12-2.4.0.tgz，解压缩到“C:\”下。因为Kafka的运行需要依赖于Zookeeper，因此，需要下载并安装Zookeeper。当然，Kafka也内置了Zookeeper服务，因此，也可以不用额外安装Zookeeper，而是直接使用内置的Zookeeper服务。为了简单起见，这里直接使用Kafka内置的Zookeeper服务。

4.5.2使用Kafka在Windows系统中打开第1个cmd窗口，启动Zookeeper服务：cdc:\kafka_2.12-2.4.0.\bin\windows\zookeeper-server-start.bat.\config\zookeeper.Properties注意，执行上面命令以后，cmd窗口会返回一堆信息，然后就停住不动了，没有回到命令提示符状态，这时，不要误以为死机了，而是Zookeeper服务器已经启动，正在处于服务状态。所以，不要关闭这个cmd窗口，一旦关闭，Zookeeper服务就停止了。

4.5.2使用Kafka打开第2个cmd窗口，然后输入下面命令启动Kafka服务：cdc:\kafka_2.12-2.4.0.\bin\windows\kafka-server-start.bat.\config\perties执行上面命令以后，如果启动失败，并且出现提示信息“此时不应有\QuickTime\QTSystem\QTJava.zip”，则需要把CLASSPATH环境变量的相关信息删除，具体方法是：右键点击“我的电脑”-“高级系统设置”-“环境变量”，然后，找到CLASSPATH环境变量，把类似如下的信息删除：C:\ProgramFiles(x86)\QuickTime\QTSystem\QTJava.zip然后重新启动计算机，让配置修改生效。重新启动计算机以后，再次按照上面方法启动Zookeeper和Kafka。执行上面命令以后，如果启动成功，cmd窗口会返回一堆信息，然后就会停住不动，没有回到命令提示符状态，这时，同样不要误以为死机了，而是Kafka服务器已经启动，正在处于服务状态。所以，不要关闭这个cmd窗口，一旦关闭，Kafka服务就停止了。

4.5.2使用Kafka为了测试Kafka，这里创建一个主题（Topic），名称为“topic_test”，包含一个分区，只有一个副本，在第3个cmd窗口中执行如下命令：cdc:\kafka_2.12-2.4.0.\bin\windows\kafka-topics.bat--create--zookeeperlocalhost:2181--replication-factor1--partitions1--topictopic_test可以继续执行如下命令，查看topic_test是否创建成功：.\bin\windows\kafka-topics.bat--list--zookeeperlocalhost:2181如果创建成功，就可以在执行结果中看到topic_test。

4.5.2使用Kafka继续在第3个cmd窗口中执行如下命令创建一个生产者来产生消息：.\bin\windows\kafka-console-producer.bat--broker-listlocalhost:9092--topictopic_test该命令执行以后，屏幕上的光标会一直在闪烁，这时，就可以用键盘输入一些内容，比如输入：IloveKafkaKafkaisgood新建第4个cmd窗口，执行如下命令来消费消息：cdc:\kafka_2.12-2.4.0.\bin\windows\kafka-console-consumer.bat--bootstrap-serverlocalhost:9092--topictopic_test--from-beginning该命令执行以后，就会在屏幕上看到刚才输入的语句“Il