我使用KafkaSink将结果传递给类似于.sinkTo(kafkaSink)的kafka。我正在尝试提出一个端到端的集成测试，并希望使用一个简单的接收器来进行测试。我遇到了CollectSink，在那里我可以将结果添加到列表中并进行匹配。但是，CollectSink是SinkFunction，我无法在.sinkTo中使用它，而addSink是它可以使用的地方。
我已经尝试过PrintSink，但我想再次读取保存的数据以进行一些匹配。
有人能帮助我如何添加测试水槽，以便它可以与.sinkTo一起使用吗？
提前感谢
您可以查看Immerok Cookbook的集成测试是如何组织的。https://www.docs.immerok.cloud/docs/cookbook/creating-dead-letter-queues-from-and-to-apache-kafka-with-apache-flink/这可能是一个很好的起点，因为它说明了如何使用多个接收器测试作业。
免责声明：我为Immerok 工作