我正在尝试使用jsonschema和schema registry。它给出了一些与代码相关的bug。
有人试过jsonschema吗。
java.lang.NoSuchMethodError: io.confluent.kafka.serializers.subject.strategy.SubjectNameStrategy.subjectName(Ljava/lang/String;ZLio/confluent/kafka/schemaregistry/ParsedSchema;)Ljava/lang/String;
at io.confluent.kafka.serializers.AbstractKafkaSchemaSerDe.getSubjectName(AbstractKafkaSchemaSerDe.java:117)
at io.confluent.connect.json.JsonSchemaConverter$Serializer.serialize(JsonSchemaConverter.java:135)
at io.confluent.connect.json.JsonSchemaConverter.fromConnectData(JsonSchemaConverter.java:88)
at org.apache.kafka.connect.storage.Converter.fromConnectData(Converter.java:63)
at org.apache.kafka.connect.runtime.WorkerSourceTask.lambda$convertTransformedRecord$2(WorkerSourceTask.java:295)似乎有getsubjectname函数，但没有subjectname
1条答案
按热度按时间bkkx9g8r1#
当您在同一个项目中尝试不同的生产者时，这个问题通常会发生。在我们的场景中，我们在同一个项目和路径中运行avro producer和json producer。
删除gradle构建文件中的avro依赖项后，producer成功执行。另外，确保所有依赖项都添加到maven/gradle。