我有一个基于reactor的spring boot kafka流处理应用程序，我正在为它编写集成测试。我用的是Spring的 @EmbeddedKafka 经纪人。它工作得很好，我让它覆盖在我的React式处理器的使用者和发布者上配置的bootstrap broker url，但是我还没有弄清楚在测试时如何处理处理器的模式注册表。我用的是合流的 KafkaAvroSerializer 以及 KafkaAvroDeserializer 上课的时候 schema.registry.url 在我的spring应用程序中配置的字段配置为注入kafka属性。我用的是合流的 MockSchemaRegistryClient 对于测试生产者和生产者，但我需要的是一种方法，在我的流处理器代码中将这个模拟客户机注入到实际的消费者和生产者中，但是我看不到这样做的方法。似乎我需要一个更像架构注册表的嵌入式版本的东西来让他们喜欢嵌入式代理。我们的构建管道不支持旋转容器，否则我将使用docker或testcontainers。其他人已经解决了吗？感谢您的帮助或建议。