@Override
    public SchemaAndValue toConnectData(String topic, byte[] value) {
        try {
            return new SchemaAndValue(schema, deserializer.deserialize(topic, value));
        } catch (SerializationException e) {
            throw new DataException("Failed to deserialize " + typeName + ": ", e);
        }
    }
Create the converter.

@param typeName the displayable name of the type; may not be null
@param schema the optional schema to be used for all deserialized forms; may not be null
@param serializer the serializer; may not be null
@param deserializer the deserializer; may not be null
connect/runtime/src/main/java/org/apache/kafka/connect/converters/NumberConverter.java