温馨提示×

kafka主题debian怎创建

小樊
37
2026-09-28 02:11:37
栏目: 智能运维

在 Debian 系统上创建 Kafka 主题,前提是 Kafka 已经安装并运行。下面按常见情况说明。


一、前提条件

  1. 已安装 Kafka(如 /opt/kafka 或 /usr/local/kafka)
  2. Kafka 服务已启动
    # 启动 Zookeeper(老版本)
    bin/zookeeper-server-start.sh config/zookeeper.properties
    
    # 启动 Kafka
    bin/kafka-server-start.sh config/server.properties
    

二、使用 Kafka 自带脚本创建主题(推荐)

进入 Kafka 安装目录:

cd /opt/kafka

1️⃣ Kafka 2.x 及以后(常用方式)

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

参数说明:

  • --bootstrap-server:Kafka 地址
  • --replication-factor:副本数(≤ broker 数量)
  • --partitions:分区数
  • --topic:主题名

2️⃣ 老版本(依赖 Zookeeper)

bin/kafka-topics.sh \
  --create \
  --zookeeper localhost:2181 \
  --replication-factor 1 \
  --partitions 3 \
  --topic test-topic

三、验证主题是否创建成功

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

查看主题详情:

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

四、Debian 上常见问题

1️⃣ 命令找不到

确认 Java 已安装:

java -version

2️⃣ 端口不对

Debian 上常见:

  • Kafka:9092
  • Zookeeper:2181

3️⃣ 权限问题

sudo chown -R kafka:kafka /opt/kafka

五、示例(完整)

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

如果你愿意,可以告诉我:

  • Kafka 版本
  • 是否使用 Docker
  • 单机还是集群

我可以给你更精确的操作命令。

0 踩