在 Debian 上部署 Kafka 时,“分区(partition)怎么设”通常涉及创建 topic 时指定分区数、修改已有 topic 分区数,以及一些配置建议。下面按常见场景说明。
假设:
/opt/kafka/opt/kafka/bin/kafka-topics.sh \
--create \
--topic test-topic \
--bootstrap-server localhost:9092 \
--partitions 3 \
--replication-factor 1
说明:
--partitions 3:设置 3 个分区--replication-factor 1:副本数(生产环境通常 ≥2)/opt/kafka/bin/kafka-topics.sh \
--describe \
--topic test-topic \
--bootstrap-server localhost:9092
输出示例:
Topic: test-topic PartitionCount: 3 ReplicationFactor: 1
⚠️ Kafka 不支持减少分区数
/opt/kafka/bin/kafka-topics.sh \
--alter \
--topic test-topic \
--partitions 6 \
--bootstrap-server localhost:9092
如果你是用 apt 或 systemd 安装的 Kafka:
sudo systemctl status kafka
sudo journalctl -u kafka -f
执行脚本时确保:
kafka 用户或有权限的用户JAVA_HOME 已配置分区数 ≥ 消费者实例数
如果你用的是 Kafka 3.x+ KRaft:
kafka-topics.sh \
--create \
--topic test \
--bootstrap-server localhost:9093 \
--partitions 3 \
--replication-factor 1
如果你愿意,可以告诉我:
我可以给你更具体的分区方案。