你现在查看的是Kafka 0.9.0.2中的旧版Scala Producer API（对应kafka.producer.Producer类），以及它的Java包装类，分区决策的逻辑确实不在你看到的这两个send方法里，而是藏在以下几个环节中：

1. 核心逻辑在EventHandler的实现类里 #

你看到的Scala Producer的send方法中，同步发送时会调用this.eventHandler().handle(messages)——这里的EventHandler就是处理分区分配的关键组件。默认实现是DefaultEventHandler，它会在handle方法中完成分区的计算：

当处理每条KeyedMessage时，如果消息本身没有手动指定分区（即KeyedMessage的partition字段为null），DefaultEventHandler会调用Partitioner（默认是kafka.producer.DefaultPartitioner，注意和你提到的新版clients包下的不是同一个类）的partition方法，根据消息的key、topic名称以及集群的分区数量来计算出对应的分区ID。

2. 两种分区指定方式 #

• 手动指定分区：如果你在创建KeyedMessage时已经指定了分区ID（比如new KeyedMessage<>(topic, partitionId, key, value)），那么EventHandler会直接使用这个指定的分区，不会再调用Partitioner。
• 自动计算分区：如果没有手动指定，就会触发Partitioner的逻辑自动计算分区ID，这个过程是在EventHandler.handle()方法内部完成的，所以不会在你看到的send方法代码里直接体现。

3. 新旧Producer API的区别 #

你提到的org.apache.kafka.clients.producer.internals.DefaultPartitioner属于新版Java Producer API（从Kafka 0.9开始引入的kafka-clients模块），这套API和你现在查看的旧版Scala Producer API是相互独立的：

• 新版API的入口是org.apache.kafka.clients.producer.KafkaProducer，它的分区逻辑确实会在发送流程中直接调用DefaultPartitioner，但你现在看的是旧版的API实现，所以找不到对应代码。

查找建议 #

如果你想继续追踪旧版API的分区逻辑，可以去查找：

• kafka.producer.DefaultEventHandler类的handle方法
• kafka.producer.DefaultPartitioner类的partition方法

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