在 Debian 上创建 Kafka 主题,一般步骤如下(假设你已经安装并启动了 Kafka)。
cd /opt/kafka # 或你的 kafka 安装目录
bin/kafka-topics.sh \
--create \
--zookeeper localhost:2181 \
--replication-factor 1 \
--partitions 1 \
--topic test-topic
bin/kafka-topics.sh \
--create \
--bootstrap-server localhost:9092 \
--replication-factor 1 \
--partitions 1 \
--topic test-topic
--topic:主题名称--partitions:分区数--replication-factor:副本数(不能超过 broker 数量)--bootstrap-server:Kafka 服务地址(推荐)--zookeeper:老版本方式bin/kafka-topics.sh --list --bootstrap-server localhost:9092
查看主题详情:
bin/kafka-topics.sh --describe --topic test-topic --bootstrap-server localhost:9092
Topic exists说明主题已存在,可先删除:
bin/kafka-topics.sh --delete --topic test-topic --bootstrap-server localhost:9092
90922181使用 sudo 或确保当前用户有 Kafka 目录权限。
如果你愿意,可以告诉我:
我可以给你更精确的命令。