在 Debian 系统上创建 Kafka 主题,通常有两种方式:命令行方式(最常用) 和 通过 Kafka 管理工具/代码。下面重点讲 命令行方式,这也是在 Debian 服务器上最常见的做法。
/opt/kafka 或 /usr/local/kafka)cd /opt/kafka
(具体路径以你的安装位置为准)
bin/kafka-topics.sh \
--create \
--topic test-topic \
--bootstrap-server localhost:9092 \
--partitions 3 \
--replication-factor 1
参数说明:
--topic:主题名--bootstrap-server:Kafka 地址(新版本推荐)--partitions:分区数--replication-factor:副本数(不能大于 broker 数量)✅ Kafka 2.2+ 推荐使用 --bootstrap-server
bin/kafka-topics.sh \
--create \
--topic test-topic \
--zookeeper localhost:2181 \
--partitions 3 \
--replication-factor 1
bin/kafka-topics.sh --list --bootstrap-server localhost:9092
查看主题详情:
bin/kafka-topics.sh --describe --topic test-topic --bootstrap-server localhost:9092
jps
应看到 Kafka
启动 Kafka:
bin/kafka-server-start.sh config/server.properties
例如只有 1 个 broker,却设置:
--replication-factor 2
会报错
如果你是用 apt 安装的 Kafka(较少见),可能命令在:
/usr/share/kafka/bin/kafka-topics.sh
# 启动 Kafka
bin/kafka-server-start.sh -daemon config/server.properties
# 创建主题
bin/kafka-topics.sh --create \
--topic my-topic \
--bootstrap-server localhost:9092 \
--partitions 1 \
--replication-factor 1
如果你愿意,我可以:
你现在 Kafka 是已经装好了,还是刚开始装?