in core/src/main/java/org/apache/rocketmq/streams/core/util/Utils.java [55:74]
public static String buildKey(String key, String... args) {
if (StringUtils.isEmpty(key)) {
return null;
}
StringBuilder builder = new StringBuilder();
builder.append(key);
if (args == null || args.length == 0) {
return builder.toString();
}
builder.append(Constant.SPLIT);
for (String arg : args) {
builder.append(arg);
builder.append(Constant.SPLIT);
}
return builder.substring(0, builder.lastIndexOf(Constant.SPLIT));
}