如何在Spring Cloud Stream中正确地单元测试dq

Question

在spring cloud stream kafka binder中有一些本地配置，如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来从它消费并验证它是否收到了您期望的消息。