在 Debian 上设置 Kafka 分区,通常分为两种情况:
1️⃣ 新建 Topic 时指定分区数
2️⃣ 已有 Topic 增加分区数
下面以 Kafka 3.x(自带 ZooKeeper 或 KRaft) 为例说明。
假设:
/opt/kafkacd /opt/kafka
bin/kafka-topics.sh \
--create \
--zookeeper localhost:2181 \
--topic test-topic \
--partitions 6 \
--replication-factor 1
bin/kafka-topics.sh \
--create \
--bootstrap-server localhost:9092 \
--topic test-topic \
--partitions 6 \
--replication-factor 1
✅ 说明:
--partitions 6:设置 6 个分区--replication-factor 1:副本数(生产环境一般 ≥2)bin/kafka-topics.sh \
--describe \
--bootstrap-server localhost:9092 \
--topic test-topic
bin/kafka-topics.sh \
--alter \
--bootstrap-server localhost:9092 \
--topic test-topic \
--partitions 10
⚠ 注意:
如果是用 systemd 启动的 Kafka:
sudo systemctl status kafka
命令仍用 kafka-topics.sh,只是路径可能不同:
/usr/share/kafka/bin/kafka-topics.sh
如果你愿意,可以告诉我:
我可以给你更精确的配置示例。