我正在尝试将JsonSchema与模式注册表一起使用。它提供了一些与代码相关的错误。 有没有人成功试用过JsonSchema。(Ljava/lang/String;ZLio/confluent/kafka/schemaregistry/ParsedSchema;)Ljava/lang/String;
at io.confluent.kafka.serializers.AbstractKafkaSchemaSerDe.getSubject
我有一个由KafkaConnect创建的注册表架构。我还试图以编程方式发布到与模式相关的Kafka主题(使用TopicRecordNameStrategy),使用与我的Java应用程序中的注册表中存在的模式定义完全相同的模式定义,用例是自动重新发布延迟的消息因此,通过使用已经存在的确切模式,我是如何抛出异常的:
"Schema being registered is incompatib