温馨提示×

kafka主题在debian怎设

小樊
51
2026-09-19 01:16:08
栏目: 智能运维

在 Debian 上“设置 Kafka 主题”通常分为两部分:安装/启动 Kafka 和 创建/配置主题。下面给你一个从零开始的简明流程(以 Kafka 3.x 为例,使用 KRaft 或 ZooKeeper 都可以,这里先给最常见的 ZooKeeper 方式)。


一、在 Debian 上安装 Kafka

1. 安装 Java

Kafka 需要 Java:

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

2. 下载 Kafka

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

二、启动 Kafka(ZooKeeper 模式)

1. 启动 ZooKeeper

cd /opt/kafka
bin/zookeeper-server-start.sh config/zookeeper.properties

(建议用 nohup 或 systemd 后台运行)

2. 启动 Kafka

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

三、创建 Kafka 主题

1. 基本创建命令

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

说明:

  • --topic:主题名
  • --partitions:分区数
  • --replication-factor:副本数(单节点只能是 1)

四、查看 / 删除主题

查看所有主题

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

查看主题详情

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

删除主题

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

(需 delete.topic.enable=true)


五、常用配置示例(主题级)

创建时指定参数:

bin/kafka-topics.sh --create \
  --topic logs \
  --bootstrap-server localhost:9092 \
  --partitions 6 \
  --replication-factor 1 \
  --config retention.ms=604800000 \
  --config cleanup.policy=delete

六、Debian 系统服务(可选)

如果你想用 systemctl 管理 Kafka,我可以帮你写:

  • kafka.service
  • zookeeper.service

如果你是指:

  • ✅ KRaft 模式(无 ZooKeeper)
  • ✅ Docker 方式
  • ✅ 多节点集群
  • ✅ 权限 / SASL / ACL

告诉我你的使用场景,我可以给你更合适的配置。

0 踩