为Kafka schema.registry.ssl.engine.factory.class

问题描述

我有一个带有一些kafka提供程序/消费者和一些集成测试（使用嵌入式kafka）的spring boot应用程序。一切工作正常，直到我将Spring Boot版本从2.1.x提升到2.3（春季版本）并将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结合使用，抱怨上面的属性。

是否有必须设置的属性，或者有人曾经遇到过此问题并有解决方案？

谢谢！

解决方法

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