我是 Confluence Cloud 的新手,并使用 Confluence Kafka 集群的免费试用版来部署它。 我正在尝试使用经过身份验证的架构注册表(可以映射架构)生成/使用来自 Kafka 主题的 JSON 消息。 我指的是官方文档https://docs.confluence.io/platform/current/schema-registry/serdes-develop/serdes-json.html 但提到的 JSON 序列化器不起作用。 我的 SCALA 代码中出现以下错误:
Invalid value io.confluent.kafka.serializers.json.KafkaJsonSchemaSerializer for configuration value.serializer: Class io.confluent.kafka.serializers.json.KafkaJsonSchemaSerializer could not be found.
您能否告知我们此功能是否已被弃用或不再有效? 有人可以在这里指教吗?
这是我的确切 build.sbt :
name := "JsonProducer"
version := "0.1"
scalaVersion := "2.12.5"
resolvers += "confluent" at "https://packages.confluent.io/maven/" // https://mvnrepository.com/artifact/io.confluent/kafka-json-schema-serializer
libraryDependencies += "io.confluent" % "kafka-json-schema-serializer" % "6.2.0"
通过在 build.sbt 中添加这些依赖项解决了这个问题:
resolvers += "jitpack" at "https://jitpack.io"
libraryDependencies += "org.everit.json" % "org.everit.json.schema" % "1.5.1"
libraryDependencies += "io.confluent" % "kafka-json-schema-serializer" % "6.2.0"
你需要这种依赖
"io.confluent" % "kafka-json-schema-serializer" % "6.2.0"