在 Debian 上“配置 Kafka 主题”通常分三步:安装 Kafka(或连接已有 Kafka)→ 启动服务 → 用命令行创建/修改主题。下面给你一套最常用、可直接照做的流程。
sudo apt update
sudo apt install -y default-jdk
java -version
以 Kafka 3.6 为例(可换版本):
cd /opt
sudo wget https://downloads.apache.org/kafka/3.6.1/kafka_2.13-3.6.1.tgz
sudo tar -xzf kafka_2.13-3.6.1.tgz
sudo mv kafka_2.13-3.6.1 kafka
cd /opt/kafka
bin/zookeeper-server-start.sh config/zookeeper.properties
新开一个终端:
cd /opt/kafka
bin/kafka-server-start.sh config/server.properties
✅ Kafka 3.x 也支持 KRaft 模式(无 Zookeeper),但新手建议先用 Zookeeper。
bin/kafka-topics.sh \
--create \
--topic test-topic \
--bootstrap-server localhost:9092 \
--partitions 3 \
--replication-factor 1
说明:
--partitions 3:3 个分区--replication-factor 1:单节点只能为 1bin/kafka-topics.sh --list --bootstrap-server localhost:9092
bin/kafka-topics.sh --describe --topic test-topic --bootstrap-server localhost:9092
bin/kafka-topics.sh \
--alter \
--topic test-topic \
--partitions 5 \
--bootstrap-server localhost:9092
⚠️ Kafka 不能减少分区,也不能直接改副本数(需用 reassignment)
bin/kafka-console-producer.sh \
--topic test-topic \
--bootstrap-server localhost:9092
bin/kafka-console-consumer.sh \
--topic test-topic \
--from-beginning \
--bootstrap-server localhost:9092
| 文件 | 作用 |
|---|---|
config/server.properties |
Kafka 主配置 |
config/zookeeper.properties |
Zookeeper 配置 |
log.dirs |
消息存储目录 |
只需:
bin/kafka-topics.sh \
--create \
--topic my-topic \
--bootstrap-server kafka-host:9092
不用安装 Kafka Server,只保留 kafka_2.13-*.tgz 的 bin 工具即可。
如果你愿意,可以告诉我:
我可以直接给你一份 Debian 专用配置方案。