|
|
@@ -1,6 +1,7 @@
|
|
|
package org.dromara.common.message.kafka.producer;
|
|
|
|
|
|
import cn.hutool.core.util.IdUtil;
|
|
|
+import cn.hutool.core.util.ObjectUtil;
|
|
|
import cn.hutool.json.JSONUtil;
|
|
|
import com.alibaba.fastjson2.JSON;
|
|
|
import lombok.RequiredArgsConstructor;
|
|
|
@@ -49,10 +50,11 @@ public class KafkaNormalProducer {
|
|
|
public void sendKafkaMessage(String topic, String eventType, String sender, Object data) {
|
|
|
KafkaMessage<Object> message = new KafkaMessage<>();
|
|
|
KafkaHeader header = message.getHeader();
|
|
|
- String tenantId = JSONUtil.parseObj(data).get("tenantId").toString();
|
|
|
header.setTimestamp(System.currentTimeMillis());
|
|
|
header.setEventId(IdUtil.simpleUUID());
|
|
|
- header.setTenantId(tenantId);
|
|
|
+ if(ObjectUtil.isNotEmpty(JSONUtil.parseObj(data).get("tenantId"))) {
|
|
|
+ header.setTenantId(JSONUtil.parseObj(data).get("tenantId").toString());
|
|
|
+ }
|
|
|
header.setEventType(eventType);
|
|
|
header.setSender(sender);
|
|
|
|