【发布时间】:2021-06-09 21:05:30
【问题描述】:
在 spring cloud stream kafka binder 中有一些本机配置,例如 enableDlq,但是我没有找到任何示例来说明 enableDlq 是否正常工作时如何正确进行单元测试。有没有关于如何正确实施此类测试的示例?
【问题讨论】:
标签: spring-cloud spring-kafka dead-letter spring-cloud-stream-binder-kafka
在 spring cloud stream kafka binder 中有一些本机配置,例如 enableDlq,但是我没有找到任何示例来说明 enableDlq 是否正常工作时如何正确进行单元测试。有没有关于如何正确实施此类测试的示例?
【问题讨论】:
标签: spring-cloud spring-kafka dead-letter spring-cloud-stream-binder-kafka
binder 项目本身有一堆测试:
一般技术是使用单独的绑定绑定到 dlq,但您同样可以定义一个 KafkaConsumer 来使用它并验证它是否收到了您期望的消息。
【讨论】: