在本教程中，我们将讨论如何安装 Apache Ubuntu 上的卡夫卡。
什么是 Apache 卡夫卡？
Apache Kafka是LinkedIn开发的开源流处理软件平台，捐赠给 Apache 软件基础，用 Scala 和 Java 编写。 简单来说，Kafka 是一个旨在快速、可扩展和持久的消息传递系统。
为什么它被称为流媒体平台？
它被称为流媒体平台，因为它具有以下特点：
- 发布和订阅记录流
- 以容错方式存储记录流
- 在记录流出现时对其进行处理。
Kafka 充当生产者和消费者之间的消息代理。 它从生产者和消费者发送和接收数据。 它是在计算机集群上运行的分布式系统。
安装步骤 Apache Ubuntu 上的卡夫卡
现在我们将介绍在 Ubuntu 上安装 apache Kafka 并启动和运行所需的步骤。 由于 Kakfa 在 Java 上运行，因此您必须在系统上安装 Java。 如果你不知道怎么做，这里有一个关于如何在 Ubuntu 上安装 java 的教程，你可以遵循。
步骤 1. 下载并解压 Kafka 文件
基本要求是Kafka的tar文件。 您也可以从此链接下载它： Apache 卡夫卡下载链接。
您可以使用 wget 下载文件或 curl 如下所示：
wget -c https://www.apache.org/dyn/closer.cgi?path=/kafka/2.4.0/kafka_2.11-2.4.0.tgz
要提取 Kafka tar 文件，请使用以下命令：
$ tar –xvzf kafka_2.12-1.1.0.tgz
提取文件后， cd 进入该目录。
$ cd kafka_2.12-1.1.0.
步骤 2. 启动服务器
让我们首先了解 Zookeeper。 它是 Kafka 用来管理其集群状态和配置的一项服务。 简单来说，Zookeeper 就像是社会中的一名守卫，知道每个业主的地址。 生产者在不知道消费者身份的情况下发送消息。 Zookeeper 将消息定向到特定的消费者。
启动zookeeper，语法如下：
$ bin/zookeeper-server-start.sh config/zookeeper.properties
步骤 3. 启动 Kafka 服务器
下一步是启动 Kafka 服务器，可以通过以下命令完成。
$ bin/kafka-server-start.sh config/server.properties
Step 4. 如何创建话题？
Kafka 充当生产者和消费者之间的消息代理。 它在生产者和消费者之间发送和接收数据，如下图所示。
在下图中，生产者将消息发送到代理。 Broker 创建主题，为其分配一个分区号并将其发送给消费者。
Producer 向 Broker 发送消息
卡夫卡制作人创建主题的语法如下：
$ bin/kafka-topics.sh --create --zookeeper localhost:2181 --replication-factor 1 --partitions 1 --topic test1
步骤 5. 检查主题列表
创建主题后，如果要检查主题列表，我们使用以下命令：
$ bin/kafka-topics.sh --list --zookeeper localhost:2181
以下命令显示创建的主题列表。
步骤 6. 在生产者和消费者之间创建连接
生产者通过 Kafka 服务器向消费者发送消息。 因此，在生产者和消费者之间建立联系很重要。
建立连接后，您将看到消息打印在生产者和消费者双方。
$ bin/kafka-console-producer.sh --broker-list localhost:9092 --topic test
不要忘记启动消费者。 启动消费者的语法如下：
$ bin/kafka-console-consumer.sh –bootstrap-server localhost:9092 –topic test –from -beginning
步骤 7. 生产者-消费者连接
建立生产者和消费者的连接后，我们可以发送消息，消费者端会收到。 我们来看一下。
在生产者网站
在消费者现场
在这里，您可以看到双方的消息，即生产者和消费者。
结论
在本教程中，我们已经介绍了如何安装 Apache ubuntu 中的卡夫卡。 我们希望您现在知道如何有效地使用该命令。 如果您有任何疑问，请在评论中告诉我们。
