如何在 Ubuntu 22.04 上安装 Kafka 并发送和消费消息

kafka 是一个分布式流平台，允许发布和订阅记录流，以容错方式存储记录流，并在记录发生时处理记录流。在本文中，将向你展示如何在 Ubuntu 22.04 上安装 Kafka 并开始发送和消费消息。我们还将介绍消费者、生产者、代理、集群等概念，以及 Kafka 消息的结构。

在 Kafka 中，生产者是向一个或多个主题发布消息的应用程序。消费者是一种应用程序，它订阅一个或多个主题，并按照产生的顺序处理消息。

代理是一种服务器，它将消息存储在主题中，并将其提供给消费者。集群是一组协同工作的代理，可提供高可用性和可扩展性。

在 Kafka 中，每个分区都有一个有序的、不可更改的消息序列，并被不断追加。分区内的每条消息都会被分配一个唯一的偏移量编号，以标识其在分区内的位置。

从主题分区消费消息时，可以指定要从哪个偏移量开始消费消息。这样，您就可以从离开的位置继续消费消息。

在 Kafka 中，消费者可以组织成消费者组。组内的每个消费者从一个独特的分区读取信息，而整个组则消费整个主题的所有信息。

第1步：下载并安装Kafka

wget https://downloads.apache.org/kafka/3.5.1/kafka-3.5.1-src.tgz

接下来，解压下载的文件：

tar -xzf kafka_2.12-3.5.1.tgz

导航至提取的目录：

cd kafka_2.12-3.5.1

第2步：启动ZooKeeper

在启动 Kafka 之前，需要启动 ZooKeeper，Kafka 使用它来协调 Broker 之间的关系。

./bin/zookeeper-server-start.sh config/zookeeper.properties

第 3 步：启动Kafka服务器

打开另一个终端窗口并导航到 Kafka 目录。然后，启动 Kafka 服务器：

./bin/kafka-server-start.sh config/server.properties

第 4 步：创建主题

现在已经启动并运行了 Kafka，创建一个名为“test”的主题，其中包含一个分区和一个副本：

./bin/kafka-topics.sh --create --topic test --bootstrap-server localhost:9092

第 5 步：发送消息

现在可以使用控制台生产者客户端将消息发送到“test”主题：

./bin/kafka-console-producer.sh --topic test --bootstrap-server localhost:9092

在控制台中键入信息，然后按回车键发送。

第 6 步：消费消息

要读取 “test “主题中的消息，请打开另一个终端窗口并导航到 Kafka 目录。然后，运行以下命令：

./bin/kafka-console-consumer.sh --topic test --from-beginning --bootstrap-server localhost:9092

你应该能在控制台中看到之前发送的信息。

就是这样！你已经成功安装了 Kafka、发送了消息、消费了消息、了解了主题分区偏移和消费者组。

作者：EazyPeazyGeeky
原文：https://blog.devgenius.io/getting-started-with-kafka-on-ubuntu-22-04-lts-40c7338ea8b