A Kafka Serde for turning Avro-generated classes into JSON objects (only does serialization)

JsonSerdeForAvroClasses.java

import com.fasterxml.jackson.annotation.JsonAutoDetect;
import com.fasterxml.jackson.databind.ObjectMapper;
import com.fasterxml.jackson.databind.node.ObjectNode;
import org.apache.kafka.streams.kstream.ValueMapper;

import java.nio.charset.Charset;

public class JsonSerdeForAvroClasses<T> {

    public static <T> JsonSerdeForAvroClasses<T> gen() {
        return new JsonSerdeForAvroClasses<>();
    }

    public JsonSerdeForAvroClasses() {}

    final static private ObjectMapper mapper = new ObjectMapper();
    static {
        mapper.setVisibility(mapper.getVisibilityChecker()
                .withFieldVisibility(JsonAutoDetect.Visibility.PUBLIC_ONLY)
                .withGetterVisibility(JsonAutoDetect.Visibility.NONE)
                .withSetterVisibility(JsonAutoDetect.Visibility.NONE)
                .withCreatorVisibility(JsonAutoDetect.Visibility.NONE));
    }

    final private ValueMapper<T, ObjectNode> jsonMapper = (v -> mapper.convertValue(v, ObjectNode.class));

    public SerdeFunction<T> serdeFunction() {
        return new SerdeFunction<>(t -> {

            try {
                return jsonMapper.apply(t).toString().getBytes(Charset.defaultCharset());
            } catch (Throwable e) {
                throw new RuntimeException("Failed to serialize", e);
            }

        }, b -> {
            throw new UnsupportedOperationException();
        });
    }
}