kafka/spring集成的java故障转移集成测试

qlzsbp2j 于 2021-06-07 发布在 Kafka

关注(0)|答案(1)|浏览(402)

我正在研究两个场景，在spring与kafka集成的基础上：
快乐路径-通道正确地流动，并成功地将其有效负载传递到出界通道
另一种情况-通道正确流动，但出界通道向下
我的计划是在服务器上使用aop KafkaTemplate ，它在被任何send方法调用时引发异常。这将返回到错误通道。
我想知道还有什么（更简单，不引人注目！）测试技术，可用于处理不可用的出界通道？
applicationcontext（即xml）解决方案的加分，而不是基于注解的加分！

Java spring apache-kafka spring-integration

来源：https://stackoverflow.com/questions/46794044/failover-integration-testing-of-kafka-spring-integration

1条答案

按热度按时间

smtd7mpg1#

只有在以下情况下，调用线程才会出现异常 sync 是真的；否则，异步失败可能会发送到错误通道（从2.3/3.0开始）。
请参见向端点添加行为；特别是 ExpressionEvaluatingRequestHandlerAdvice .
编辑
您还可以在通道适配器的上游添加中流网关。

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

public interface OneWay {

    void sendIt(Message<?> message);

}

这个 ec 会得到一个 ErrorMessage 用一个 MessagingException 有效载荷 failedMessage 以及 cause 属性。

赞(0）回复(0）举报 2021-06-07

我来回答

kafka/spring集成的java故障转移集成测试

1条答案

相关问题

热门标签

最新问答