使用SpringBoot+Apache Camel时Kafka DefaultPartitioner调用两次是否正常？

这种情况在SpringBoot 2.7.8搭配Apache Camel 3.20.2集成Kafka的场景下属于正常行为，核心原因来自Camel Kafka组件的内部设计：

• Camel组件的预检查机制：Camel Kafka生产者在发送消息前，会先调用partition()方法做一次预计算，目的是验证分区配置合法性、确认目标分区在集群中是否可用，避免实际发送时出现无效分区的异常。之后在真正执行消息发送逻辑时，会再次调用该方法完成最终的分区路由。
• Kafka客户端的元数据同步逻辑：少数场景下，Kafka生产者客户端在更新集群元数据后，会重新触发分区计算，但结合你的使用场景，核心原因还是Camel组件的预校验流程导致的二次调用。

关键注意点 #

• 只要DefaultPartitioner两次调用时的参数（topic、key、集群元数据）一致，返回的分区结果就会完全相同，不会造成消息投递异常，这也是你目前未遇到业务问题的核心原因。
• 如果后续自定义了分区器，需要保证partition()方法是幂等的，避免两次调用返回不同分区导致的消息路由异常。

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