如何安装 Apache Debian 9 上的卡夫卡

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