@Override
            public Object toConnect(final Schema schema, final JsonNode value) {
                if (value.isNumber()) return value.decimalValue();
                if (value.isBinary() || value.isTextual()) {
                    try {
                        return Decimal.toLogical(schema, value.binaryValue());
                    } catch (Exception e) {
                        throw new DataException("Invalid bytes for Decimal field", e);
                    }
                }

                throw new DataException("Invalid type for Decimal, underlying representation should be numeric or bytes but was " + value.getNodeType());
            }
Implementation of {@link Converter} and {@link HeaderConverter} that uses JSON to store schemas and objects. By
default this converter will serialize Connect keys, values, and headers with schemas, although this can be disabled with
the {@link JsonConverterConfig#SCHEMAS_ENABLE_CONFIG schemas.enable} configuration option.
<p>
This implementation currently does nothing with the topic names or header keys.
connect/json/src/main/java/org/apache/kafka/connect/json/JsonConverter.java