Конвертировать JSON serde в Avro Serde

Question

У меня есть Java-класс pojo для сопоставления входящих данных с JavaObject, я относительно новичок в AVRO и его функциях.Я использую мультитенантный кластер Kafka, где они используют только AVRO.

Необходимо прочитать тему Кафки, затем выполнить сортировку, агрегации и т. Д. Мои Junits работают нормально

Приложение разработано и реализовано для чтения JSON, но теперь необходимо прочитать AVRO

Myтекущий Json Wrapper.

@Data
@JsonAutoDetect(fieldVisibility = Visibility.ANY, getterVisibility = Visibility.NONE, isGetterVisibility = Visibility.NONE, setterVisibility = Visibility.NONE)
public class nodeWrapper {
    protected final ObjectNode JSON;

    public nodeWrapper(ObjectNode json) {
        if (json == null) {
            throw new NullPointerException("no data in the object node");
        }
        this.JSON = json;
    }

    public void put(String fieldName, String value) {
        JSON.put(fieldName, value);
    }

    public void put(String fieldName, int v) {
        JSON.put(fieldName, v);
    }

    public void put(String fieldName, boolean v) {
        JSON.put(fieldName, v);
    }

    public void put(String fieldName, long v) {
        JSON.put(fieldName, v);
    }