如何在Ubuntu上正确安装Kafka

在Ubuntu上安装Apache Kafka的步骤如下：

安装前准备

1. 更新系统包：

sudo apt update
sudo apt upgrade -y

2. 安装Java环境：

Kafka需要Java运行时环境（JRE）或Java开发工具包（JDK）。你可以安装OpenJDK：

sudo apt install openjdk-11-jdk -y

验证安装：

java -version

下载并解压Kafka

1. 下载Kafka安装包：

访问Apache Kafka官网选择版本并下载，例如下载Kafka 3.5.2版本：

wget https://downloads.apache.org/kafka/3.5.2/kafka_2.12-3.5.2.tgz

2. 解压安装包：

tar -xzf kafka_2.12-3.5.2.tgz

3. 进入解压后的目录：

cd kafka_2.12-3.5.2

配置与启动Kafka

1. 配置Kafka：

• 复制配置文件：

cp config/server.properties config/server.properties.bak

• 编辑配置文件：

sudo vi config/server.properties

• 修改以下参数（根据您的需求）：

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

2. 启动Kafka服务：

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

验证Kafka是否启动成功

使用以下命令检查Kafka是否正在监听9092端口：

netstat -tunlp | grep 9092

创建和测试Topic

1. 创建一个主题：

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

2. 查看所有主题：

bin/kafka-topics.sh --list --bootstrap-server localhost:9092

3. 启动生产者发送消息：

bin/kafka-console-producer.sh --broker-list localhost:9092 --topic test

在控制台输入消息后，消费者应能实时接收。

4. 启动消费者接收消息：

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

通过以上步骤，您可以在Ubuntu系统上成功安装并运行Apache Kafka。