将 @Gateway 与 Spring-Integration-Kafka 一起使用

Question

使用 Spring-Integration-Kafka 是否还能使用@MessagingGateway 和@Gateway。

我当前的代码如下所示：

@MessagingGateway
public interface OrderGateway {
 @Gateway(requestChannel = "requestChannel", replyChannel = "replyChannel",headers = {@GatewayHeader(name = "kafka_topic", value ="requestTopic"))
  Order order(Item item)
}

关于我的 Spring Spring 配置：

@Bean
@ServiceActivator(inputChannel = "requestChannel")
public MessageHandler kafkaMessageHandler(KafkaTemplate kafkaTemplate) {
    KafkaProducerMessageHandler<String, String> messageHandler = new KafkaProducerMessageHandler<>(kafkaTemplate);
    messageHandler.setMessageKeyExpression(new LiteralExpression("spring-integration-kafka"));
    messageHandler.setTopicExpression(new SpelExpressionParser().parseExpression("headers.kafka_topic"));
    return messageHandler;
}

使用此设置，我得到错误提示：

by: org.springframework.messaging.core.DestinationResolutionException: no output-channel or replyChannel header available  

Answer 1

您似乎没有显示完整的配置。

网关期待回复，但kafkaMessageHandler 没有回复（除非模板是ReplyingKafkaTemplate）并且将丢失replyChannel 标头。

所以，大概，您正试图从其他地方发送回复。

如果您期待请求/回复语义；使用new outbound gateway。

模板必须是ReplyingKafkaTemplate。