在本教程中,我们将讨论如何安装 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 创建主题,为其分配一个分区号并将其发送给消费者。
![咖啡机](https://adatiya.com/images/uploads/sites/7/1641769054.png)
![卡夫卡制作人](https://adatiya.com/images/uploads/sites/7/1641769056.png)
创建主题的语法如下:
$ bin/kafka-topics.sh --create --zookeeper localhost:2181 --replication-factor 1 --partitions 1 --topic test1
![卡夫卡主题1](https://adatiya.com/images/uploads/sites/7/1641769059.png)
步骤 5. 检查主题列表
创建主题后,如果要检查主题列表,我们使用以下命令:
$ bin/kafka-topics.sh --list --zookeeper localhost:2181
![卡夫卡列表](https://adatiya.com/images/uploads/sites/7/1641769061.png)
以下命令显示创建的主题列表。
步骤 6. 在生产者和消费者之间创建连接
生产者通过 Kafka 服务器向消费者发送消息。 因此,在生产者和消费者之间建立联系很重要。
建立连接后,您将看到消息打印在生产者和消费者双方。
$ bin/kafka-console-producer.sh --broker-list localhost:9092 --topic test
![卡夫卡康 1](https://adatiya.com/images/uploads/sites/7/1641769063.png)
不要忘记启动消费者。 启动消费者的语法如下:
$ bin/kafka-console-consumer.sh –bootstrap-server localhost:9092 –topic test –from -beginning
![咖啡消费者](https://adatiya.com/images/uploads/sites/7/1641769065.png)
步骤 7. 生产者-消费者连接
建立生产者和消费者的连接后,我们可以发送消息,消费者端会收到。 我们来看一下。
在生产者网站
![卡夫卡](https://adatiya.com/images/uploads/sites/7/1641769067.png)
在消费者现场
![卡夫卡](https://adatiya.com/images/uploads/sites/7/1641769069.png)
在这里,您可以看到双方的消息,即生产者和消费者。
结论
在本教程中,我们已经介绍了如何安装 Apache ubuntu 中的卡夫卡。 我们希望您现在知道如何有效地使用该命令。 如果您有任何疑问,请在评论中告诉我们。