为 Kafka 提供什么价值 schema.registry.ssl.engine.factory.class
What value to provide for the Kafka schema.registry.ssl.engine.factory.class
我有一个 spring 启动应用程序,其中包含一些 kafka providers/consumers 和一些集成测试(使用嵌入式 kafka)。一切正常,直到我将 spring 引导版本提升到 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.
尝试构造消费者时出现错误。我正在使用带有 MockSchemaRegistryClient
的自定义 KafkaAvroDeserializer
,它抱怨上述 属性.
是否有必须设置的 属性 或有人 运行 解决过这个问题并且有解决方案?
谢谢!
解决方案是将 kafka-avro-serializer
库的版本升级到 5.5.0。
我有一个 spring 启动应用程序,其中包含一些 kafka providers/consumers 和一些集成测试(使用嵌入式 kafka)。一切正常,直到我将 spring 引导版本提升到 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.
尝试构造消费者时出现错误。我正在使用带有 MockSchemaRegistryClient
的自定义 KafkaAvroDeserializer
,它抱怨上述 属性.
是否有必须设置的 属性 或有人 运行 解决过这个问题并且有解决方案?
谢谢!
解决方案是将 kafka-avro-serializer
库的版本升级到 5.5.0。