我有一个带有一些 kafka 提供者/消费者和一些集成测试(使用嵌入式 kafka)的 Spring Boot 应用程序。一切正常,直到我将 spring boot 版本提升到 2.3(从 2.1.x)和 spring-kafka 到 2.6.0。
现在我收到以下异常:io.confluent.common.config.ConfigException: Invalid value for configuration schema.registry.ssl.engine.factory.class: Class could not be found.
尝试构建消费者时出现错误。我正在使用一个KafkaAvroDeserializer
抱怨MockSchemaRegistryClient
上述属性的自定义。
是否有必须设置的属性,或者之前有人遇到过这个问题并有解决方案?
谢谢!