Spring Integration Kafka报错Dispatcher无订阅者，无法接收kafka-out响应

问题描述 #

使用Kafka实现消息通道，流程为http --> gateway --> kafka-in --> kafka-transform --> kafka-out，消息可成功发送至kafka-out但无法接收响应，出现两个核心错误：

1. 消息分发错误：

   org.springframework.integration.MessageDispatchingException: Dispatcher has no subscribers

2. OutboundGateway注解冲突错误：

   org.springframework.beans.factory.support.BeanDefinitionValidationException: The MessageHandler [outGateway] can not be populated because of ambiguity with annotation attributes [sendTimeout, outputChannel, requiresReply] which are not allowed when an integration annotation is used with a @Bean definition for a MessageHandler.The attribute causing the ambiguity is: [outputChannel].

错误一：OutboundGateway注解冲突解决 #

当通过@Bean定义MessageHandler类型的Bean（如KafkaOutboundGateway）时，不能在Bean方法上同时使用带有outputChannel、sendTimeout、requiresReply属性的Spring Integration注解（如@ServiceActivator），这些属性会与Bean自身配置产生歧义。

修复方式：
移除注解中冲突的属性，改为在Bean实例中配置相关参数：

// 错误示例：注解与Bean配置属性冲突
@Bean
@ServiceActivator(inputChannel = "kafka-out", outputChannel = "replyChannel")
public KafkaOutboundGateway outGateway(KafkaTemplate<String, Object> kafkaTemplate) {
    KafkaOutboundGateway gateway = new KafkaOutboundGateway(kafkaTemplate);
    return gateway;
}

// 正确示例：将属性移至Bean实例配置
@Bean
@ServiceActivator(inputChannel = "kafka-out")
public KafkaOutboundGateway outGateway(KafkaTemplate<String, Object> kafkaTemplate) {
    KafkaOutboundGateway gateway = new KafkaOutboundGateway(kafkaTemplate);
    gateway.setReplyChannelName("replyChannel"); // 替代注解的outputChannel
    gateway.setRequiresReply(true);
    gateway.setSendTimeout(5000);
    return gateway;
}

错误二：Dispatcher无订阅者解决 #

该错误表示响应消息的目标通道（如replyChannel）没有对应的消费者订阅，导致消息无法流转回HTTP请求。

修复步骤：

1. 确认Gateway接口与响应通道绑定：确保Gateway接口明确指定replyChannel，且定义了返回值：

@Gateway(requestChannel = "kafka-in", replyChannel = "replyChannel")
String sendMessage(String payload);

2. 确保响应通道存在且有订阅者：定义replyChannel的Bean，并确保有对应的处理器订阅该通道（通常由Gateway自动关联，但需确认配置无遗漏）：

@Bean
public MessageChannel replyChannel() {
    return new DirectChannel();
}

3. 检查消息头完整性：自定义Transformer时，避免修改或移除replyChannel消息头，该头由Gateway自动生成，是响应回流的关键标识。
4. 验证Kafka响应链路：若使用Kafka Outbound Gateway，需确保Kafka响应主题的消费者能正确将消息发送至replyChannel。

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