in src/main/java/org/apache/rocketmq/exporter/util/JsonUtil.java [102:112]
public static <T> T byte2Obj(byte[] bytes, Class<T> clazz) {
if (bytes == null || clazz == null) {
return null;
}
try {
return clazz.equals(byte[].class) ? (T) bytes : objectMapper.readValue(bytes, clazz);
} catch (Exception e) {
logger.error("Parse byte[] to Object error\nbyte[]: {}\nClass<T>: {}\nError: {}", bytes, clazz.getName(), e);
return null;
}
}