【发布时间】:2020-10-29 16:42:11
【问题描述】:
我有一个带有一些 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,它抱怨上述属性。
是否有必须设置的属性,或者之前有人遇到过这个问题并有解决方案?
谢谢!
【问题讨论】:
标签: java spring-boot spring-kafka confluent-schema-registry embedded-kafka