Я работаю над проблемой, когда я сопоставляю значения Avro из одного типа / схемы в другой (цель является подмножеством источника, но значения отображаются по разным путям).
Проблема в том, что я пытаюсь сделать это динамически, поэтому программа принимает аргументы.
В настоящее время я использую запись из Kafka, и тип SpecificRecordBase в schema x. Мне нужно как-то инициализировать другую SpecificRecordBase динамически, которая соответствует цели schema y. Как я мог go сделать это?
У меня есть pathmapper, который будет проходить и отображать значение из одного объекта в другой, но для этого требуется второй аргумент SpecificRecordBase.
Пример вызова:
Optional<SpecificRecordBase> mappedModel = this.mapper.mapSourceToTarget(incomingRecordSpecificRecordBase, targetSpecificRecordBase);