connectors/rocketmq-connect-doris/src/main/java/org/apache/rocketmq/connect/doris/serialization/StringDeserializer.java [38:48]:
- - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - -
    public String deserialize(String topic, byte[] data) {
        try {
            if (data == null) {
                return null;
            } else {
                return new String(data, encoding);
            }
        } catch (UnsupportedEncodingException e) {
            throw new RuntimeException("Error when deserializing byte[] to string due to unsupported encoding " + encoding);
        }
    }
- - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - -



rocketmq-connect-runtime/src/main/java/org/apache/rocketmq/connect/runtime/serialization/StringDeserializer.java [38:48]:
- - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - -
    public String deserialize(String topic, byte[] data) {
        try {
            if (data == null) {
                return null;
            } else {
                return new String(data, encoding);
            }
        } catch (UnsupportedEncodingException e) {
            throw new RuntimeException("Error when deserializing byte[] to string due to unsupported encoding " + encoding);
        }
    }
- - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - -