Блог

Я пытаюсь использовать JsonSchema вместе с реестром схемы. Это приводит к некоторой ошибке, связанной с кодом.

Кто-нибудь успешно пробовал 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

Эта проблема в основном возникает, когда вы пробуете разных производителей в одном проекте. В нашем сценарии мы запускали Avro producer и Json producer в одном проекте и по одному пути.

После удаления зависимостей Avro в файле сборки gradle производитель успешно выполнил. Кроме того, убедитесь, что все зависимости добавлены в maven / gradle.