在本教程中,我们将向您展示如何安装 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 卡夫卡网站.