diff --git a/spring-cloud-alibaba-starters/spring-cloud-starter-stream-rocketmq/src/main/java/com/alibaba/cloud/stream/binder/rocketmq/utils/RocketMQUtils.java b/spring-cloud-alibaba-starters/spring-cloud-starter-stream-rocketmq/src/main/java/com/alibaba/cloud/stream/binder/rocketmq/utils/RocketMQUtils.java index f61e86a3b..91cebaba2 100644 --- a/spring-cloud-alibaba-starters/spring-cloud-starter-stream-rocketmq/src/main/java/com/alibaba/cloud/stream/binder/rocketmq/utils/RocketMQUtils.java +++ b/spring-cloud-alibaba-starters/spring-cloud-starter-stream-rocketmq/src/main/java/com/alibaba/cloud/stream/binder/rocketmq/utils/RocketMQUtils.java @@ -77,10 +77,10 @@ public final class RocketMQUtils { if (null != rpcHook) { SessionCredentials sessionCredentials = ((AclClientRPCHook) rpcHook) .getSessionCredentials(); - instanceName.append(sessionCredentials.getAccessKey()).append(separator) - .append(sessionCredentials.getSecretKey()).append(separator); + instanceName.append(sessionCredentials.getAccessKey()).append(separator); } - instanceName.append(identify).append(separator).append(UtilAll.getPid()); + instanceName.append(identify).append(separator).append(UtilAll.getPid()) + .append(separator).append(Long.toString(System.nanoTime(), 36)); return instanceName.toString(); }