Kafka/Spring集成的故障转移集成测试

Question

我正在研究 两个 场景，在 Spring 与 Kafka 的集成之上工作：

1. Happy path - 通道正确流动并将其有效负载成功传递到出站通道
2. 另一种情况 - 通道正确流动，但出站通道关闭

我的计划是在KafkaTemplate 上使用AOP，当它被任何发送方法调用时会引发异常。然后将其返回到错误通道。

我想知道还有哪些其他（更简单且不显眼！）测试技术可用于处理不可用的出站通道？

加分适用于 ApplicationContext（即 XML）解决方案，而不是基于注释！

Answer 1

1. 如果sync 为真，您只会在调用线程上获得异常；否则异步失败可能会被发送到错误通道（从 2.3/3.0 开始）。

2. 见Adding Behavior to Endpoints；特别是ExpressionEvaluatingRequestHandlerAdvice。

编辑

您还可以在通道适配器的上游添加一个中流网关。

<int:gateway service-interface=OneWay error-channel="ec"
    default-request-channel="toKafka" />

public interface OneWay {

    void sendIt(Message<?> message);

}

ec 将获得带有MessagingException 有效负载的ErrorMessage，该负载具有failedMessage 和cause 属性。