结构调整

This commit is contained in:
pengjie 2023-06-28 20:33:25 +08:00
parent 80331b6f51
commit 2894c0332d
2 changed files with 48 additions and 0 deletions

View File

@ -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 successtopic:{} partition:{} offset:{}", topic, partition, offset);
}
@Override
public void onError(ProducerRecord producerRecord, Exception exception) {
log.info("send fail : {}", exception.getMessage());
}
}

View File

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