如何安装 Apache Ubuntu 16.04 LTS 上的 Kafka

在本教程中,我们将向您展示如何安装 Apache Ubuntu 16.04 LTS 上的 Kafka。 对于那些不知道的人, Apache Kafka 是一种分布式消息代理,旨在有效处理大量实时信息。 与 ActiveMQ 和 RabbitMQ 等传统代理不同,Kafka 充当一组一个或多个服务器,这使其具有高度可扩展性,并且由于其分布式特性,它具有内置的容错性,同时与同类产品相比提供更大的吞吐量。

本文假设您至少具备 Linux 的基本知识,知道如何使用 shell,最重要的是,您将网站托管在自己的 VPS 上。 安装非常简单,假设您在 root 帐户下运行,如果不是,您可能需要添加 ‘sudo‘ 到命令以获取 root 权限。 我将向您展示逐步安装 Apache Ubuntu 16.04 Xenial Xerus 服务器上的 Kafka。

安装 Apache Ubuntu 16.04 LTS 上的 Kafka

步骤 1. 首先,通过运行以下命令确保所有系统包都是最新的 apt-get 终端中的命令。

sudo apt-get update sudo apt-get upgrade

步骤 2. 安装 Java。

Kafka 是用 Java 编写的,您需要在系统上安装 Java:

add-apt-repository -y ppa:webupd8team/java

完成后,运行以下命令安装 Java:

apt-get update apt-get install oracle-java8-installer

步骤 3. 安装 Zookeeper。

Apache Kafka 依赖 Zookeeper 进行集群管理。 因此,在启动 Kafka 之前,必须启动 Zookeeper:

apt-get install zookeeperd

安装完成后,ZooKeeper 会自动作为守护进程启动。 默认情况下,它将侦听端口 2181:

netstat -ant | grep :2181

步骤 4. 安装 Kafka 服务器。

首先,从 Apache 网站。 您可以使用 wget 下载卡夫卡:

mkdir /opt/Kafka cd /opt/Kafka wget https://ftp.jaist.ac.jp/pub/apache/kafka/0.10.0.0/kafka_2.11-0.10.0.0.tgz

使用 tar 命令解压下载的存档 /opt/Kafka

tar -xvf kafka_2.11-0.10.0.0.tgz -C /opt/Kafka/

配置卡夫卡服务器:

sudo /opt/Kafka/kafka_2.11-0.10.0.0/bin/kafka-server-start.sh /opt/Kafka/kafka_2.11-0.10.0.0/config/server.properties

您可以使用 nohup 使用脚本将 Kafka 服务器作为后台进程启动:

sudo nohup /opt/Kafka/kafka_2.11-0.10.0.0/bin/kafka-server-start.sh /opt/Kafka/kafka_2.11-0.10.0.0/config/server.properties /tmp/kafka.log 2>&1 &

现在,是时候验证 Kafka 服务器是否正常运行了:

sudo /opt/Kafka/kafka_2.11-0.10.0.0/bin/kafka-topics.sh --create --zookeeper localhost:2181 --replication-factor 1 --partitions 1 --topic testing

您应该看到以下输出:

Created topic "testing".

现在,请 Zookeeper 列出可用的主题 Apache 卡夫卡:

sudo /opt/Kafka/kafka_2.11-0.10.0.0/bin/kafka-topics.sh --list --zookeeper localhost:2181

您应该看到以下输出:

testing

接下来,将示例消息发布到 Apache 使用以下生产者命令调用测试的 Kafka 主题:

sudo /opt/Kafka/kafka_2.11-0.10.0.0/bin/kafka-console-producer.sh --broker-list localhost:9092 --topic testing

最后,使用消费者命令检查消息 Apache Kafka 主题通过运行以下命令调用测试:

sudo /opt/Kafka/kafka_2.11-0.10.0.0/bin/kafka-console-consumer.sh --zookeeper localhost:2181 --topic testing --from-beginning

您应该看到以下输出:

Hi how are you? Where are you?

嗯,你已经成功验证你有一个有效的 Apache 卡夫卡设置 Apache 动物园管理员。

恭喜! 您已成功安装 Apache 卡夫卡。 感谢您使用本教程进行安装 Apache Ubuntu 16.04 系统上的 Kafka。 如需其他帮助或有用信息,我们建议您查看 官方 Apache 卡夫卡网站.

Save