在 macOS 上安装 Apache Kafka

2024 年 8 月 29 日 | 阅读 3 分钟

先决条件: 系统上应安装 Java 8 版本。

要下载最新版本的 Apache Kafka(或根据需要),将使用以下步骤

步骤 1: 打开 Apache 基金会的官方网站或使用链接:https://kafka.apache.org/downloads。 从二进制下载中选择并下载 Kafka 二进制文件。 选择 Scala 2.11 或 Scala 2.12。

步骤 2: 单击所选的二进制文件后,将打开一个新页面。 单击第一个链接,这将是 Kafka 下载的镜像大小。 下载将开始。

步骤 3: 将下载一个 Kafka“tar”文件。 移至下载的 Kafka 目录。 使用命令解压或解压缩目录:'tar -xvf'.

步骤 4: 使用“ls”命令查看解压后的文件。 现在,进入.

要测试,请使用'/bin/kafka-topics.sh'。 如果它给出正确的输出,则表示 java 正在运行。 使用“java -version”命令了解系统上安装的 java 版本。

步骤 5: 如果未安装所需的 java 版本或尚未安装 java,请使用 brew 命令:'brew tap caskroom/versions',然后使用'brew cask install java8',java8 将开始安装。 它会询问:'brew cask install java8',按 Enter 键。

步骤 6: 将在系统上安装 java8。 再次使用“java-version”进行检查。

设置路径

要从任何地方运行 Kafka,请使用以下步骤设置路径

步骤 1: 进入。 使用命令打开“.bash_profile”文件:'nano ~/.bash_profile'。

步骤 2: 将打开“.bash_profile”文件。 转到末尾并设置路径

注意: 要了解正向路径目录,请使用“pwd”命令。 它将显示其名称。

步骤 3: 设置路径后,应用“kafka-”或“kafka-topics.sh”命令以了解是否成功设置了路径。

使用 Brew

如果 mac 用户已安装 Brew,则可以使用它来安装 Kafka。

以下是使用 brew 安装 Apache Kafka 的步骤

步骤 1: 使用“brew install kafka”并按 Enter 键安装 Kafka。 等一会儿,Kafka 将安装在系统上。 要测试,请使用任何 kafka 命令。

步骤 2: 如果使用了“kafka-”命令,它将显示带有和不带“.sh”扩展文件的文件。 这是因为 bin 路径已在“.bash_profile”文件中设置。 因此,再次编辑该文件并从末尾删除该行。 保存并退出。

步骤 3: 再次使用命令“kafka-”,现在将出现不带“.sh”的文件。

步骤 4: 但是,要使用 kafka 命令,用户需要始终访问 kafka_directory。

因此,这是在系统上安装 Apache Kafka 的另一种方法。

启动 Zookeeper

由于 Apache Kafka 无法在没有 zookeeper 的情况下工作,因此必须在系统上运行 zookeeper 服务器。 按照以下步骤安装 zookeeper 服务器

步骤 1: 键入命令“zookeeper-server-start config/zookeeper.properties”并按 Enter 键。 如果端口值 = 2181 未发生任何错误,则表示 zookeeper 已成功启动。 否则,如果其他应用程序绑定到 2181,将抛出“地址在使用中”错误。

步骤 2: 不应关闭 zookeeper 窗口以使用 Kafka。 打开另一个窗口,并在 kafka_directory 下创建一个新目录“data”。 使用命令“mkdir data”执行此操作。

步骤 3: 在数据目录中,创建两个新目录:“zookeeper”和“kafka”。

步骤 4: 使用命令“nano config/zookeeper.properties”打开放置在 kafka_directory 中的“config”目录。

步骤 5: 通过放置新创建的 zookeeper 目录的地址来编辑“datadir”的值。 保存文件并退出。

步骤 6: 在窗口中键入“ls data/zookeeper”。 列表中将出现一个新目录“version-2”。 这意味着 zookeeper 已成功启动。

步骤 7: 现在,打开“server.properties”文件以启动 Kafka 服务器。 使用命令:'nano config/server.properties' 打开文件。

步骤 8: 通过放置来自正向路径的新创建的 kafka 文件夹的地址来编辑 log.dirs 的值。 保存文件并退出。

步骤 9: 最后,借助以下命令启动 Kafka 服务器

'kafka-server-start config/server.properties' 并按 Enter 键。 如果输出显示“kafka server started”,

步骤 10: 执行“ls data/kafka”,将看到新创建的文件,这表明 Kafka 服务器已成功安装在系统上。


下一个主题创建 Kafka 主题