【发布时间】:2021-10-05 03:20:22
【问题描述】:
我是 Confluent Cloud 的新手,并使用 Confluent Kafka 集群的免费试用版进行部署。 我正在尝试使用可以映射 Schema 的经过身份验证的 Schema Registry 生成/使用来自 Kafka 主题的 JSON 消息。 我指的是官方文档https://docs.confluent.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"
【问题讨论】:
-
你找到解决办法了吗?
标签: json apache-kafka confluent-platform confluent-schema-registry jsonserializer