如何用Rust编程获取Kafka分区数？解决Seek未知分区错误

核心原因 #

你指定的分区编号不存在，导致seek失败。Kafka的分区从0开始计数，自动创建的主题默认分区数通常为1，但需要先确认实际情况。

步骤1：确认主题的分区信息 #

进入你的Docker Kafka容器，执行Kafka自带的命令查看目标主题的分区详情：

# 替换kafka为你的容器名，替换"你的主题名"为Self::topic()返回的主题名称
docker exec -it kafka /opt/kafka/bin/kafka-topics.sh --describe --topic "你的主题名" --bootstrap-server localhost:9092

执行结果里的Partitions字段会显示总分区数，每个分区的编号从0开始递增。

步骤2：修正seek代码 #

根据第一步得到的实际分区号，修改seek的第二个参数：
比如确认只有1个分区，就用0：

self.consumer
    .seek(Self::topic(), 0, Offset::Offset(1), Timeout::Never)
    .expect("Trying to seek but didn't work");

如果有多个分区，就填入存在的分区编号（如0、1等）。

额外注意 #

• 自动创建主题的分区数由Kafka配置num.partitions控制，默认是1，若你的Docker环境修改过这个配置，分区数会变化。
• 执行seek前，确保消费者已经通过subscribe或assign方法订阅/分配了目标主题的对应分区，否则也可能触发类似错误。

内容的提问来源于stack exchange，提问作者ten5peed