在本教程中,我们将向您展示如何安装 Apache Debian 9 上的 Kafka。对于那些不知道的人, Apache Kafka 是一种分布式消息代理,旨在有效处理大量实时信息。 与 ActiveMQ 和 RabbitMQ 等传统代理不同,Kafka 充当一组一个或多个服务器,这使其具有高度可扩展性,并且由于其分布式特性,它具有内置的容错性,同时与同类产品相比提供更大的吞吐量。
本文假设您至少具备 Linux 的基本知识,知道如何使用 shell,最重要的是,您将网站托管在自己的 VPS 上。 安装非常简单,假设您在 root 帐户下运行,如果不是,您可能需要添加 ‘sudo
‘ 到命令以获取 root 权限。 我将向您展示逐步安装 Apache Debian 9 (Stretch) 服务器上的 Kafka。
安装 Apache Debian 9 Stretch 上的 Kafka
第 1 步。在我们安装任何软件之前,重要的是通过运行以下命令确保您的系统是最新的 apt-get
终端中的命令:
apt-get update apt-get upgrade
步骤 2. 安装 Java。
Kafka 是用 Java 编写的,您需要在系统上安装 Java:
apt-get install default-jdk
步骤 4. 安装 Kafka 服务器。
首先,从 Apache 网站。 您可以使用 wget
下载卡夫卡:
wget https://www-us.apache.org/dist/kafka/1.0.1/kafka_2.12-1.0.1.tgz
使用提取下载的存档 tar
/opt/Kafka 中的命令:
tar xzf kafka_2.12-1.0.1.tgz mv kafka_2.12-1.0.1 /usr/local/kafka
Kafka 使用 ZooKeeper,因此首先,在您的系统上启动 ZooKeeper 服务器:
cd /usr/local/kafka bin/zookeeper-server-start.sh config/zookeeper.properties
让我们创建一个名为“NewTopic”的主题,它只有一个分区和一个副本:
bin/kafka-topics.sh --create --zookeeper localhost:2181 --replication-factor 1 --partitions 1 --topic NewTopic Created topic "NewTopic".
现在您可以通过运行 list topic 命令在 Kafka 上查看创建的主题:
bin/kafka-topics.sh --list --zookeeper localhost:2181 NewTopic
Kafka 还有一个命令行消费者,用于从 Kafka 集群读取数据并将消息显示到标准输出:
bin/kafka-console-consumer.sh --bootstrap-server localhost:9092 --topic NewTopic --from-beginning Welcome to kafka This is my New topic
恭喜! 您已成功安装 Apache 卡夫卡。 感谢您使用本教程在 Debian 9 Stretch 系统上安装 Install Kotlin Compiler。 如需更多帮助或有用信息,我们建议您查看 官方 Apache 卡夫卡网站.