Spring Cloud Stream下Kafka Sticky Partitioner生效条件咨询

首先明确Spring Cloud Stream Kafka binder的处理逻辑：

• 当你配置了partitionKeyExpression时，框架会先解析表达式得到分区键值，若结果为null，框架不会自定义计算目标分区，会直接把分区选择权交给Kafka原生生产者分区器
• 如果你没有显式替换Kafka生产者的默认分区器，从Kafka 2.4版本开始默认使用的DefaultPartitioner内置了Sticky Partitioner逻辑，当传入的消息键/分区键为null时，Sticky Partitioner默认会生效，会将连续的一批无键消息固定分配到同一个分区，减少分区切换开销，提升生产吞吐量。

• 当你没有给生产者配置partitionKeyExpression，也没有在消息头中设置kafka_partitionKey相关参数时，Spring Cloud Stream Kafka binder不会为消息生成任何分区键，相当于传递给Kafka原生分区器的键值为null
• 该场景下Kafka默认分区器的Sticky Partitioner逻辑会正常触发，和显式配置分区键表达式但得到null值的效果完全一致。

补充说明：上述结论仅适用于使用Kafka默认DefaultPartitioner的场景，如果你显式配置了自定义分区器类替换了默认实现，Sticky Partitioner是否生效完全由自定义分区器的逻辑决定。

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