【问题标题】:How to Properly Unit Test Dlq within Spring Cloud Stream如何在 Spring Cloud Stream 中正确地对 Dlq 进行单元测试
【发布时间】:2021-06-09 21:05:30
【问题描述】:

在 spring cloud stream kafka binder 中有一些本机配置,例如 enableDlq,但是我没有找到任何示例来说明 enableDlq 是否正常工作时如何正确进行单元测试。有没有关于如何正确实施此类测试的示例?

【问题讨论】:

    标签: spring-cloud spring-kafka dead-letter spring-cloud-stream-binder-kafka


    【解决方案1】:

    binder 项目本身有一堆测试:

    https://github.com/spring-cloud/spring-cloud-stream-binder-kafka/blob/33aa926940ffdbe9d0847b4eab020ccbadfab062/spring-cloud-stream-binder-kafka/src/test/java/org/springframework/cloud/stream/binder/kafka/KafkaBinderTests.java#L941-L1193

    一般技术是使用单独的绑定绑定到 dlq,但您同样可以定义一个 KafkaConsumer 来使用它并验证它是否收到了您期望的消息。

    【讨论】:

    • 谢谢加里!我是否建议添加一个指向提供参考实现的文档的链接。我知道谷歌搜索有效,但也很高兴在指南中看到它们。
    • 随时根据您的建议针对活页夹打开 GitHub 问题。
    猜你喜欢
    • 2018-12-17
    • 2018-11-10
    • 1970-01-01
    • 2020-01-06
    • 2010-09-23
    • 2014-01-30
    • 2011-02-02
    • 1970-01-01
    • 1970-01-01
    相关资源
    最近更新 更多