5

我有一个带有一些 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上述属性的自定义。

是否有必须设置的属性,或者之前有人遇到过这个问题并有解决方案?

谢谢!

4

1 回答 1

12

解决方案是将kafka-avro-serializer库的版本升级到 5.5.0。

于 2020-10-30T11:51:26.973 回答