Kafka 安装到Mac

先决条件: 应在系统上安装版本 8 的 java。

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

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

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

步骤 3: 将下载 Kafka 'tar' 文件。移动到下载的 Kafka 目录。使用以下命令解压缩或解压缩目录: 'tar-xvf

Step4: 使用'ls'命令查看解压文件。现在，进入 要测试，请使用'/bin/kafka-topics.sh'。如果它给出正确的输出意味着 java 正在工作。使用"java-version"命令了解系统上安装的java版本。

Step5: 如果没有安装所需的java版本或者java还没有安装，那么使用brew命令: 'brew tap caskroom/versions'，然后使用'brew cask install java8'并且 java8 将开始安装。它会问: 'brew cask install java8'，按回车。

Step6: java8 将安装在系统上。使用'java-version'再次检查。

设置路径

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

Step1: 移动到 bin 文件夹 .使用以下命令打开".bash_profile"文件: "nano ~/.bash_profile"。

第 2 步: '.bash_profile' 文件将打开。到最后，设置路径为:

export PATH:"$PATH:/<forepath_directory>/<kafka_directory>/bin"
     

注意: 要知道前路径目录，请使用 'pwd' 命令。它将显示其名称。

Step3: 设置好路径后，应用'kafka-'或'kafka-topics.sh'命令查看路径是否设置成功。

使用 Brew

如果mac用户已经安装了Brew，他们可以使用它来安装Kafka。

使用 brew 安装 Apache Kafka 有以下步骤:

第一步: 使用 'brew install kafka' 并按回车键安装 Kafka。稍等片刻，系统就会安装Kafka。要进行测试，请使用任何 kafka 命令。

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

Step3: 再次使用命令'kafka-'，现在会出现没有'.sh'的文件。

Step4; 但是，要使用 kafka 命令，用户需要始终访问 kafka_directory。 所以，这是在系统上安装 Apache Kafka 的另一种方式。

启动 Zookeeper

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

步骤 1: 输入命令"zookeeper-server-start config/zookeeper.properties"并按 Enter。如果端口值=2181 没有报错，则说明zookeeper启动成功。否则，如果其他应用程序绑定到 2181，则会抛出"address in use"错误。

Step2: zookeeper 窗口不应该关闭以与 Kafka 一起工作。打开另一个窗口，并在 kafka_directory 下创建一个新目录"data"。使用命令"mkdir data"来执行此操作。

Step3: 在数据目录中，创建两个新目录: "zookeeper"和"kafka"。

步骤 4: 使用命令"nano config/zookeeper.properties"打开 kafka_directory 中的"config"目录。

Step5: 通过放置新创建的zookeeper 目录的地址来编辑'datadir' 的值。保存文件并退出。

步骤 6: 在窗口中输入"ls data/zookeeper"。列表中将出现一个新目录"version-2"。表示zookeeper启动成功。

Step7: 现在，打开"server.properties"文件以启动 Kafka 服务器。使用命令: 'nano config/server.properties' 打开文件。

步骤 8: 编辑 log.dirs 的值，将新创建的 kafka 文件夹的地址放置在前路径中。保存文件并退出。

Step9: 最后，借助以下命令启动Kafka服务器:

'kafka-server-start config/server.properties' 并按回车键。如果输出显示'kafka server started'，

Step10: 执行'ls data/kafka'，可以看到新建的文件，说明Kafka服务器安装成功。