在 Debian 系统上创建 Kafka 主题,前提是 Kafka 已经安装并运行。下面按常见情况说明。
/opt/kafka 或 /usr/local/kafka)# 启动 Zookeeper(老版本)
bin/zookeeper-server-start.sh config/zookeeper.properties
# 启动 Kafka
bin/kafka-server-start.sh config/server.properties
进入 Kafka 安装目录:
cd /opt/kafka
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:主题名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
确认 Java 已安装:
java -version
Debian 上常见:
90922181sudo 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
如果你愿意,可以告诉我:
我可以给你更精确的操作命令。