kafka在ubuntu如何测试

在 Ubuntu 上测试 Kafka，通常分为 安装、启动、创建 topic、收发消息 这几个步骤。下面给你一个最常用、可操作的完整流程（基于 Kafka 自带脚本）。

一、环境准备

1️⃣ 安装 Java（Kafka 依赖）

sudo apt update
sudo apt install openjdk-11-jdk -y
java -version

二、安装 Kafka（单机测试）

2️⃣ 下载 Kafka

wget https://downloads.apache.org/kafka/3.6.1/kafka_2.13-3.6.1.tgz
tar -xzf kafka_2.13-3.6.1.tgz
cd kafka_2.13-3.6.1

版本号可换，建议用 3.x 稳定版。

三、启动 Kafka（本地测试）

Kafka 依赖 Zookeeper（旧版本） 或 KRaft（新版本）
下面分别给你两种测试方式。

✅ 方式一：使用 Zookeeper（最经典，适合入门）

3️⃣ 启动 Zookeeper

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

新终端窗口继续操作

4️⃣ 启动 Kafka Broker

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

✅ 方式二：使用 KRaft（推荐，无 Zookeeper）

3️⃣ 生成集群 ID

KAFKA_CLUSTER_ID="$(bin/kafka-storage.sh random-uuid)"

4️⃣ 格式化日志目录

bin/kafka-storage.sh format -t $KAFKA_CLUSTER_ID -c config/kraft/server.properties

5️⃣ 启动 Kafka

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

三、测试 Kafka（核心步骤）

5️⃣ 创建 Topic

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

查看 topic：

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

6️⃣ 启动生产者（发送消息）

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

输入几条消息：

hello kafka
this is a test

按 Ctrl+C 退出。

7️⃣ 启动消费者（接收消息）

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

✅ 如果看到刚才发的消息，说明 Kafka 测试成功！

四、快速验证是否成功

# 查看 broker 是否运行
jps

应看到：

Kafka
QuorumPeerMain  # 如果用 Zookeeper

五、常见问题

❌ 端口被占用

sudo netstat -tulnp | grep 9092

❌ 无法连接 localhost:9092

检查：

config/server.properties

确认：

listeners=PLAINTEXT://localhost:9092

六、适合你的下一步

你可以告诉我：

✅ 是 学习 / 开发 / 生产环境
✅ 是否用 Docker
✅ 是否和 Spring Boot / Python / Go 集成

我可以给你 Docker 一键测试方案 或 生产级配置示例。