in src/main/java/com/aliyun/dts/subscribe/clients/common/BytesUtil.java [238:260]
public static String toString(byte[] bytes, String encoding) throws UnsupportedEncodingException {
if (bytes == null) {
return null;
}
if (bytes.length == 0) {
return "";
}
String realEncoding = UTF8_ENCODING;
if (isValidEncoding(encoding)) {
realEncoding = encoding;
}
try {
return new String(bytes, realEncoding);
} catch (UnsupportedEncodingException foo) {
String mappedEncoding = JDKCharsetMapper.getJDKECharset(realEncoding);
LOGGER.warn("get bytes from from using encoding {} failed, just try to use encoding {} again", realEncoding, mappedEncoding);
return new String(bytes, mappedEncoding);
}
}