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; +}