Rust rd-kafka中如何设置有效的partition.assignment.strategy参数值

你遇到的问题根源在于：rd-kafka依赖的librdkafka（C实现），其分区分配策略的参数取值和Java Kafka客户端完全不兼容，不能直接照搬Apache Kafka文档里的Java类名。

正确配置方式 #

要启用轮询（RoundRobin）分配策略，你需要将参数值设为全小写的roundrobin，而非Java客户端的类名或驼峰命名：

.set("partition.assignment.strategy", "roundrobin")

librdkafka支持的所有分区分配策略选项 #

librdkafka内置以下几种策略，直接使用对应的字符串即可：

• range：默认策略，按主题分区的连续范围分配给消费者
• roundrobin：轮询式分配，将分区均匀分散给消费者
• sticky：粘性分配，重平衡时尽量保留消费者已有的分区分配
• cooperative-sticky：协作式粘性分配，支持增量式重平衡，避免全量重新分配

为什么之前的配置无效 #

Apache Kafka官方文档里的partition.assignment.strategy取值是针对Java客户端的类路径（比如org.apache.kafka.clients.consumer.RoundRobinAssignor），但librdkafka作为C语言实现的客户端，使用了一套独立的字符串标识体系，两者不通用，所以你之前的配置会触发"Unsupported partition.assignment.strategy"错误。

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