@Override
    public JsonNode deserialize(String topic, byte[] bytes) {
        if (bytes == null)
            return null;

        JsonNode data;
        try {
            data = objectMapper.readTree(bytes);
        } catch (Exception e) {
            throw new SerializationException(e);
        }

        return data;
    }
A constructor that additionally specifies some {@link DeserializationFeature}s
for the deserializer

@param deserializationFeatures the specified deserialization features
@param jsonNodeFactory the json node factory to use.
connect/json/src/main/java/org/apache/kafka/connect/json/JsonDeserializer.java