From 2894c0332ddc3fd9ae7d9e65a1347f774ff28aa8 Mon Sep 17 00:00:00 2001
From: pengjie <17373303529@163.com>
Date: Wed, 28 Jun 2023 20:33:25 +0800
Subject: [PATCH] =?UTF-8?q?=E7=BB=93=E6=9E=84=E8=B0=83=E6=95=B4?=
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 8bit

---
 .../xmgl/handler/KafkaSendResultHandler.java  | 26 +++++++++++++++++++
 .../xmgl/modules/basicdata/dto/MenuHzDto.java | 22 ++++++++++++++++
 2 files changed, 48 insertions(+)
 create mode 100644 src/main/java/com/zhgd/xmgl/handler/KafkaSendResultHandler.java
 create mode 100644 src/main/java/com/zhgd/xmgl/modules/basicdata/dto/MenuHzDto.java

diff --git a/src/main/java/com/zhgd/xmgl/handler/KafkaSendResultHandler.java b/src/main/java/com/zhgd/xmgl/handler/KafkaSendResultHandler.java
new file mode 100644
index 0000000..3238990
--- /dev/null
+++ b/src/main/java/com/zhgd/xmgl/handler/KafkaSendResultHandler.java
@@ -0,0 +1,26 @@
+package com.zhgd.xmgl.handler;
+
+import lombok.extern.slf4j.Slf4j;
+import org.apache.kafka.clients.producer.ProducerRecord;
+import org.apache.kafka.clients.producer.RecordMetadata;
+import org.springframework.kafka.support.ProducerListener;
+import org.springframework.stereotype.Component;
+
+@Component
+@Slf4j
+public class KafkaSendResultHandler implements ProducerListener {
+
+    @Override
+    public void onSuccess(ProducerRecord producerRecord,
+                          RecordMetadata recordMetadata) {
+        String topic = recordMetadata.topic();
+        int partition = recordMetadata.partition();
+        long offset = recordMetadata.offset();
+        log.info("send success：topic:{} partition:{} offset:{}", topic, partition, offset);
+    }
+
+    @Override
+    public void onError(ProducerRecord producerRecord, Exception exception) {
+        log.info("send fail : {}", exception.getMessage());
+    }
+}
diff --git a/src/main/java/com/zhgd/xmgl/modules/basicdata/dto/MenuHzDto.java b/src/main/java/com/zhgd/xmgl/modules/basicdata/dto/MenuHzDto.java
new file mode 100644
index 0000000..c5739a3
--- /dev/null
+++ b/src/main/java/com/zhgd/xmgl/modules/basicdata/dto/MenuHzDto.java
@@ -0,0 +1,22 @@
+package com.zhgd.xmgl.modules.basicdata.dto;
+
+import io.swagger.annotations.ApiModel;
+import io.swagger.annotations.ApiModelProperty;
+import lombok.Data;
+
+@Data
+@ApiModel(value = "项目管理子系统信息(DTO)", description = "MenuHzDto")
+public class MenuHzDto {
+
+    @ApiModelProperty(value = "id")
+    private Long id;
+
+    @ApiModelProperty(value = "父ID")
+    private Long parentId;
+
+    @ApiModelProperty(value = "名称")
+    private String name;
+
+    @ApiModelProperty(value = "路由")
+    private String url;
+}