为 Kafka schema.registry.ssl.engine.factory.class 提供什么值

Question

我有一个 spring boot 应用程序，其中包含一些 kafka 提供者/消费者和一些集成测试（使用嵌入式 kafka）。一切正常，直到我将 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该抱怨上述财产。

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

谢谢！

Answer 1

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