|
|
@@ -1,6 +1,7 @@
|
|
|
package org.dromara.backstage.mq.dubbo;
|
|
|
|
|
|
import cn.hutool.core.lang.UUID;
|
|
|
+import cn.hutool.core.util.IdUtil;
|
|
|
import lombok.RequiredArgsConstructor;
|
|
|
import org.apache.commons.lang3.StringUtils;
|
|
|
import org.apache.dubbo.config.annotation.DubboService;
|
|
|
@@ -35,7 +36,7 @@ public class RemoteSyncToLocalByKafkaServiceImpl implements RemoteSyncToLocalByK
|
|
|
KafkaMessage<Object> message = new KafkaMessage<>();
|
|
|
KafkaHeader header = message.getHeader();
|
|
|
header.setTimestamp(System.currentTimeMillis());
|
|
|
- header.setEventId(UUID.randomUUID().toString());
|
|
|
+ header.setEventId(IdUtil.simpleUUID());
|
|
|
MessageBo.KafkaHeader dataHeader = data.getHeader();
|
|
|
header.setEventType(dataHeader.getEventType());
|
|
|
header.setSender(dataHeader.getSender());
|