优化

src/main/java/com/dragon/tj/portal/component/message/KafkaInitialConfiguration.java

@@ -14,6 +14,26 @@ public class KafkaInitialConfiguration {
 
     public static String sseTopic = "sseTopic";
 
+    /**
+    *
+     @Bean
+     public KafkaAdmin.NewTopics topics456() {
+     return new NewTopics(
+     TopicBuilder.name("defaultBoth")
+     .build(),
+     TopicBuilder.name("defaultPart")
+     .replicas(1)
+     .build(),
+     TopicBuilder.name("defaultRepl")
+     .partitions(3)
+     .build());
+     }
+
+     ————————————————
+     版权声明：本文为CSDN博主「Doker 多克」的原创文章，遵循CC 4.0 BY-SA版权协议，转载请附上原文出处链接及本声明。
+     原文链接：https://blog.csdn.net/leesinbad/article/details/129889030
+    *
+    */
     /**
      * 创建一个名为 sseTopic 的Topic并设置分区数为8，分区副本数为2
      */

src/main/java/com/dragon/tj/portal/controller/TestController.java

@@ -1,42 +0,0 @@
-package com.dragon.tj.portal.controller;
-
-
-import com.dragon.tj.portal.component.log.dto.SysLogDTO;
-import com.dragon.tj.portal.common.base.R;
-import com.dragon.tj.portal.component.log.annotation.SysLog;
-import com.dragon.tj.portal.component.redis.StringCacheUtil;
-import com.dragon.tj.portal.entity.Test;
-import com.dragon.tj.portal.service.TestService;
-import org.springframework.beans.factory.annotation.Autowired;
-import org.springframework.validation.annotation.Validated;
-import org.springframework.web.bind.annotation.RequestBody;
-import org.springframework.web.bind.annotation.RequestMapping;
-import org.springframework.web.bind.annotation.RestController;
-
-/**
- * <p>
- * 前端控制器
- * </p>
- *
- * @author huey
- * @since 2023-06-11
- */
-@RestController
-@RequestMapping("/test")
-public class TestController {
-
-    @Autowired
-    private TestService testService;
-
-    @Autowired
-    private StringCacheUtil stringCacheUtil;
-
-    @RequestMapping("/test1")
-    @SysLog("huey测试日志记录")
-    public R test1(@Validated @RequestBody SysLogDTO sysLogDTO) {
-        Test byId = testService.getById(1);
-        stringCacheUtil.set("huey", "huey-test");
-        return R.ok(byId.getContent());
-    }
-}
-

src/main/java/com/dragon/tj/portal/service/TestService.java

@@ -1,16 +0,0 @@
-package com.dragon.tj.portal.service;
-
-import com.dragon.tj.portal.entity.Test;
-import com.baomidou.mybatisplus.extension.service.IService;
-
-/**
- * <p>
- *  服务类
- * </p>
- *
- * @author huey
- * @since 2023-06-11
- */
-public interface TestService extends IService<Test> {
-
-}

src/main/java/com/dragon/tj/portal/service/impl/TestServiceImpl.java

@@ -1,20 +0,0 @@
-package com.dragon.tj.portal.service.impl;
-
-import com.dragon.tj.portal.entity.Test;
-import com.dragon.tj.portal.mapper.TestMapper;
-import com.dragon.tj.portal.service.TestService;
-import com.baomidou.mybatisplus.extension.service.impl.ServiceImpl;
-import org.springframework.stereotype.Service;
-
-/**
- * <p>
- *  服务实现类
- * </p>
- *
- * @author huey
- * @since 2023-06-11
- */
-@Service
-public class TestServiceImpl extends ServiceImpl<TestMapper, Test> implements TestService {
-
-}

src/main/resources/mapper/TestMapper.xml

@@ -1,5 +0,0 @@
-<?xml version="1.0" encoding="UTF-8"?>
-<!DOCTYPE mapper PUBLIC "-//mybatis.org//DTD Mapper 3.0//EN" "http://mybatis.org/dtd/mybatis-3-mapper.dtd">
-<mapper namespace="com.dragon.tj.portal.mapper.TestMapper">
-
-</mapper>