Spring Reactor Kafka多消费者并行消费时发送共用同一线程问题咨询

• Apache Kafka 原生Producer的设计特性：Kafka官方提供的Java客户端中，KafkaProducer被设计为线程安全、全局复用的组件，其内部会启动一个唯一的后台IO线程（默认命名格式为producer-数字序号），所有上层提交的发送请求都会先进入内部线程安全的缓冲区，再由这个专属IO线程统一处理批量聚合、网络请求发送、结果回调触发等逻辑。不管上层有多少个线程调用send方法提交消息，实际的发送执行和回调都会在这个专属IO线程上运行，这是该现象的核心根源。
• Reactive Kafka 的封装逻辑：你配置的ReactiveKafkaProducerTemplate底层依赖单例的KafkaSender实例，KafkaSender默认复用全局的KafkaProducer，其发送响应的信号默认会绑定到KafkaProducer的内部IO线程上发布，所以你在doOnNext、doOnSuccess等回调中打印的线程名，都是这个IO线程的名称，和上层触发发送的消费者线程无关。
• 默认调度规则的影响：你在sendToKafka方法中直接调用subscribe()触发发送流程，没有手动指定响应信号的调度器，Reactor框架默认会使用信号产生的原生线程执行后续回调，进一步固定了回调的执行线程为producer-1。

如果需要调整回调的执行线程，可以在kafkaProducerTemplate.send()返回的Mono后添加publishOn(自定义调度器)手动切换线程，不会影响Producer本身的发送性能。

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