in core/src/main/java/org/apache/rocketmq/streams/core/util/Utils.java [112:128]
public static String toHexString(Object obj) {
try {
if (obj instanceof byte[]) {
return DigestUtils.md5Hex((byte[]) obj);
} else if (obj instanceof String) {
return DigestUtils.md5Hex((String) obj);
} else if (obj instanceof InputStream) {
return DigestUtils.md5Hex((InputStream) obj);
} else {
byte[] bytes = object2Byte(obj);
return DigestUtils.md5Hex(bytes);
}
} catch (Throwable t) {
throw new RStreamsException("object to HexString error, object=" + obj, t);
}
}