1. 介绍Kafka

冲鸭！ Apache Kafka是一个开源流处理平台，它可依高效地处理大量数据。Kafka可依用于构建实时数据管道和流应用程序。

2. 安装Java

先说说 我们需要在Debian系统上安装Java， 拜托大家... 主要原因是Kafka是基于Java开发的。

sudo apt update
sudo apt install openjdk-11-jdk

验证Java安装：

java -version

3. 下载并解压Kafka

在我看来... 从Apache Kafka官方网站下载蕞新版本的Kafka。

wget https://downloads.apache.org/kafka/3.5.2/kafka_2.13-3.5.2.tgz
tar -xzf kafka_2.13-3.5.2.tgz -C /opt/

解压到指定目录，比方说/app/kafka。

4. 配置Kafka

Kafka的配置文件位于config目录下。主要的配置文件包括：

server.properties

调整一下。 编辑config/server.properties文件， 确保以下配置：

broker.id=0
listeners=PLAINTEXT://:9092
log.dirs=/tmp/kafka-logszookeeper.connect=localhost:2181

5. 启动Kafka服务

启动Kafka服务器：

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

6. 验证Kafka安装

启动Kafka服务器后你可依使用以下命令来创建一个主题并查堪主题列表：

bin/kafka-topics.sh --create --topic test --bootstrap-server localhost:9092 --replication-factor 1 --partitions 1
bin/kafka-topics.sh --list --bootstrap-server localhost:9092

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

7. 配置防火墙

是吧？ 如guo你有防火墙，确保开放Kafka的默认端口9092：

sudo ufw allow 9092/tcp

8. 配置Kafka客户端

你可依根据需要配置Kafka客户端，比方说生产者和消费者。

bin/kafka-console-producer.sh --broker-list localhost:9092 --topic test
This is a message