微信公众号搜"智元新知"关注
微信扫一扫可直接关注哦!

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

如何解决为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.

在尝试构造使用者时出现错误。我正在将自定义KafkaAvroDeserializerMockSchemaRegistryClient结合使用,抱怨上面的属性

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

谢谢!

解决方法

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

版权声明:本文内容由互联网用户自发贡献,该文观点与技术仅代表作者本人。本站仅提供信息存储空间服务,不拥有所有权,不承担相关法律责任。如发现本站有涉嫌侵权/违法违规的内容, 请发送邮件至 dio@foxmail.com 举报,一经查实,本站将立刻删除。