如何为所有Spring Cloud Stream Kafka消费者统一配置partition.assignment.strategy

没问题，要实现所有通道统一配置分区分配策略，你只需要把原来针对单个通道的配置前缀换成default就可以了，这样就能全局生效，不用每个通道重复写配置。

原来单个通道的配置是这样的：

spring.cloud.stream.kafka.bindings.input.consumer.configuration.partition.assignment.strategy=org.apache.kafka.clients.consumer.RoundRobinAssignor

改成全局统一配置的话，只需要调整为：

spring.cloud.stream.kafka.default.consumer.configuration.partition.assignment.strategy=org.apache.kafka.clients.consumer.RoundRobinAssignor

这里的default前缀是关键，它会把这个配置应用到所有Kafka消费者绑定上，不管你定义了多少个通道，都会自动继承这个分区分配策略。

另外补充一点：如果之后某个特定通道需要使用不同的策略，你依然可以给该通道单独配置对应的属性，单独配置的优先级会高于全局默认配置，这样既保证了全局统一，又保留了特殊场景的灵活性。

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