---

安装
A. JDK设置
1.双击JRE安装程序后，可以单击“安装”继续，也可以单击“更改目标文件夹”复选框。
2. JDK的默认安装路径为：C: \ Program Files \ Java \ jre1.8.0_xx。但是，您也可以将其修改为目标目录，例如C: \ Java \ jre1.8.0_xx，然后单击“下一步”。
3.现在，您可以通过单击：控制面板 - >来执行此操作
系统 - >
高级系统设置 - >
一个环境变量，用于设置与变量关联的系统运行时环境。
4.如下图所示，在“用户变量”部分，您可以单击“新建用户变量”，然后在弹出的对话框中输入“JAVA_HOME”作为“变量名称”，并在“变量”中输入价值“jre的道路。
（注意：Java的具体路径和版本可能会有所不同，具体取决于您使用的Kafka版本）
5.现在直接点击“确定”。
6.在“系统变量”部分中，找到并打开“环境变量”对话框。
7.现在编辑“路径”。如下图所示，在“变量值”的现有文本的末尾，键入“；％JAVA_HOME％\ bin”。
8.要确认已安装Java，可以打开“cmd”并键入“java -version”。此时，您应该能够看到刚刚安装的Java版本。
如果您的命令提示符显示类似于上面的命令提示符，那么一切都准备就绪。否则，您需要重新检查您的设置以匹配当前的操作系统体系结构（例如x86或x64），或者环境变量路径是否正确。B. ZooKeeper的安装
1.让我们把注意力转向ZooKeeper的配置目录。在这里，我使用：“C: \ zookeeper-3.4.7 \ conf”。
2.我将文件“zoo_samplep.cfg”重命名为“zoo.cfg”。
3.使用文本编辑器（如记事本）打开zoo.cfg，这里我使用的是Notepad ++。
4.找到“dataDir=/tmp/zookeeper”字段并修改“C: \ zookeeper-3.4.7 \ data”。
5.如上面的Java设置中所述，我们在系统环境变量中添加了另一个条目。
一个。将“ZOOKEEPER_HOME=C: \ zookeeper-3.4.7”添加到系统变量（系统变量）。
湾编辑名为“Path”的系统变量并添加“；％ZOOKEEPER_HOME％\ bin”。
6.您可以将zoo.cfg文件的默认ZooKeeper端口更改为其他端口。默认端口为2181。
7.打开一个新cmd并键入zkserver以运行ZooKeeper。
8.您将能够看到包含以下详细信息的命令提示符。
您的ZooKeeper现在已在端口2181上启动并运行。
C.建立卡夫卡
1.现在转到Kafka配置目录。这是C: \ kafka_2.11-0.9.0.0 \ config。
2.请编辑文件：“server.properties”。
3.找到并找到“log.dirs=/tmp/kafka-logs”行并将其更改为：“log.dir=C: \ kafka_2.11-0.9.0.0 \ kafka-logs”。
4.如果ZooKeeper需要在另一台计算机或群集上运行，请将“zookeeper.connect: 2181”更改为目标IP地址和端口号。这里我们使用相同的机器，因此无需进行任何更改。此外，还可以正确配置Kafka的端口号和broker.id。请保持其他设置不变。
5.在此示例中，我们的Kafka将在默认端口9092上运行，并将连接到ZooKeeper的默认端口2181。
D.运行Kafka服务器要点：在启动Kafka服务器之前，请确保您的ZooKeeper实例已启动并正在运行。
1.请转到Kafka安装目录，此处：C: \ kafka_2.11-0.9.0.0 \。
2.按住shift并右键单击打开命令提示符，然后选择“在此处打开命令窗口”选项。
3.如下所示，键入“。\ bin \ windows \ kafka-server-start.bat。\ config \ server.properties bat”，然后按Enter键。
4.如果一切正常，您的命令提示符将显示以下消息：
5.此时，您的Kafka服务器已启动并正在运行，您可以继续创建用于存储消息的各种主题。此外，您可以使用Java，Scala代码或直接在命令提示符下生成或使用数据。
E.创建主题
1.由于只有一个Kafka服务器正在运行，我们只需创建一个名为“test”的主题，复制因子为1.当然，如果您有一个运行多个Kafka服务器的集群，您可以相应地增加复制因子以增加数据可用性并充当容错系统。
2.在C: \ kafka_2.11-0.9.0.0 \ bin \ windows下打开一个新的命令提示符。
3.如下所示，键入命令：“kafka-topics.bat --create --zookeeper localhost: 2181 --rerelication-factor 1 --partitions 1 --topic test”，然后按Enter键。
F.为测试服务器创建Producer和Consumer
1.请在C: \ kafka_2.11-0.9.0.0 \ bin \ windows打开一个新的命令提示符。
2.键入命令：“kafka-console-producer.bat --broker-list localhost: 9092 --topic test”以启动生产者。
3.同时在C: \ kafka_2.11-0.9.0.0 \ bin \ windows打开另一个新的命令提示符。4.键入命令：“kafka-console-consumer.bat --zookeeper localhost: 2181 --topic test”以启动使用者。
5.以上两个命令提示的屏幕截图如下所示:
6.现在，您可以在生产者的命令提示符下键入任何内容，然后按Enter键；那么你应该能够在另一个命令提示符中看到相同的消息内容。
7.可以看出，如果您可以在消费者端看到推送消息，那么您已完成Kafka设置。
一些其他有用的命令
1.列表主题：kafka-topics.bat --list --zookeeper localhost: 2181
2.描述主题：kafka-topics.bat --describe --zookeeper localhost: 2181 --topic [主题名称]
3.从头开始阅读所有类型的新闻：kafka-console-consumer.bat --zookeeper localhost: 2181 --topic [主题名称]  - 从头开始
4.删除主题：kafka-run-class.bat kafka.admin.TopicCommand --delete --topic [topic_to_delete] --zookeeper localhost: 2181

• 上一篇: 蓝盟IT外包，元宇宙：四梁八柱是什么
  下一篇: 解读网络安全的新趋势

• 分享到：