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