Apache Kafka 的安装

Apache Kafka 支持 Windows、macOS 以及 Linux 环境。每个操作系统都有其自己安装 Apache Kafka 的步骤/过程。

到达此阶段意味着所有有志者可能都清楚 Apache Kafka 的基本概念。 在本节中，我们将讨论 Windows 上的安装过程，设置路径以及启动 zookeeper 和 Kafka 服务器。

在 Windows 上安装 Apache Kafka

步骤 1: 要安装 Apache Kafka，java8 JDK 工具包应安装在系统上。 如果已经安装，但不是java8，则用户需要重新安装 Java。 因为当前的 Kafka 版本仅支持 java8。 使用 'java -version' 在 Windows 命令提示符下检查版本。

如果需要安装 java8，请使用以下链接: https://www.oracle.com/technetwork/java/javase/downloads/jdk8-downloads-2133151.html

步骤 2: 现在，在系统上下载 Apache Kafka，如下所示: 使用链接: https://kafka.apache.org/downloads

步骤 3: 点击链接并从二进制文件下载中下载任何二进制文件，如下所示

在本教程中，选择 Scala 2.12 或可以相应地选择。

步骤 4: 将打开一个新窗口。 现在，选择用于 Kafka 的 MIrrorMaker。 点击第一个链接并下载相应的 '.tgz' 文件，如下所示

保存文件。

步骤 5: 转到相应的下载位置，并使用 WinRAR 提取下载的文件。

提取文件后，它将转换为一个文件夹，如

步骤 6: 将 Kafka 文件夹复制到根目录（本地磁盘 C）。

步骤 7: 打开命令提示符，使用 'cd..' 命令移动到 C:\ 驱动器。 现在，借助以下命令移动到 Kafka 目录

cd <kafka 文件夹名称>。 按 Enter。 输入后，它将看起来像

步骤 8: 检查 java 版本。 如果正确安装，则在应用 'java -version' 命令后将显示以下输出。 否则，将显示错误。

步骤 9: 成功安装 java8 之后，请尝试 Kafka 文件夹中的一些 Kafka 命令，如: 'bin\windows\kafka-topics.bat'。 如下所示

使用 'kafka-' 命令查看所有 Kafka 命令。

注意: 如果正确遵循了上述所有步骤，则 Windows Defender 防火墙框可能会显示安全警报。 点击允许访问。

设置 Kafka 目录路径

到目前为止，我们了解了如何在 Kafka 目录中使用 kafka 命令。 但是，如果我们希望从任何地方使用命令，则需要设置 Kafka 的路径。

步骤 1: 打开 Kafka 文件夹>bin>windows 并复制其地址。

步骤 2: 转到我的电脑，然后右键单击。 将打开一个对话框。 点击属性>高级系统设置>环境变量。

步骤 3: 通过粘贴复制的地址来编辑路径变量。 点击确定。

步骤 4: 再次打开命令提示符，从任何驱动器应用命令 'kafka-topics.bat'。 下面的快照中显示了一个示例

如果路径设置成功，它将显示以上输出。 现在，kafka 命令可以从任何地方执行。

安装 Zookeeper

如果没有安装 zookeeper，Apache Kafka 将无法运行。 因此，要使用 Kafka，用户需要在系统上启动 zookeeper。

以下是启动 zookeeper 的步骤

步骤 1: 转到 Kafka 目录并创建一个新文件夹作为 'data'。

步骤 2: 打开新创建的数据文件夹，并在其下创建另外两个文件夹。 将文件夹命名为 'zookeeper' 和 'kafka'。

步骤 3: 现在，复制 zookeeper 文件夹的地址。 复制后，返回到 Kafka 目录。

步骤 4: 移动到 Kafka 目录下的 config 文件夹。

打开 config 文件夹，然后转到 zookeeper.properties 文件。 右键单击该文件，然后点击“使用 Notepad++ 编辑”，如下所示

注意: 使用 Notepad++ 可以获得最佳的视图和轻松编辑文件。

步骤 5: 通过粘贴 zookeeper 文件夹地址来编辑 'datadir' 的值。 保存。 此地址将用于客户端连接。

步骤 6: Zookeeper 服务器已准备好启动。 打开命令提示符并转到 Kafka 目录。 然后，键入命令: 'zookeeper-server-start.bat config\zookeeper.properties'。 按 Enter。

如果显示以下所示的输出，则表示 zookeeper 服务器已成功启动。 在输出屏幕中，显示端口号 2181，这说明 zookeeper 服务器已成功启动。

否则，端口号 2181 与其他一些应用程序绑定。

步骤 7: 打开 data>zookeeper。 将自动创建一个新文件夹 'version-2'。 如果不是这样，则出现问题。

步骤 8: 启动 zookeeper 服务器后，转到 kafka 目录>data>kafka。 复制 kafka 文件夹的地址。

步骤 9: 返回到 Kafka 目录>config>server.properties。

右键单击并点击“使用 Notepad++ 编辑”。 将打开以下所示的文件。

步骤 10: 再次，将 kafka 文件夹的复制地址粘贴为 log.dirs 的值。

步骤 11: 打开命令提示符并移动到 Kafka 目录。 键入命令: 'kafka-server-start.bat config\server.properties'。 查看下面的快照

将显示输出屏幕，如下面的快照所示

如果显示突出显示的输出，则表示 kafka 服务器已成功启动。

步骤 12: 打开 Kafka 目录>data>kafka。 在这里，用户将找到一些文件，这些文件将在 Kafka 服务器成功启动时生成。

因此，以这种方式，可以在 Windows 操作系统上安装 Kafka 服务器。

注意: 必须首先启动 zookeeper 服务器才能运行 kafka 命令。