如何在 Spring Cloud Stream 中正确地对 Dlq 进行单元测试

Question

spring 云流 kafka 活页夹中有一些本机配置，如 enableDlq，但我没有找到任何关于如何正确单元测试 enableDlq 是否正常工作的示例。有没有关于如何正确实施此类测试的示例？

Answer 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 来使用它并验证它是否收到了您期望的消息。