diff --git a/eventmesh-dashboard-console/pom.xml b/eventmesh-dashboard-console/pom.xml
index fa06c45..ddf6595 100644
--- a/eventmesh-dashboard-console/pom.xml
+++ b/eventmesh-dashboard-console/pom.xml
@@ -69,6 +69,20 @@
             <artifactId>mysql-connector-j</artifactId>
             <scope>runtime</scope>
         </dependency>
+
+        <dependency>
+            <groupId>org.springframework</groupId>
+            <artifactId>spring-aspects</artifactId>
+            <version>5.1.2.RELEASE</version>
+        </dependency>
+        <dependency>
+            <groupId>junit</groupId>
+            <artifactId>junit</artifactId>
+            <version>4.13.2</version>
+            <scope>test</scope>
+        </dependency>
+
+
     </dependencies>
 
 </project>
\ No newline at end of file
diff --git a/eventmesh-dashboard-console/src/main/java/org/apache/eventmesh/dashboard/console/EventMeshDashboardApplication.java b/eventmesh-dashboard-console/src/main/java/org/apache/eventmesh/dashboard/console/EventMeshDashboardApplication.java
index 79fc03d..117dd06 100644
--- a/eventmesh-dashboard-console/src/main/java/org/apache/eventmesh/dashboard/console/EventMeshDashboardApplication.java
+++ b/eventmesh-dashboard-console/src/main/java/org/apache/eventmesh/dashboard/console/EventMeshDashboardApplication.java
@@ -19,19 +19,21 @@
 
 import org.springframework.boot.SpringApplication;
 import org.springframework.boot.autoconfigure.SpringBootApplication;
-import org.springframework.context.annotation.ComponentScan;
-import org.springframework.scheduling.annotation.EnableScheduling;
+import org.springframework.transaction.annotation.EnableTransactionManagement;
 
 import lombok.extern.slf4j.Slf4j;
 
 @Slf4j
 @SpringBootApplication
-@EnableScheduling
-@ComponentScan({"org.apache.eventmesh.dashboard.service", "org.apache.eventmesh.dashboard.console"})
+@EnableTransactionManagement
 public class EventMeshDashboardApplication {
 
     public static void main(String[] args) {
-        SpringApplication.run(EventMeshDashboardApplication.class, args);
-        log.info("{} Successfully booted.", EventMeshDashboardApplication.class.getSimpleName());
+        try {
+            SpringApplication.run(EventMeshDashboardApplication.class, args);
+            log.info("{} Successfully booted.", EventMeshDashboardApplication.class.getSimpleName());
+        } catch (Exception e) {
+            log.error(e.getMessage(), e);
+        }
     }
 }
diff --git a/eventmesh-dashboard-console/src/main/java/org/apache/eventmesh/dashboard/console/annotation/EmLog.java b/eventmesh-dashboard-console/src/main/java/org/apache/eventmesh/dashboard/console/annotation/EmLog.java
new file mode 100644
index 0000000..efae3a5
--- /dev/null
+++ b/eventmesh-dashboard-console/src/main/java/org/apache/eventmesh/dashboard/console/annotation/EmLog.java
@@ -0,0 +1,33 @@
+/*
+ * Licensed to the Apache Software Foundation (ASF) under one or more
+ * contributor license agreements.  See the NOTICE file distributed with
+ * this work for additional information regarding copyright ownership.
+ * The ASF licenses this file to You under the Apache License, Version 2.0
+ * (the "License"); you may not use this file except in compliance with
+ * the License.  You may obtain a copy of the License at
+ *
+ *     http://www.apache.org/licenses/LICENSE-2.0
+ *
+ * Unless required by applicable law or agreed to in writing, software
+ * distributed under the License is distributed on an "AS IS" BASIS,
+ * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+ * See the License for the specific language governing permissions and
+ * limitations under the License.
+ */
+
+package org.apache.eventmesh.dashboard.console.annotation;
+
+import java.lang.annotation.ElementType;
+import java.lang.annotation.Retention;
+import java.lang.annotation.RetentionPolicy;
+import java.lang.annotation.Target;
+
+@Retention(RetentionPolicy.RUNTIME)
+@Target(ElementType.METHOD)
+public @interface EmLog {
+
+    String OprType() default "";
+
+    String OprTarget() default "";
+
+}
diff --git a/eventmesh-dashboard-console/src/main/java/org/apache/eventmesh/dashboard/console/entity/group/GroupEntity.java b/eventmesh-dashboard-console/src/main/java/org/apache/eventmesh/dashboard/console/entity/group/GroupEntity.java
new file mode 100644
index 0000000..c395bac
--- /dev/null
+++ b/eventmesh-dashboard-console/src/main/java/org/apache/eventmesh/dashboard/console/entity/group/GroupEntity.java
@@ -0,0 +1,50 @@
+/*
+ * Licensed to the Apache Software Foundation (ASF) under one or more
+ * contributor license agreements.  See the NOTICE file distributed with
+ * this work for additional information regarding copyright ownership.
+ * The ASF licenses this file to You under the Apache License, Version 2.0
+ * (the "License"); you may not use this file except in compliance with
+ * the License.  You may obtain a copy of the License at
+ *
+ *     http://www.apache.org/licenses/LICENSE-2.0
+ *
+ * Unless required by applicable law or agreed to in writing, software
+ * distributed under the License is distributed on an "AS IS" BASIS,
+ * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+ * See the License for the specific language governing permissions and
+ * limitations under the License.
+ */
+
+package org.apache.eventmesh.dashboard.console.entity.group;
+
+import java.sql.Timestamp;
+
+import lombok.AllArgsConstructor;
+import lombok.Data;
+import lombok.NoArgsConstructor;
+
+@NoArgsConstructor
+@AllArgsConstructor
+@Data
+public class GroupEntity {
+    private Long id;
+
+    private Long clusterId;
+
+    private String name;
+
+    private Integer memberCount;
+
+    private String members;
+
+    private Integer type;
+
+    private String state;
+
+    private Timestamp createTime;
+
+    private Timestamp updateTime;
+
+
+
+}
diff --git a/eventmesh-dashboard-console/src/main/java/org/apache/eventmesh/dashboard/console/entity/groupmember/GroupMemberEntity.java b/eventmesh-dashboard-console/src/main/java/org/apache/eventmesh/dashboard/console/entity/groupmember/GroupMemberEntity.java
new file mode 100644
index 0000000..dbadc1e
--- /dev/null
+++ b/eventmesh-dashboard-console/src/main/java/org/apache/eventmesh/dashboard/console/entity/groupmember/GroupMemberEntity.java
@@ -0,0 +1,47 @@
+/*
+ * Licensed to the Apache Software Foundation (ASF) under one or more
+ * contributor license agreements.  See the NOTICE file distributed with
+ * this work for additional information regarding copyright ownership.
+ * The ASF licenses this file to You under the Apache License, Version 2.0
+ * (the "License"); you may not use this file except in compliance with
+ * the License.  You may obtain a copy of the License at
+ *
+ *     http://www.apache.org/licenses/LICENSE-2.0
+ *
+ * Unless required by applicable law or agreed to in writing, software
+ * distributed under the License is distributed on an "AS IS" BASIS,
+ * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+ * See the License for the specific language governing permissions and
+ * limitations under the License.
+ */
+
+package org.apache.eventmesh.dashboard.console.entity.groupmember;
+
+import java.sql.Timestamp;
+
+import lombok.AllArgsConstructor;
+import lombok.Data;
+import lombok.NoArgsConstructor;
+
+@Data
+@NoArgsConstructor
+@AllArgsConstructor
+public class GroupMemberEntity {
+    private Long id;
+
+    private Long clusterId;
+
+    private String topicName;
+
+    private String groupName;
+
+    private String eventMeshUser;
+
+    private String state;
+
+    private Timestamp createTime;
+
+    private Timestamp updateTime;
+
+
+}
diff --git a/eventmesh-dashboard-console/src/main/java/org/apache/eventmesh/dashboard/console/entity/log/LogEntity.java b/eventmesh-dashboard-console/src/main/java/org/apache/eventmesh/dashboard/console/entity/log/LogEntity.java
new file mode 100644
index 0000000..ac7c30a
--- /dev/null
+++ b/eventmesh-dashboard-console/src/main/java/org/apache/eventmesh/dashboard/console/entity/log/LogEntity.java
@@ -0,0 +1,51 @@
+/*
+ * Licensed to the Apache Software Foundation (ASF) under one or more
+ * contributor license agreements.  See the NOTICE file distributed with
+ * this work for additional information regarding copyright ownership.
+ * The ASF licenses this file to You under the Apache License, Version 2.0
+ * (the "License"); you may not use this file except in compliance with
+ * the License.  You may obtain a copy of the License at
+ *
+ *     http://www.apache.org/licenses/LICENSE-2.0
+ *
+ * Unless required by applicable law or agreed to in writing, software
+ * distributed under the License is distributed on an "AS IS" BASIS,
+ * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+ * See the License for the specific language governing permissions and
+ * limitations under the License.
+ */
+
+package org.apache.eventmesh.dashboard.console.entity.log;
+
+import java.sql.Timestamp;
+
+import lombok.AllArgsConstructor;
+import lombok.Data;
+import lombok.NoArgsConstructor;
+
+@Data
+@NoArgsConstructor
+@AllArgsConstructor
+public class LogEntity {
+
+    private Long id;
+
+    private Long clusterId;
+
+    private String operationType;
+
+    private String targetType;
+
+    private Integer status;
+
+    private String content;
+
+    private Timestamp createTime;
+
+    private Timestamp endTime;
+
+    private String operationUser;
+
+    private String result;
+
+}
diff --git a/eventmesh-dashboard-console/src/main/java/org/apache/eventmesh/dashboard/console/entity/topic/TopicEntity.java b/eventmesh-dashboard-console/src/main/java/org/apache/eventmesh/dashboard/console/entity/topic/TopicEntity.java
new file mode 100644
index 0000000..6b4bd09
--- /dev/null
+++ b/eventmesh-dashboard-console/src/main/java/org/apache/eventmesh/dashboard/console/entity/topic/TopicEntity.java
@@ -0,0 +1,50 @@
+/*
+ * Licensed to the Apache Software Foundation (ASF) under one or more
+ * contributor license agreements.  See the NOTICE file distributed with
+ * this work for additional information regarding copyright ownership.
+ * The ASF licenses this file to You under the Apache License, Version 2.0
+ * (the "License"); you may not use this file except in compliance with
+ * the License.  You may obtain a copy of the License at
+ *
+ *     http://www.apache.org/licenses/LICENSE-2.0
+ *
+ * Unless required by applicable law or agreed to in writing, software
+ * distributed under the License is distributed on an "AS IS" BASIS,
+ * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+ * See the License for the specific language governing permissions and
+ * limitations under the License.
+ */
+
+package org.apache.eventmesh.dashboard.console.entity.topic;
+
+import java.sql.Timestamp;
+
+import lombok.AllArgsConstructor;
+import lombok.Data;
+import lombok.NoArgsConstructor;
+
+@Data
+@NoArgsConstructor
+@AllArgsConstructor
+public class TopicEntity {
+    private Long id;
+
+    private Long clusterId;
+
+    private String topicName;
+
+    private String runtimeId;
+
+    private String storageId;
+
+    private Long retentionMs;
+
+    private Integer type;
+
+    private String description;
+
+    private Timestamp createTime;
+
+    private Timestamp updateTime;
+
+}
diff --git a/eventmesh-dashboard-console/src/main/java/org/apache/eventmesh/dashboard/console/log/OprLog.java b/eventmesh-dashboard-console/src/main/java/org/apache/eventmesh/dashboard/console/log/OprLog.java
new file mode 100644
index 0000000..9df7e23
--- /dev/null
+++ b/eventmesh-dashboard-console/src/main/java/org/apache/eventmesh/dashboard/console/log/OprLog.java
@@ -0,0 +1,122 @@
+/*
+ * Licensed to the Apache Software Foundation (ASF) under one or more
+ * contributor license agreements.  See the NOTICE file distributed with
+ * this work for additional information regarding copyright ownership.
+ * The ASF licenses this file to You under the Apache License, Version 2.0
+ * (the "License"); you may not use this file except in compliance with
+ * the License.  You may obtain a copy of the License at
+ *
+ *     http://www.apache.org/licenses/LICENSE-2.0
+ *
+ * Unless required by applicable law or agreed to in writing, software
+ * distributed under the License is distributed on an "AS IS" BASIS,
+ * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+ * See the License for the specific language governing permissions and
+ * limitations under the License.
+ */
+
+package org.apache.eventmesh.dashboard.console.log;
+
+import org.apache.eventmesh.dashboard.console.annotation.EmLog;
+import org.apache.eventmesh.dashboard.console.entity.log.LogEntity;
+import org.apache.eventmesh.dashboard.console.service.log.LogService;
+
+import java.lang.reflect.Field;
+import java.lang.reflect.Method;
+import java.sql.Timestamp;
+import java.util.Objects;
+
+import org.aspectj.lang.ProceedingJoinPoint;
+import org.aspectj.lang.annotation.Around;
+import org.aspectj.lang.annotation.Aspect;
+import org.aspectj.lang.annotation.Pointcut;
+import org.aspectj.lang.reflect.MethodSignature;
+import org.springframework.beans.BeansException;
+import org.springframework.context.ApplicationContext;
+import org.springframework.context.ApplicationContextAware;
+import org.springframework.core.Ordered;
+import org.springframework.stereotype.Service;
+import org.springframework.util.ClassUtils;
+
+@Aspect
+@Service
+public class OprLog implements Ordered, ApplicationContextAware {
+
+    private int order = LOWEST_PRECEDENCE - 1000; // Specify the order of execution
+
+    private LogService logService;
+
+    private ApplicationContext applicationContext;
+
+
+    @Pointcut("within(org.apache.eventmesh.dashboard.console.service..*)")
+    public void pointCut() {
+    }
+
+
+    @Around("pointCut()")
+    public Object logStart(ProceedingJoinPoint joinPoint) throws Throwable {
+        if (Objects.isNull(this.logService)) {
+            this.logService = applicationContext.getBean(LogService.class);
+        }
+        EmLog declaredAnnotation = this.getTargetEmlog(joinPoint);
+        //Get the Emlog annotation on the method
+        if (Objects.isNull(declaredAnnotation)) {
+            return joinPoint.proceed();
+        }
+        LogEntity logEntity = this.productLoEntity(declaredAnnotation, joinPoint);
+        logService.addLog(logEntity);
+        logEntity.setEndTime(new Timestamp(System.currentTimeMillis()));
+        Object proceed = null;
+        try {
+            proceed = joinPoint.proceed();
+            logEntity.setStatus(2);
+            logEntity.setResult(Objects.isNull(proceed) ? "" : proceed.toString());
+            return proceed;
+        } catch (Throwable e) {
+            logEntity.setStatus(3);
+            throw new RuntimeException(e);
+        } finally {
+            logEntity.setResult(proceed.toString());
+            logService.updateLog(logEntity);
+        }
+
+
+    }
+
+    public LogEntity productLoEntity(EmLog declaredAnnotation, ProceedingJoinPoint joinPoint) throws NoSuchFieldException, IllegalAccessException {
+        LogEntity logEntity = new LogEntity();
+        Object[] args = joinPoint.getArgs();
+        Object model = args[0];
+        //Obtaining the Input Parameter of the Operation Method (Specified as the First)
+        Field clusterPhyId = model.getClass().getDeclaredField("clusterId");
+        clusterPhyId.setAccessible(true);
+        Long opClusterPhyId = (Long) clusterPhyId.get(model);
+        //The clusterId is obtained from the parameter object, and the operation is described as the object itself
+        logEntity.setClusterId(opClusterPhyId);
+        logEntity.setContent(model.toString());
+        logEntity.setOperationType(declaredAnnotation.OprType());
+        logEntity.setTargetType(declaredAnnotation.OprTarget());
+        logEntity.setStatus(1);
+        logEntity.setCreateTime(new Timestamp(System.currentTimeMillis()));
+        return logEntity;
+    }
+
+    public EmLog getTargetEmlog(ProceedingJoinPoint joinPoint) {
+        MethodSignature signature = (MethodSignature) joinPoint.getSignature();
+        Method method = signature.getMethod();
+        Method mostSpecificMethod = ClassUtils.getMostSpecificMethod(method, joinPoint.getTarget().getClass());
+        EmLog declaredAnnotation = mostSpecificMethod.getAnnotation(EmLog.class);
+        return declaredAnnotation;
+    }
+
+    @Override
+    public int getOrder() {
+        return order;
+    }
+
+    @Override
+    public void setApplicationContext(ApplicationContext applicationContext) throws BeansException {
+        this.applicationContext = applicationContext;
+    }
+}
diff --git a/eventmesh-dashboard-console/src/main/java/org/apache/eventmesh/dashboard/console/mapper/group/OprGroupMapper.java b/eventmesh-dashboard-console/src/main/java/org/apache/eventmesh/dashboard/console/mapper/group/OprGroupMapper.java
new file mode 100644
index 0000000..f1a91ed
--- /dev/null
+++ b/eventmesh-dashboard-console/src/main/java/org/apache/eventmesh/dashboard/console/mapper/group/OprGroupMapper.java
@@ -0,0 +1,73 @@
+/*
+ * Licensed to the Apache Software Foundation (ASF) under one or more
+ * contributor license agreements.  See the NOTICE file distributed with
+ * this work for additional information regarding copyright ownership.
+ * The ASF licenses this file to You under the Apache License, Version 2.0
+ * (the "License"); you may not use this file except in compliance with
+ * the License.  You may obtain a copy of the License at
+ *
+ *     http://www.apache.org/licenses/LICENSE-2.0
+ *
+ * Unless required by applicable law or agreed to in writing, software
+ * distributed under the License is distributed on an "AS IS" BASIS,
+ * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+ * See the License for the specific language governing permissions and
+ * limitations under the License.
+ */
+
+package org.apache.eventmesh.dashboard.console.mapper.group;
+
+import org.apache.eventmesh.dashboard.console.entity.group.GroupEntity;
+
+import org.apache.ibatis.annotations.Delete;
+import org.apache.ibatis.annotations.Insert;
+import org.apache.ibatis.annotations.Mapper;
+import org.apache.ibatis.annotations.Options;
+import org.apache.ibatis.annotations.Select;
+import org.apache.ibatis.annotations.Update;
+
+import java.util.List;
+
+/**
+ * operate Group mapper
+ **/
+@Mapper
+public interface OprGroupMapper {
+
+    @Insert("INSERT INTO `group` (cluster_id, name, member_count, members, type, state)"
+        + "VALUE (#{clusterId},#{name},#{memberCount},#{members},#{type},#{state}) "
+        + "on duplicate key update is_delete=0")
+    @Options(useGeneratedKeys = true, keyProperty = "id", keyColumn = "id")
+    void addGroup(GroupEntity groupEntity);
+
+    @Update("update `group`set member_count=#{memberCount},"
+        + "members=#{members},type=#{type},state=#{state} where id=#{id}")
+    @Options(useGeneratedKeys = true, keyProperty = "id", keyColumn = "id")
+    Integer updateGroup(GroupEntity groupEntity);
+
+    @Delete("update `group` set  is_delete=1 where id=#{id}")
+    @Options(useGeneratedKeys = true, keyProperty = "id", keyColumn = "id")
+    Integer deleteGroup(GroupEntity groupEntity);
+
+    @Select("select * from `group` where cluster_id=#{clusterId} and name=#{name} and is_delete=0")
+    GroupEntity selectGroupByUnique(GroupEntity groupEntity);
+
+    @Select("select * from `group` where id=#{id} and is_delete=0")
+    GroupEntity selectGroupById(GroupEntity groupEntity);
+
+    @Select("<script>"
+        + "select * from `group`"
+        + "<where>"
+        + "<if test='clusterId != null'>"
+        + "cluster_id=#{clusterId}"
+        + "</if>"
+        + "<if test='name != null'>"
+        + "and name like concat('%',#{name},'%')"
+        + "</if>"
+        + "and is_delete=0"
+        + "</where>"
+        + "</script>")
+    List<GroupEntity> selectGroup(GroupEntity groupEntity);
+
+
+}
diff --git a/eventmesh-dashboard-console/src/main/java/org/apache/eventmesh/dashboard/console/mapper/groupmember/OprGroupMemberMapper.java b/eventmesh-dashboard-console/src/main/java/org/apache/eventmesh/dashboard/console/mapper/groupmember/OprGroupMemberMapper.java
new file mode 100644
index 0000000..3179eff
--- /dev/null
+++ b/eventmesh-dashboard-console/src/main/java/org/apache/eventmesh/dashboard/console/mapper/groupmember/OprGroupMemberMapper.java
@@ -0,0 +1,81 @@
+/*
+ * Licensed to the Apache Software Foundation (ASF) under one or more
+ * contributor license agreements.  See the NOTICE file distributed with
+ * this work for additional information regarding copyright ownership.
+ * The ASF licenses this file to You under the Apache License, Version 2.0
+ * (the "License"); you may not use this file except in compliance with
+ * the License.  You may obtain a copy of the License at
+ *
+ *     http://www.apache.org/licenses/LICENSE-2.0
+ *
+ * Unless required by applicable law or agreed to in writing, software
+ * distributed under the License is distributed on an "AS IS" BASIS,
+ * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+ * See the License for the specific language governing permissions and
+ * limitations under the License.
+ */
+
+package org.apache.eventmesh.dashboard.console.mapper.groupmember;
+
+
+import org.apache.eventmesh.dashboard.console.entity.groupmember.GroupMemberEntity;
+
+import org.apache.ibatis.annotations.Delete;
+import org.apache.ibatis.annotations.Insert;
+import org.apache.ibatis.annotations.Mapper;
+import org.apache.ibatis.annotations.Options;
+import org.apache.ibatis.annotations.Select;
+import org.apache.ibatis.annotations.Update;
+
+import java.util.List;
+
+/**
+ * operate GroupMember mapper
+ **/
+
+@Mapper
+public interface OprGroupMemberMapper {
+
+    @Select("select * from group_member where cluster_id=#{clusterId} and is_delete=0")
+    List<GroupMemberEntity> getGroupByClusterId(GroupMemberEntity groupMemberEntity);
+
+    @Insert("insert into group_member (cluster_id, topic_name, group_name, eventmesh_user,state)"
+        + " VALUE (#{clusterId},#{topicName},#{groupName},#{eventMeshUser},#{state})"
+        + "on duplicate key update is_delete=0")
+    @Options(useGeneratedKeys = true, keyProperty = "id", keyColumn = "id")
+    void addGroupMember(GroupMemberEntity groupMemberEntity);
+
+    @Update("update group_member set state=#{state} where id=#{id}")
+    @Options(useGeneratedKeys = true, keyProperty = "id", keyColumn = "id")
+    void updateGroupMember(GroupMemberEntity groupMemberEntity);
+
+    @Delete("update group_member set is_delete=1 where id=#{id} ")
+    @Options(useGeneratedKeys = true, keyProperty = "id", keyColumn = "id")
+    GroupMemberEntity deleteGroupMember(GroupMemberEntity groupMemberEntity);
+
+    @Select("select * from group_member where cluster_id=#{clusterId} and group_name=#{groupName} and topic_name=#{topicName} and is_delete=0")
+    GroupMemberEntity selectGroupMemberByUnique(GroupMemberEntity groupMemberEntity);
+
+    @Select("select * from group_member where id=#{id} and is_delete=0")
+    GroupMemberEntity selectGroupMemberById(GroupMemberEntity groupMemberEntity);
+
+    @Select("<script>"
+        + "select * from group_member"
+        + "<where>"
+        + "<if test='clusterId != null'>"
+        + "cluster_id=#{clusterId}"
+        + "</if>"
+        + "<if test='groupName != null'>"
+        + "and group_name=#{groupName}"
+        + "</if>"
+        + "<if test='topicName != null'>"
+        + "and topic_name=#{topicName}"
+        + "</if>"
+        + "</where>"
+        + "and is_delete=0"
+        + "</script>")
+    List<GroupMemberEntity> selectMember(GroupMemberEntity groupMemberEntity);
+
+    @Update("update group_member set state=#{state} where topic_name=#{topicName}")
+    void updateMemberByTopic(GroupMemberEntity groupMemberEntity);
+}
\ No newline at end of file
diff --git a/eventmesh-dashboard-console/src/main/java/org/apache/eventmesh/dashboard/console/mapper/log/OprLogMapper.java b/eventmesh-dashboard-console/src/main/java/org/apache/eventmesh/dashboard/console/mapper/log/OprLogMapper.java
new file mode 100644
index 0000000..d6c96f7
--- /dev/null
+++ b/eventmesh-dashboard-console/src/main/java/org/apache/eventmesh/dashboard/console/mapper/log/OprLogMapper.java
@@ -0,0 +1,60 @@
+/*
+ * Licensed to the Apache Software Foundation (ASF) under one or more
+ * contributor license agreements.  See the NOTICE file distributed with
+ * this work for additional information regarding copyright ownership.
+ * The ASF licenses this file to You under the Apache License, Version 2.0
+ * (the "License"); you may not use this file except in compliance with
+ * the License.  You may obtain a copy of the License at
+ *
+ *     http://www.apache.org/licenses/LICENSE-2.0
+ *
+ * Unless required by applicable law or agreed to in writing, software
+ * distributed under the License is distributed on an "AS IS" BASIS,
+ * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+ * See the License for the specific language governing permissions and
+ * limitations under the License.
+ */
+
+package org.apache.eventmesh.dashboard.console.mapper.log;
+
+import org.apache.eventmesh.dashboard.console.entity.log.LogEntity;
+
+import org.apache.ibatis.annotations.Insert;
+import org.apache.ibatis.annotations.Mapper;
+import org.apache.ibatis.annotations.Select;
+import org.apache.ibatis.annotations.SelectKey;
+import org.apache.ibatis.annotations.Update;
+
+import java.util.List;
+
+/**
+ * operate operationLog mapper
+ **/
+@Mapper
+public interface OprLogMapper {
+
+    @Select("<script>"
+        + "select * from operation_log"
+        + "<where>"
+        + "<if test='targetType!=null'>"
+        + "target_type=#{targetType}"
+        + "</if>"
+        + "<if test='operationUser!=null'>"
+        + "and operation_user=#{operationUser}"
+        + "</if>"
+        + "<if test='clusterId!=null'>"
+        + "and cluster_id=#{clusterId} "
+        + "</if>"
+        + "and is_delete=0"
+        + "</where>"
+        + "</script>")
+    List<LogEntity> getLogList(LogEntity logEntity);
+
+    @Insert("insert into operation_log ( cluster_id, operation_type,target_Type, description,operation_user,result_content)"
+        + "VALUE (#{clusterId},#{operationType},#{targetType},#{description},#{operationUser},#{resultContent})")
+    @SelectKey(keyColumn = "id", statement = {" select last_insert_id()"}, keyProperty = "id", before = false, resultType = Long.class)
+    Long addLog(LogEntity logEntity);
+
+    @Update("update operation_log set status=#{status} ,result_content=#{resultContent} where id=#{id}")
+    Integer updateLog(LogEntity logEntity);
+}
diff --git a/eventmesh-dashboard-console/src/main/java/org/apache/eventmesh/dashboard/console/mapper/topic/TopicMapper.java b/eventmesh-dashboard-console/src/main/java/org/apache/eventmesh/dashboard/console/mapper/topic/TopicMapper.java
new file mode 100644
index 0000000..8a396be
--- /dev/null
+++ b/eventmesh-dashboard-console/src/main/java/org/apache/eventmesh/dashboard/console/mapper/topic/TopicMapper.java
@@ -0,0 +1,70 @@
+/*
+ * Licensed to the Apache Software Foundation (ASF) under one or more
+ * contributor license agreements.  See the NOTICE file distributed with
+ * this work for additional information regarding copyright ownership.
+ * The ASF licenses this file to You under the Apache License, Version 2.0
+ * (the "License"); you may not use this file except in compliance with
+ * the License.  You may obtain a copy of the License at
+ *
+ *     http://www.apache.org/licenses/LICENSE-2.0
+ *
+ * Unless required by applicable law or agreed to in writing, software
+ * distributed under the License is distributed on an "AS IS" BASIS,
+ * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+ * See the License for the specific language governing permissions and
+ * limitations under the License.
+ */
+
+package org.apache.eventmesh.dashboard.console.mapper.topic;
+
+
+import org.apache.eventmesh.dashboard.console.entity.topic.TopicEntity;
+
+import org.apache.ibatis.annotations.Delete;
+import org.apache.ibatis.annotations.Insert;
+import org.apache.ibatis.annotations.Mapper;
+import org.apache.ibatis.annotations.Options;
+import org.apache.ibatis.annotations.Select;
+import org.apache.ibatis.annotations.Update;
+
+import java.util.List;
+
+/**
+ * operate Topic mapper
+ **/
+@Mapper
+public interface TopicMapper {
+
+    @Select("<script>"
+        + "select * from topic"
+        + "<where>"
+        + "<if test='topicName!=null'>"
+        + "and topic_name=#{topicName}"
+        + "</if>"
+        + "<if test='clusterId!=null'>"
+        + "and cluster_id=#{clusterId} "
+        + "</if>"
+        + "and is_delete=0"
+        + "</where>"
+        + "</script>")
+    List<TopicEntity> getTopicList(TopicEntity topicEntity);
+
+    @Insert("INSERT INTO topic (cluster_id, topic_name, runtime_id, storage_id, retention_ms, type, description) "
+        + "VALUE (#{clusterId},#{topicName},#{runtimeId},#{storageId},#{retentionMs},#{type},#{description})"
+        + "on duplicate key update is_delete = 0")
+    @Options(useGeneratedKeys = true, keyProperty = "id", keyColumn = "id")
+    void addTopic(TopicEntity topicEntity);
+
+    @Update("update topic set type=#{type},description=#{description} where id=#{id}")
+    void updateTopic(TopicEntity topicEntity);
+
+    @Delete("update `topic` set is_delete=1 where id=#{id}")
+    void deleteTopic(TopicEntity topicEntity);
+
+    @Select("select * from topic where cluster_id=#{clusterId} and topic_name=#{topicName}")
+    TopicEntity selectTopicByUnique(TopicEntity topicEntity);
+
+    @Select("select * from topic where id=#{id}")
+    TopicEntity selectTopicById(TopicEntity topicEntity);
+
+}
\ No newline at end of file
diff --git a/eventmesh-dashboard-console/src/main/java/org/apache/eventmesh/dashboard/console/service/group/GroupService.java b/eventmesh-dashboard-console/src/main/java/org/apache/eventmesh/dashboard/console/service/group/GroupService.java
new file mode 100644
index 0000000..e5a80c5
--- /dev/null
+++ b/eventmesh-dashboard-console/src/main/java/org/apache/eventmesh/dashboard/console/service/group/GroupService.java
@@ -0,0 +1,45 @@
+/*
+ * Licensed to the Apache Software Foundation (ASF) under one or more
+ * contributor license agreements.  See the NOTICE file distributed with
+ * this work for additional information regarding copyright ownership.
+ * The ASF licenses this file to You under the Apache License, Version 2.0
+ * (the "License"); you may not use this file except in compliance with
+ * the License.  You may obtain a copy of the License at
+ *
+ *     http://www.apache.org/licenses/LICENSE-2.0
+ *
+ * Unless required by applicable law or agreed to in writing, software
+ * distributed under the License is distributed on an "AS IS" BASIS,
+ * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+ * See the License for the specific language governing permissions and
+ * limitations under the License.
+ */
+
+package org.apache.eventmesh.dashboard.console.service.group;
+
+import org.apache.eventmesh.dashboard.console.entity.group.GroupEntity;
+import org.apache.eventmesh.dashboard.console.entity.groupmember.GroupMemberEntity;
+
+
+import java.util.List;
+
+/**
+ * operate Group Service
+ */
+
+public interface GroupService {
+
+    List<GroupEntity> getGroupByClusterId(GroupEntity groupEntity);
+
+    GroupEntity addGroup(GroupEntity groupEntity);
+
+    void updateGroup(GroupEntity groupEntity);
+
+    Integer deleteGroup(GroupEntity groupEntity);
+
+    GroupEntity selectGroup(GroupEntity groupEntity);
+
+    Integer insertMemberToGroup(GroupMemberEntity groupMemberEntity);
+
+    Integer deleteMemberFromGroup(GroupMemberEntity groupMemberEntity);
+}
diff --git a/eventmesh-dashboard-console/src/main/java/org/apache/eventmesh/dashboard/console/service/group/GroupServiceImpl.java b/eventmesh-dashboard-console/src/main/java/org/apache/eventmesh/dashboard/console/service/group/GroupServiceImpl.java
new file mode 100644
index 0000000..3647a5a
--- /dev/null
+++ b/eventmesh-dashboard-console/src/main/java/org/apache/eventmesh/dashboard/console/service/group/GroupServiceImpl.java
@@ -0,0 +1,103 @@
+/*
+ * Licensed to the Apache Software Foundation (ASF) under one or more
+ * contributor license agreements.  See the NOTICE file distributed with
+ * this work for additional information regarding copyright ownership.
+ * The ASF licenses this file to You under the Apache License, Version 2.0
+ * (the "License"); you may not use this file except in compliance with
+ * the License.  You may obtain a copy of the License at
+ *
+ *     http://www.apache.org/licenses/LICENSE-2.0
+ *
+ * Unless required by applicable law or agreed to in writing, software
+ * distributed under the License is distributed on an "AS IS" BASIS,
+ * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+ * See the License for the specific language governing permissions and
+ * limitations under the License.
+ */
+
+package org.apache.eventmesh.dashboard.console.service.group;
+
+import org.apache.eventmesh.dashboard.console.annotation.EmLog;
+import org.apache.eventmesh.dashboard.console.entity.group.GroupEntity;
+import org.apache.eventmesh.dashboard.console.entity.groupmember.GroupMemberEntity;
+import org.apache.eventmesh.dashboard.console.mapper.group.OprGroupMapper;
+import org.apache.eventmesh.dashboard.console.service.groupmember.GroupMemberService;
+
+import java.sql.Timestamp;
+import java.util.List;
+
+import org.springframework.beans.factory.annotation.Autowired;
+import org.springframework.stereotype.Service;
+
+@Service
+public class GroupServiceImpl implements GroupService {
+
+    @Autowired
+    OprGroupMapper oprGroupMapper;
+
+    @Autowired
+    GroupMemberService groupMemberService;
+
+    @EmLog(OprType = "search", OprTarget = "Group")
+    @Override
+    public List<GroupEntity> getGroupByClusterId(GroupEntity groupEntity) {
+        return oprGroupMapper.selectGroup(groupEntity);
+
+    }
+
+    @EmLog(OprType = "add", OprTarget = "Group")
+    @Override
+    public GroupEntity addGroup(GroupEntity groupEntity) {
+        oprGroupMapper.addGroup(groupEntity);
+        return groupEntity;
+    }
+
+    @Override
+    public void updateGroup(GroupEntity groupEntity) {
+        oprGroupMapper.updateGroup(groupEntity);
+    }
+
+    @Override
+    public Integer deleteGroup(GroupEntity groupEntity) {
+        return oprGroupMapper.deleteGroup(groupEntity);
+    }
+
+    @Override
+    public GroupEntity selectGroup(GroupEntity groupEntity) {
+        return oprGroupMapper.selectGroupById(groupEntity);
+    }
+
+    @Override
+    public Integer insertMemberToGroup(GroupMemberEntity groupMemberEntity) {
+        groupMemberService.addGroupMember(groupMemberEntity);
+        GroupEntity groupEntity = new GroupEntity();
+        groupEntity.setName(groupMemberEntity.getGroupName());
+        groupEntity.setClusterId(groupMemberEntity.getClusterId());
+        GroupEntity groupEntity1 = oprGroupMapper.selectGroupByUnique(groupEntity);
+        //^Obtain the group to which the member belongs
+        groupEntity1.setMembers(groupMemberEntity.getId() + "" + "," + groupEntity1.getMembers());
+        //Concatenate the members of the group
+        groupEntity1.setMemberCount(groupEntity1.getMemberCount() + 1);
+        groupEntity1.setUpdateTime(new Timestamp(System.currentTimeMillis()));
+        oprGroupMapper.updateGroup(groupEntity1);
+        return 1;
+        //Modify the group member information
+    }
+
+    @Override
+    public Integer deleteMemberFromGroup(GroupMemberEntity groupMemberEntity) {
+        groupMemberService.deleteGroupMember(groupMemberEntity);
+        GroupEntity groupEntity = new GroupEntity();
+        groupEntity.setName(groupMemberEntity.getGroupName());
+        groupEntity.setClusterId(groupMemberEntity.getClusterId());
+        GroupEntity groupEntity1 = oprGroupMapper.selectGroupByUnique(groupEntity);
+        //^Obtain the group to which the member belongs
+        groupEntity1.setMembers(groupEntity1.getMembers().replaceAll(groupMemberEntity.getId() + "" + ",", ""));
+        groupEntity1.setMemberCount(groupEntity1.getMemberCount() - 1);
+        groupEntity1.setUpdateTime(new Timestamp(System.currentTimeMillis()));
+        oprGroupMapper.updateGroup(groupEntity1);
+        return 1;
+    }
+
+
+}
diff --git a/eventmesh-dashboard-console/src/main/java/org/apache/eventmesh/dashboard/console/service/groupmember/GroupMemberService.java b/eventmesh-dashboard-console/src/main/java/org/apache/eventmesh/dashboard/console/service/groupmember/GroupMemberService.java
new file mode 100644
index 0000000..28f9516
--- /dev/null
+++ b/eventmesh-dashboard-console/src/main/java/org/apache/eventmesh/dashboard/console/service/groupmember/GroupMemberService.java
@@ -0,0 +1,44 @@
+/*
+ * Licensed to the Apache Software Foundation (ASF) under one or more
+ * contributor license agreements.  See the NOTICE file distributed with
+ * this work for additional information regarding copyright ownership.
+ * The ASF licenses this file to You under the Apache License, Version 2.0
+ * (the "License"); you may not use this file except in compliance with
+ * the License.  You may obtain a copy of the License at
+ *
+ *     http://www.apache.org/licenses/LICENSE-2.0
+ *
+ * Unless required by applicable law or agreed to in writing, software
+ * distributed under the License is distributed on an "AS IS" BASIS,
+ * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+ * See the License for the specific language governing permissions and
+ * limitations under the License.
+ */
+
+package org.apache.eventmesh.dashboard.console.service.groupmember;
+
+import org.apache.eventmesh.dashboard.console.entity.group.GroupEntity;
+import org.apache.eventmesh.dashboard.console.entity.groupmember.GroupMemberEntity;
+
+import java.util.List;
+
+/**
+ * Service About GroupMember
+ */
+public interface GroupMemberService {
+
+    List<GroupMemberEntity> getGroupMemberByClusterId(GroupMemberEntity groupMemberEntity);
+
+    void addGroupMember(GroupMemberEntity groupMemberEntity);
+
+    void updateGroupMember(GroupMemberEntity groupMemberEntity);
+
+    GroupMemberEntity deleteGroupMember(GroupMemberEntity groupMemberEntity);
+
+    GroupMemberEntity selectGroupMemberById(GroupMemberEntity groupMemberEntity);
+
+    List<GroupMemberEntity> selectGroupMemberByGroup(GroupEntity groupEntity);
+
+    List<GroupMemberEntity> selectAllMemberByTopic(GroupMemberEntity groupMemberEntity);
+
+}
diff --git a/eventmesh-dashboard-console/src/main/java/org/apache/eventmesh/dashboard/console/service/groupmember/GroupMemberServiceImp.java b/eventmesh-dashboard-console/src/main/java/org/apache/eventmesh/dashboard/console/service/groupmember/GroupMemberServiceImp.java
new file mode 100644
index 0000000..d50173e
--- /dev/null
+++ b/eventmesh-dashboard-console/src/main/java/org/apache/eventmesh/dashboard/console/service/groupmember/GroupMemberServiceImp.java
@@ -0,0 +1,78 @@
+/*
+ * Licensed to the Apache Software Foundation (ASF) under one or more
+ * contributor license agreements.  See the NOTICE file distributed with
+ * this work for additional information regarding copyright ownership.
+ * The ASF licenses this file to You under the Apache License, Version 2.0
+ * (the "License"); you may not use this file except in compliance with
+ * the License.  You may obtain a copy of the License at
+ *
+ *     http://www.apache.org/licenses/LICENSE-2.0
+ *
+ * Unless required by applicable law or agreed to in writing, software
+ * distributed under the License is distributed on an "AS IS" BASIS,
+ * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+ * See the License for the specific language governing permissions and
+ * limitations under the License.
+ */
+
+package org.apache.eventmesh.dashboard.console.service.groupmember;
+
+import org.apache.eventmesh.dashboard.console.annotation.EmLog;
+import org.apache.eventmesh.dashboard.console.entity.group.GroupEntity;
+import org.apache.eventmesh.dashboard.console.entity.groupmember.GroupMemberEntity;
+import org.apache.eventmesh.dashboard.console.mapper.groupmember.OprGroupMemberMapper;
+
+import java.util.List;
+
+import org.springframework.beans.factory.annotation.Autowired;
+import org.springframework.stereotype.Service;
+
+@Service
+public class GroupMemberServiceImp implements GroupMemberService {
+
+    @Autowired
+    OprGroupMemberMapper oprGroupMemberMapper;
+
+    @Override
+    @EmLog(OprType = "View", OprTarget = "GroupMember")
+    public List<GroupMemberEntity> getGroupMemberByClusterId(GroupMemberEntity groupMemberEntity) {
+        return oprGroupMemberMapper.getGroupByClusterId(groupMemberEntity);
+    }
+
+    @Override
+    @EmLog(OprType = "add", OprTarget = "GroupMember")
+    public void addGroupMember(GroupMemberEntity groupMemberEntity) {
+        oprGroupMemberMapper.addGroupMember(groupMemberEntity);
+    }
+
+    @Override
+    public void updateGroupMember(GroupMemberEntity groupMemberEntity) {
+        oprGroupMemberMapper.updateGroupMember(groupMemberEntity);
+    }
+
+    @Override
+    public GroupMemberEntity deleteGroupMember(GroupMemberEntity groupMemberEntity) {
+        return oprGroupMemberMapper.deleteGroupMember(groupMemberEntity);
+    }
+
+    @Override
+    public GroupMemberEntity selectGroupMemberById(GroupMemberEntity groupMemberEntity) {
+        return oprGroupMemberMapper.selectGroupMemberById(groupMemberEntity);
+    }
+
+    @Override
+    public List<GroupMemberEntity> selectGroupMemberByGroup(GroupEntity groupEntity) {
+        GroupMemberEntity groupMemberEntity = new GroupMemberEntity();
+        groupMemberEntity.setGroupName(groupEntity.getName());
+        groupMemberEntity.setClusterId(groupEntity.getClusterId());
+        //Obtain a member who meets the conditions of a group
+        return oprGroupMemberMapper.selectMember(groupMemberEntity);
+    }
+
+    @Override
+    public List<GroupMemberEntity> selectAllMemberByTopic(GroupMemberEntity groupMemberEntity) {
+        List<GroupMemberEntity> groupMemberEntities = oprGroupMemberMapper.selectMember(groupMemberEntity);
+        return groupMemberEntities;
+    }
+
+}
diff --git a/eventmesh-dashboard-console/src/main/java/org/apache/eventmesh/dashboard/console/service/log/LogService.java b/eventmesh-dashboard-console/src/main/java/org/apache/eventmesh/dashboard/console/service/log/LogService.java
new file mode 100644
index 0000000..d496ae6
--- /dev/null
+++ b/eventmesh-dashboard-console/src/main/java/org/apache/eventmesh/dashboard/console/service/log/LogService.java
@@ -0,0 +1,38 @@
+/*
+ * Licensed to the Apache Software Foundation (ASF) under one or more
+ * contributor license agreements.  See the NOTICE file distributed with
+ * this work for additional information regarding copyright ownership.
+ * The ASF licenses this file to You under the Apache License, Version 2.0
+ * (the "License"); you may not use this file except in compliance with
+ * the License.  You may obtain a copy of the License at
+ *
+ *     http://www.apache.org/licenses/LICENSE-2.0
+ *
+ * Unless required by applicable law or agreed to in writing, software
+ * distributed under the License is distributed on an "AS IS" BASIS,
+ * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+ * See the License for the specific language governing permissions and
+ * limitations under the License.
+ */
+
+package org.apache.eventmesh.dashboard.console.service.log;
+
+import org.apache.eventmesh.dashboard.console.entity.log.LogEntity;
+
+import java.util.List;
+
+/**
+ *
+ * operation service
+ *
+ */
+
+public interface LogService {
+
+    List<LogEntity> getLogListByCluster(LogEntity logEntity);
+
+    Long addLog(LogEntity logEntity);
+
+    Integer updateLog(LogEntity logEntity);
+
+}
diff --git a/eventmesh-dashboard-console/src/main/java/org/apache/eventmesh/dashboard/console/service/log/LogServiceImpl.java b/eventmesh-dashboard-console/src/main/java/org/apache/eventmesh/dashboard/console/service/log/LogServiceImpl.java
new file mode 100644
index 0000000..7bd680b
--- /dev/null
+++ b/eventmesh-dashboard-console/src/main/java/org/apache/eventmesh/dashboard/console/service/log/LogServiceImpl.java
@@ -0,0 +1,51 @@
+/*
+ * Licensed to the Apache Software Foundation (ASF) under one or more
+ * contributor license agreements.  See the NOTICE file distributed with
+ * this work for additional information regarding copyright ownership.
+ * The ASF licenses this file to You under the Apache License, Version 2.0
+ * (the "License"); you may not use this file except in compliance with
+ * the License.  You may obtain a copy of the License at
+ *
+ *     http://www.apache.org/licenses/LICENSE-2.0
+ *
+ * Unless required by applicable law or agreed to in writing, software
+ * distributed under the License is distributed on an "AS IS" BASIS,
+ * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+ * See the License for the specific language governing permissions and
+ * limitations under the License.
+ */
+
+package org.apache.eventmesh.dashboard.console.service.log;
+
+import org.apache.eventmesh.dashboard.console.entity.log.LogEntity;
+import org.apache.eventmesh.dashboard.console.mapper.log.OprLogMapper;
+
+import java.util.List;
+
+import org.springframework.beans.factory.annotation.Autowired;
+import org.springframework.stereotype.Service;
+
+@Service
+public class LogServiceImpl implements LogService {
+
+    @Autowired
+    OprLogMapper oprLogMapper;
+
+    @Override
+    public List<LogEntity> getLogListByCluster(LogEntity logEntity) {
+
+        return oprLogMapper.getLogList(logEntity);
+    }
+
+    @Override
+    public Long addLog(LogEntity logEntity) {
+
+        return oprLogMapper.addLog(logEntity);
+    }
+
+    @Override
+    public Integer updateLog(LogEntity logEntity) {
+
+        return oprLogMapper.updateLog(logEntity);
+    }
+}
diff --git a/eventmesh-dashboard-console/src/main/java/org/apache/eventmesh/dashboard/console/service/topic/TopicService.java b/eventmesh-dashboard-console/src/main/java/org/apache/eventmesh/dashboard/console/service/topic/TopicService.java
new file mode 100644
index 0000000..95c8a32
--- /dev/null
+++ b/eventmesh-dashboard-console/src/main/java/org/apache/eventmesh/dashboard/console/service/topic/TopicService.java
@@ -0,0 +1,41 @@
+/*
+ * Licensed to the Apache Software Foundation (ASF) under one or more
+ * contributor license agreements.  See the NOTICE file distributed with
+ * this work for additional information regarding copyright ownership.
+ * The ASF licenses this file to You under the Apache License, Version 2.0
+ * (the "License"); you may not use this file except in compliance with
+ * the License.  You may obtain a copy of the License at
+ *
+ *     http://www.apache.org/licenses/LICENSE-2.0
+ *
+ * Unless required by applicable law or agreed to in writing, software
+ * distributed under the License is distributed on an "AS IS" BASIS,
+ * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+ * See the License for the specific language governing permissions and
+ * limitations under the License.
+ */
+
+package org.apache.eventmesh.dashboard.console.service.topic;
+
+import org.apache.eventmesh.dashboard.console.entity.topic.TopicEntity;
+
+import java.util.List;
+
+/**
+ * Service about Topic
+ */
+public interface TopicService {
+    List<TopicEntity> getTopicList(TopicEntity topicEntity);
+
+    void addTopic_plus(TopicEntity topicEntity);
+
+    void updateTopic(TopicEntity topicEntity);
+
+    void deleteTopicById(TopicEntity topicEntity);
+
+    TopicEntity selectTopicById(TopicEntity topicEntity);
+
+    TopicEntity selectTopicByUnique(TopicEntity topicEntity);
+
+    void deleteTopic(TopicEntity topicEntity);
+}
diff --git a/eventmesh-dashboard-console/src/main/java/org/apache/eventmesh/dashboard/console/service/topic/TopicServiceImpl.java b/eventmesh-dashboard-console/src/main/java/org/apache/eventmesh/dashboard/console/service/topic/TopicServiceImpl.java
new file mode 100644
index 0000000..aa42e7b
--- /dev/null
+++ b/eventmesh-dashboard-console/src/main/java/org/apache/eventmesh/dashboard/console/service/topic/TopicServiceImpl.java
@@ -0,0 +1,82 @@
+/*
+ * Licensed to the Apache Software Foundation (ASF) under one or more
+ * contributor license agreements.  See the NOTICE file distributed with
+ * this work for additional information regarding copyright ownership.
+ * The ASF licenses this file to You under the Apache License, Version 2.0
+ * (the "License"); you may not use this file except in compliance with
+ * the License.  You may obtain a copy of the License at
+ *
+ *     http://www.apache.org/licenses/LICENSE-2.0
+ *
+ * Unless required by applicable law or agreed to in writing, software
+ * distributed under the License is distributed on an "AS IS" BASIS,
+ * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+ * See the License for the specific language governing permissions and
+ * limitations under the License.
+ */
+
+package org.apache.eventmesh.dashboard.console.service.topic;
+
+import org.apache.eventmesh.dashboard.console.entity.groupmember.GroupMemberEntity;
+import org.apache.eventmesh.dashboard.console.entity.topic.TopicEntity;
+import org.apache.eventmesh.dashboard.console.mapper.groupmember.OprGroupMemberMapper;
+import org.apache.eventmesh.dashboard.console.mapper.topic.TopicMapper;
+
+import java.util.List;
+
+import org.springframework.beans.factory.annotation.Autowired;
+import org.springframework.stereotype.Service;
+
+@Service
+public class TopicServiceImpl implements TopicService {
+
+    @Autowired
+    TopicMapper topicMapper;
+
+    @Autowired
+    OprGroupMemberMapper oprGroupMemberMapper;
+
+
+    @Override
+    public List<TopicEntity> getTopicList(TopicEntity topicEntity) {
+        return topicMapper.getTopicList(topicEntity);
+    }
+
+    @Override
+    public void addTopic_plus(TopicEntity topicEntity) {
+        GroupMemberEntity groupMemberEntity = new GroupMemberEntity();
+        groupMemberEntity.setTopicName(topicEntity.getTopicName());
+        groupMemberEntity.setState("active");
+        oprGroupMemberMapper.updateMemberByTopic(groupMemberEntity);
+        topicMapper.addTopic(topicEntity);
+    }
+
+    @Override
+    public void updateTopic(TopicEntity topicEntity) {
+        topicMapper.updateTopic(topicEntity);
+    }
+
+    @Override
+    public void deleteTopicById(TopicEntity topicEntity) {
+        topicMapper.deleteTopic(topicEntity);
+    }
+
+    @Override
+    public TopicEntity selectTopicById(TopicEntity topicEntity) {
+        return topicMapper.selectTopicById(topicEntity);
+    }
+
+    @Override
+    public TopicEntity selectTopicByUnique(TopicEntity topicEntity) {
+        return topicMapper.selectTopicByUnique(topicEntity);
+    }
+
+    @Override
+    public void deleteTopic(TopicEntity topicEntity) {
+        GroupMemberEntity groupMemberEntity = new GroupMemberEntity();
+        groupMemberEntity.setTopicName(topicEntity.getTopicName());
+        groupMemberEntity.setState("empty");
+        oprGroupMemberMapper.updateMemberByTopic(groupMemberEntity);
+        topicMapper.deleteTopic(topicEntity);
+    }
+}
diff --git a/eventmesh-dashboard-console/src/main/resources/application-dev.yml b/eventmesh-dashboard-console/src/main/resources/application-dev.yml
index 1c5e840..0ff18a1 100644
--- a/eventmesh-dashboard-console/src/main/resources/application-dev.yml
+++ b/eventmesh-dashboard-console/src/main/resources/application-dev.yml
@@ -32,7 +32,7 @@
       driver-class-name: com.mysql.cj.jdbc.Driver
       url: jdbc:mysql://localhost:3306/eventmesh-dashboard?useSSL=false&useUnicode=true&characterEncoding=utf-8&allowMultiQueries=true&zeroDateTimeBehavior=convertToNull&allowPublicKeyRetrieval=true
       username: root
-      password: root
+      password: 123456
 
       initial-size: 1
       max-active: 50
@@ -44,9 +44,12 @@
       test-while-idle: true
       min-evictable-idle-time-millis: 300000
 
+mybatis:
+  type-aliases-package: org.apache.eventmesh.dashboard.console.entity
+
 # cron job config, use cron expression
 cron:
-    #health check job
-    health: "0/15 * * * * ? *"
+  #health check job
+  health: "0/15 * * * * ? *"
 
 
diff --git a/eventmesh-dashboard-console/src/main/resources/eventmesh-dashboard.sql b/eventmesh-dashboard-console/src/main/resources/eventmesh-dashboard.sql
index 8de09e7..96cf1e3 100644
--- a/eventmesh-dashboard-console/src/main/resources/eventmesh-dashboard.sql
+++ b/eventmesh-dashboard-console/src/main/resources/eventmesh-dashboard.sql
@@ -14,28 +14,112 @@
  * See the License for the specific language governing permissions and
  * limitations under the License.
  */
+CREATE TABLE `group`
+(
+    `id`           bigint unsigned                                  NOT NULL AUTO_INCREMENT COMMENT 'id',
+    `cluster_id`   bigint                                           NOT NULL DEFAULT '-1' COMMENT '集群id',
+    `name`         varchar(192) CHARACTER SET utf8 COLLATE utf8_bin NOT NULL DEFAULT '' COMMENT 'Group名称',
+    `member_count` int unsigned                                     NOT NULL DEFAULT '0' COMMENT '成员数',
+    `members`      text COMMENT 'group的member列表',
+    `type`         tinyint                                          NOT NULL COMMENT 'group类型 0：consumer 1：producer',
+    `state`        varchar(64)                                      NOT NULL DEFAULT '' COMMENT '状态',
+    `create_time`  timestamp                                        NOT NULL DEFAULT CURRENT_TIMESTAMP COMMENT '创建时间',
+    `update_time`  timestamp                                        NOT NULL DEFAULT CURRENT_TIMESTAMP ON UPDATE CURRENT_TIMESTAMP COMMENT '修改时间',
+    `is_delete`    int                                              NOT NULL DEFAULT '0',
+    PRIMARY KEY (`id`),
+    UNIQUE KEY `uniq_cluster_phy_id_name` (`cluster_id`, `name`),
+    KEY `cluster_id` (`cluster_id`, `name`)
+) ENGINE = InnoDB
+  AUTO_INCREMENT = 322
+  DEFAULT CHARSET = utf8mb3 COMMENT ='Group信息表'
+
+
+
+CREATE TABLE `group_member`
+(
+    `id`             bigint unsigned NOT NULL AUTO_INCREMENT COMMENT 'id',
+    `cluster_id`     bigint          NOT NULL DEFAULT '-1' COMMENT '集群ID',
+    `topic_name`     varchar(192)    NOT NULL DEFAULT '' COMMENT 'Topic名称',
+    `group_name`     varchar(192)    NOT NULL DEFAULT '' COMMENT 'Group名称',
+    `eventmesh_user` varchar(192)    NOT NULL DEFAULT '' COMMENT 'EventMesh用户',
+    `state`          varchar(64)     NOT NULL DEFAULT '' COMMENT '状态',
+    `create_time`    timestamp       NOT NULL DEFAULT CURRENT_TIMESTAMP COMMENT '创建时间',
+    `update_time`    timestamp       NOT NULL DEFAULT CURRENT_TIMESTAMP ON UPDATE CURRENT_TIMESTAMP COMMENT '修改时间',
+    `is_delete`      int             NOT NULL DEFAULT '0',
+    PRIMARY KEY (`id`),
+    UNIQUE KEY `uniq_cluster_topic_group` (`cluster_id`, `topic_name`, `group_name`),
+    KEY `cluster_id` (`cluster_id`, `topic_name`, `group_name`)
+) ENGINE = InnoDB
+  AUTO_INCREMENT = 257
+  DEFAULT CHARSET = utf8mb3 COMMENT ='GroupMember信息表'
+
+
+
+CREATE TABLE `operation_log`
+(
+    `id`             bigint unsigned NOT NULL AUTO_INCREMENT COMMENT 'id',
+    `cluster_id`     bigint          NOT NULL DEFAULT '-1' COMMENT '物理集群ID',
+    `operation_type` varchar(192)    NOT NULL DEFAULT '' COMMENT '操作类型,如:启动，停止，重启，添加，删除，修改',
+    `status`         int             NOT NULL DEFAULT '0' COMMENT '操作状态 0:未知，1:执行中，2:成功，3:失败',
+    `content`    text COMMENT '备注信息',
+    `create_time`    timestamp       NOT NULL DEFAULT CURRENT_TIMESTAMP COMMENT '创建时间',
+    `end_time`       timestamp       NULL     DEFAULT CURRENT_TIMESTAMP COMMENT '结束时间',
+    `operation_user` varchar(192)             DEFAULT NULL,
+    `result` text,
+    `target_type`    varchar(192)    NOT NULL,
+    `is_delete`      int             NOT NULL DEFAULT '0',
+    PRIMARY KEY (`id`),
+    KEY `idx_cluster_phy_id` (`cluster_id`),
+    KEY `idx_status` (`status`)
+) ENGINE = InnoDB
+  AUTO_INCREMENT = 68
+  DEFAULT CHARSET = utf8mb3 COMMENT ='操作记录信息表'
+
+
+
+CREATE TABLE `topic`
+(
+    `id`           bigint unsigned                                  NOT NULL AUTO_INCREMENT COMMENT 'id',
+    `cluster_id`   bigint                                           NOT NULL DEFAULT '-1' COMMENT '集群ID',
+    `topic_name`   varchar(192) CHARACTER SET utf8 COLLATE utf8_bin NOT NULL DEFAULT '' COMMENT 'Topic名称',
+    `runtime_id`   varchar(2048)                                    NOT NULL DEFAULT '' COMMENT 'RuntimeId',
+    `storage_id`   varchar(2048)                                    NOT NULL DEFAULT '' COMMENT 'StorageId',
+    `retention_ms` bigint                                           NOT NULL DEFAULT '-2' COMMENT '保存时间，-2：未知，-1：无限制，>=0对应时间，单位ms',
+    `type`         tinyint                                          NOT NULL DEFAULT '0' COMMENT 'Topic类型，默认0，0:普通，1:EventMesh内部',
+    `description`  text COMMENT '备注信息',
+    `create_time`  timestamp                                        NOT NULL DEFAULT CURRENT_TIMESTAMP COMMENT '创建时间(尽量与Topic实际创建时间一致)',
+    `update_time`  timestamp                                        NOT NULL DEFAULT CURRENT_TIMESTAMP COMMENT '修改时间(尽量与Topic实际创建时间一致)',
+    `is_delete`    int                                              NOT NULL DEFAULT '0',
+    PRIMARY KEY (`id`),
+    UNIQUE KEY `uniq_cluster_phy_id_topic_name` (`cluster_id`, `topic_name`),
+    KEY `cluster_id` (`cluster_id`, `topic_name`)
+) ENGINE = InnoDB
+  AUTO_INCREMENT = 562
+  DEFAULT CHARSET = utf8mb3 COMMENT ='Topic信息表'
+
+
 
 DROP TABLE IF EXISTS `client`;
 CREATE TABLE `client`
 (
-    `id`             bigint(20)          NOT NULL AUTO_INCREMENT COMMENT 'id',
-    `cluster_id` bigint(20)          NOT NULL DEFAULT '-1' COMMENT '集群ID',
-    `name`           varchar(192)        NOT NULL DEFAULT '' COMMENT '客户端名称',
-    `platform`       varchar(192)        NOT NULL DEFAULT '' COMMENT '客户端平台',
-    `language`       varchar(192)        NOT NULL DEFAULT '' COMMENT '客户端语言',
-    `pid`            bigint(22)          NOT NULL DEFAULT '-1' COMMENT '客户端进程ID',
-    `host`           varchar(128)        NOT NULL DEFAULT '' COMMENT '客户端地址',
-    `port`           int(16)             NOT NULL DEFAULT '-1' COMMENT '客户端端口',
-    `protocol`       varchar(192)        NOT NULL DEFAULT '' COMMENT '协议类型',
-    `status`         tinyint(4) unsigned NOT NULL DEFAULT '0' COMMENT '状态: 1启用，0未启用',
-    `config_ids`     text                NOT NULL DEFAULT '' COMMENT 'csv config id list, like:1,3,7',
-    `description`    text                NOT NULL DEFAULT '' COMMENT '客户端描述',
-    `create_time`    timestamp           NOT NULL DEFAULT CURRENT_TIMESTAMP COMMENT '创建时间',
-    `end_time`       timestamp           NOT NULL DEFAULT CURRENT_TIMESTAMP COMMENT '结束时间',
-    `update_time`    timestamp           NOT NULL DEFAULT CURRENT_TIMESTAMP ON UPDATE CURRENT_TIMESTAMP COMMENT '修改时间',
+    `id`          bigint(20)          NOT NULL AUTO_INCREMENT COMMENT 'id',
+    `cluster_id`  bigint(20)          NOT NULL DEFAULT '-1' COMMENT '集群ID',
+    `name`        varchar(192)        NOT NULL DEFAULT '' COMMENT '客户端名称',
+    `platform`    varchar(192)        NOT NULL DEFAULT '' COMMENT '客户端平台',
+    `language`    varchar(192)        NOT NULL DEFAULT '' COMMENT '客户端语言',
+    `pid`         bigint(22)          NOT NULL DEFAULT '-1' COMMENT '客户端进程ID',
+    `host`        varchar(128)        NOT NULL DEFAULT '' COMMENT '客户端地址',
+    `port`        int(16)             NOT NULL DEFAULT '-1' COMMENT '客户端端口',
+    `protocol`    varchar(192)        NOT NULL DEFAULT '' COMMENT '协议类型',
+    `status`      tinyint(4) unsigned NOT NULL DEFAULT '0' COMMENT '状态: 1启用，0未启用',
+    `config_ids`  text                NOT NULL DEFAULT '' COMMENT 'csv config id list, like:1,3,7',
+    `description` text                NOT NULL DEFAULT '' COMMENT '客户端描述',
+    `create_time` timestamp           NOT NULL DEFAULT CURRENT_TIMESTAMP COMMENT '创建时间',
+    `end_time`    timestamp           NOT NULL DEFAULT CURRENT_TIMESTAMP COMMENT '结束时间',
+    `update_time` timestamp           NOT NULL DEFAULT CURRENT_TIMESTAMP ON UPDATE CURRENT_TIMESTAMP COMMENT '修改时间',
 
     PRIMARY KEY (`id`),
-    INDEX  `idx_cluster_id` (`cluster_id`)
+    INDEX `idx_cluster_id` (`cluster_id`)
 ) ENGINE = InnoDB
   DEFAULT CHARSET = utf8 COMMENT ='客户端信息表';
 
@@ -44,16 +128,16 @@
 DROP TABLE IF EXISTS `connector`;
 CREATE TABLE `connector`
 (
-    `id`                 bigint(20) unsigned NOT NULL AUTO_INCREMENT COMMENT 'id',
-    `cluster_id`     bigint(20)          NOT NULL DEFAULT '-1' COMMENT '集群ID',
-    `name`               varchar(512)        NOT NULL DEFAULT '' COMMENT 'Connector名称',
-    `class_name`         varchar(512)        NOT NULL DEFAULT '' COMMENT 'Connector类',
-    `type`               varchar(32)         NOT NULL DEFAULT '' COMMENT 'Connector类型',
-    `status`             tinyint(4) unsigned NOT NULL DEFAULT '0' COMMENT '状态: 1启用，0未启用',
-    `pod_state`          tinyint(4) unsigned NOT NULL DEFAULT '0' COMMENT 'k8s pod状态。0: pending;1: running;2: success;3: failed;4: unknown',
-    `config_ids`         text                NOT NULL DEFAULT '' COMMENT 'csv config id list, like:1,3,7',
-    `create_time`        timestamp           NOT NULL DEFAULT CURRENT_TIMESTAMP COMMENT '创建时间',
-    `update_time`        timestamp           NOT NULL DEFAULT CURRENT_TIMESTAMP ON UPDATE CURRENT_TIMESTAMP COMMENT '修改时间',
+    `id`          bigint(20) unsigned NOT NULL AUTO_INCREMENT COMMENT 'id',
+    `cluster_id`  bigint(20)          NOT NULL DEFAULT '-1' COMMENT '集群ID',
+    `name`        varchar(512)        NOT NULL DEFAULT '' COMMENT 'Connector名称',
+    `class_name`  varchar(512)        NOT NULL DEFAULT '' COMMENT 'Connector类',
+    `type`        varchar(32)         NOT NULL DEFAULT '' COMMENT 'Connector类型',
+    `status`      tinyint(4) unsigned NOT NULL DEFAULT '0' COMMENT '状态: 1启用，0未启用',
+    `pod_state`   tinyint(4) unsigned NOT NULL DEFAULT '0' COMMENT 'k8s pod状态。0: pending;1: running;2: success;3: failed;4: unknown',
+    `config_ids`  text                NOT NULL DEFAULT '' COMMENT 'csv config id list, like:1,3,7',
+    `create_time` timestamp           NOT NULL DEFAULT CURRENT_TIMESTAMP COMMENT '创建时间',
+    `update_time` timestamp           NOT NULL DEFAULT CURRENT_TIMESTAMP ON UPDATE CURRENT_TIMESTAMP COMMENT '修改时间',
     PRIMARY KEY (`id`),
     INDEX `idx_cluster_id` (`cluster_id`)
 ) ENGINE = InnoDB
@@ -62,20 +146,20 @@
 DROP TABLE IF EXISTS `connection`;
 CREATE TABLE `connection`
 (
-    `id`             bigint(20)          NOT NULL AUTO_INCREMENT COMMENT 'id',
-    `cluster_id` bigint(20)          NOT NULL DEFAULT '-1' COMMENT '集群ID',
-    `source_type`    varchar(64)         NOT NULL DEFAULT '' COMMENT 'source类型,可以为client或source connector',
-    `source_id`      bigint(20)          NOT NULL DEFAULT '-1' COMMENT 'client或source connector ID',
-    `sink_type`      varchar(64)         NOT NULL DEFAULT '' COMMENT 'sink类型,可以为client或sink connector',
-    `sink_id`        bigint(20)          NOT NULL DEFAULT '-1' COMMENT 'client或sink connector ID',
-    `runtime_id`     bigint(20)          NOT NULL DEFAULT '-1' COMMENT '对应runtime id',
-    `status`         tinyint(4) unsigned NOT NULL DEFAULT '0' COMMENT '状态: 1启用，0未启用',
-    `topic`          varchar(192)        NOT NULL DEFAULT '' COMMENT 'topic name',
-    `group_id`       bigint(20)          NOT NULL DEFAULT '-1' COMMENT 'GroupID',
-    `description`    text                NOT NULL DEFAULT '' COMMENT '客户端描述',
-    `create_time`    timestamp           NOT NULL DEFAULT CURRENT_TIMESTAMP COMMENT '创建时间',
-    `end_time`       timestamp           NOT NULL DEFAULT CURRENT_TIMESTAMP COMMENT '结束时间',
-    `update_time`    timestamp           NOT NULL DEFAULT CURRENT_TIMESTAMP ON UPDATE CURRENT_TIMESTAMP COMMENT '修改时间',
+    `id`          bigint(20)          NOT NULL AUTO_INCREMENT COMMENT 'id',
+    `cluster_id`  bigint(20)          NOT NULL DEFAULT '-1' COMMENT '集群ID',
+    `source_type` varchar(64)         NOT NULL DEFAULT '' COMMENT 'source类型,可以为client或source connector',
+    `source_id`   bigint(20)          NOT NULL DEFAULT '-1' COMMENT 'client或source connector ID',
+    `sink_type`   varchar(64)         NOT NULL DEFAULT '' COMMENT 'sink类型,可以为client或sink connector',
+    `sink_id`     bigint(20)          NOT NULL DEFAULT '-1' COMMENT 'client或sink connector ID',
+    `runtime_id`  bigint(20)          NOT NULL DEFAULT '-1' COMMENT '对应runtime id',
+    `status`      tinyint(4) unsigned NOT NULL DEFAULT '0' COMMENT '状态: 1启用，0未启用',
+    `topic`       varchar(192)        NOT NULL DEFAULT '' COMMENT 'topic name',
+    `group_id`    bigint(20)          NOT NULL DEFAULT '-1' COMMENT 'GroupID',
+    `description` text                NOT NULL DEFAULT '' COMMENT '客户端描述',
+    `create_time` timestamp           NOT NULL DEFAULT CURRENT_TIMESTAMP COMMENT '创建时间',
+    `end_time`    timestamp           NOT NULL DEFAULT CURRENT_TIMESTAMP COMMENT '结束时间',
+    `update_time` timestamp           NOT NULL DEFAULT CURRENT_TIMESTAMP ON UPDATE CURRENT_TIMESTAMP COMMENT '修改时间',
 
     PRIMARY KEY (`id`),
     INDEX `idx_cluster_id` (`cluster_id`),
@@ -89,14 +173,14 @@
 DROP TABLE IF EXISTS `health_check_result`;
 CREATE TABLE `health_check_result`
 (
-    `id`             bigint(20) unsigned NOT NULL AUTO_INCREMENT COMMENT '自增id',
-    `dimension`      int(11)             NOT NULL DEFAULT '0' COMMENT '检查维度(0:未知，1:Cluster，2:Runtime，3:Topic，4:Group)',
-    `config_name`    varchar(192)        NOT NULL DEFAULT '' COMMENT '配置名',
-    `cluster_id` bigint(20)          NOT NULL DEFAULT '0' COMMENT '集群ID',
-    `res_name`       varchar(192)        NOT NULL DEFAULT '' COMMENT '资源名称',
-    `passed`         tinyint(4)          NOT NULL DEFAULT '0' COMMENT '检查通过(0:未通过，1:通过)',
-    `create_time`    timestamp           NOT NULL DEFAULT CURRENT_TIMESTAMP COMMENT '创建时间',
-    `update_time`    timestamp           NOT NULL DEFAULT CURRENT_TIMESTAMP ON UPDATE CURRENT_TIMESTAMP COMMENT '更新时间',
+    `id`          bigint(20) unsigned NOT NULL AUTO_INCREMENT COMMENT '自增id',
+    `dimension`   int(11)             NOT NULL DEFAULT '0' COMMENT '检查维度(0:未知，1:Cluster，2:Runtime，3:Topic，4:Group)',
+    `config_name` varchar(192)        NOT NULL DEFAULT '' COMMENT '配置名',
+    `cluster_id`  bigint(20)          NOT NULL DEFAULT '0' COMMENT '集群ID',
+    `res_name`    varchar(192)        NOT NULL DEFAULT '' COMMENT '资源名称',
+    `passed`      tinyint(4)          NOT NULL DEFAULT '0' COMMENT '检查通过(0:未通过，1:通过)',
+    `create_time` timestamp           NOT NULL DEFAULT CURRENT_TIMESTAMP COMMENT '创建时间',
+    `update_time` timestamp           NOT NULL DEFAULT CURRENT_TIMESTAMP ON UPDATE CURRENT_TIMESTAMP COMMENT '更新时间',
     PRIMARY KEY (`id`),
     INDEX `idx_cluster_id` (`cluster_id`),
     UNIQUE KEY `uniq_dimension_config_cluster_res` (`dimension`, `config_name`, `cluster_id`, `res_name`)
@@ -106,20 +190,20 @@
 DROP TABLE IF EXISTS `meta`;
 CREATE TABLE `meta`
 (
-    `id`                   bigint(20) unsigned NOT NULL AUTO_INCREMENT COMMENT 'id',
-    `name`                 varchar(192)        NOT NULL DEFAULT '' COMMENT '注册中心名称',
-    `type`                 varchar(192)        NOT NULL DEFAULT '' COMMENT '注册中心类型,nacos,etcd,zookeeper',
-    `version`              varchar(128)        NOT NULL DEFAULT '' COMMENT '注册中心版本',
-    `cluster_id`       bigint(20)          NOT NULL DEFAULT '-1' COMMENT '集群ID',
-    `host`                 varchar(128)        NOT NULL DEFAULT '' COMMENT '注册中心地址',
-    `port`                 int(16)             NOT NULL DEFAULT '-1' COMMENT '注册中心端口',
-    `role`                 varchar(16)         NOT NULL DEFAULT '-1' COMMENT '角色, leader follower observer',
-    `username`             varchar(192)        NOT NULL DEFAULT '' COMMENT '注册中心用户名',
-    `params`               varchar(192)        NOT NULL DEFAULT '' COMMENT '注册中心启动参数',
-    `status`               tinyint(4) unsigned NOT NULL DEFAULT '0' COMMENT '状态: 1启用，0未启用',
+    `id`          bigint(20) unsigned NOT NULL AUTO_INCREMENT COMMENT 'id',
+    `name`        varchar(192)        NOT NULL DEFAULT '' COMMENT '注册中心名称',
+    `type`        varchar(192)        NOT NULL DEFAULT '' COMMENT '注册中心类型,nacos,etcd,zookeeper',
+    `version`     varchar(128)        NOT NULL DEFAULT '' COMMENT '注册中心版本',
+    `cluster_id`  bigint(20)          NOT NULL DEFAULT '-1' COMMENT '集群ID',
+    `host`        varchar(128)        NOT NULL DEFAULT '' COMMENT '注册中心地址',
+    `port`        int(16)             NOT NULL DEFAULT '-1' COMMENT '注册中心端口',
+    `role`        varchar(16)         NOT NULL DEFAULT '-1' COMMENT '角色, leader follower observer',
+    `username`    varchar(192)        NOT NULL DEFAULT '' COMMENT '注册中心用户名',
+    `params`      varchar(192)        NOT NULL DEFAULT '' COMMENT '注册中心启动参数',
+    `status`      tinyint(4) unsigned NOT NULL DEFAULT '0' COMMENT '状态: 1启用，0未启用',
 
-    `create_time`          timestamp           NOT NULL DEFAULT CURRENT_TIMESTAMP COMMENT '创建时间',
-    `update_time`          timestamp           NOT NULL DEFAULT CURRENT_TIMESTAMP ON UPDATE CURRENT_TIMESTAMP COMMENT '修改时间',
+    `create_time` timestamp           NOT NULL DEFAULT CURRENT_TIMESTAMP COMMENT '创建时间',
+    `update_time` timestamp           NOT NULL DEFAULT CURRENT_TIMESTAMP ON UPDATE CURRENT_TIMESTAMP COMMENT '修改时间',
 
     PRIMARY KEY (`id`),
     INDEX `idx_cluster_id` (`cluster_id`)
diff --git a/eventmesh-dashboard-console/src/test/java/org/apache/eventmesh/dashboard/console/linkage/log/TestOprLog.java b/eventmesh-dashboard-console/src/test/java/org/apache/eventmesh/dashboard/console/linkage/log/TestOprLog.java
new file mode 100644
index 0000000..afaf8d8
--- /dev/null
+++ b/eventmesh-dashboard-console/src/test/java/org/apache/eventmesh/dashboard/console/linkage/log/TestOprLog.java
@@ -0,0 +1,43 @@
+package org.apache.eventmesh.dashboard.console.linkage.log;
+
+import org.apache.eventmesh.dashboard.console.EventMeshDashboardApplication;
+import org.apache.eventmesh.dashboard.console.entity.group.GroupEntity;
+import org.apache.eventmesh.dashboard.console.entity.log.LogEntity;
+import org.apache.eventmesh.dashboard.console.service.group.GroupService;
+import org.apache.eventmesh.dashboard.console.service.log.LogService;
+
+import java.util.List;
+
+import org.junit.Assert;
+import org.junit.Test;
+import org.junit.runner.RunWith;
+import org.springframework.beans.factory.annotation.Autowired;
+import org.springframework.boot.test.context.SpringBootTest;
+import org.springframework.test.context.junit4.SpringRunner;
+
+@RunWith(SpringRunner.class)
+@SpringBootTest(classes = EventMeshDashboardApplication.class)
+public class TestOprLog {
+
+    @Autowired
+    private GroupService groupService;
+
+    @Autowired
+    private LogService logService;
+
+    @Test
+    public void testGroupServiceOprLog() {
+        GroupEntity groupEntity = new GroupEntity(null, 1L, "logTest", 0, null, 1, "OK", null, null);
+        GroupEntity groupEntity1 = groupService.addGroup(groupEntity);
+        LogEntity logEntity = new LogEntity(null, 1L, "add", "Group", 2, groupEntity1.toString(), null, null, null, null);
+        logEntity.setResult(groupEntity.toString());
+        logEntity.setId(groupEntity1.getId());
+        List<LogEntity> logListByCluster = logService.getLogListByCluster(logEntity);
+        logListByCluster.get(0).setId(null);
+        logListByCluster.get(0).setCreateTime(null);
+        logListByCluster.get(0).setEndTime(null);
+        Assert.assertEquals(logListByCluster.get(0), logEntity);
+        Assert.assertEquals(logListByCluster.size(), 1);
+    }
+
+}
diff --git a/eventmesh-dashboard-console/src/test/java/org/apache/eventmesh/dashboard/console/unit/group/TestGroupMapper.java b/eventmesh-dashboard-console/src/test/java/org/apache/eventmesh/dashboard/console/unit/group/TestGroupMapper.java
new file mode 100644
index 0000000..f247c3f
--- /dev/null
+++ b/eventmesh-dashboard-console/src/test/java/org/apache/eventmesh/dashboard/console/unit/group/TestGroupMapper.java
@@ -0,0 +1,102 @@
+package org.apache.eventmesh.dashboard.console.unit.group;
+
+import org.apache.eventmesh.dashboard.console.EventMeshDashboardApplication;
+
+import org.apache.eventmesh.dashboard.console.entity.group.GroupEntity;
+import org.apache.eventmesh.dashboard.console.mapper.group.OprGroupMapper;
+
+import java.util.ArrayList;
+import java.util.List;
+
+import org.junit.Assert;
+import org.junit.Test;
+import org.junit.runner.RunWith;
+import org.springframework.beans.factory.annotation.Autowired;
+import org.springframework.boot.test.context.SpringBootTest;
+import org.springframework.test.context.junit4.SpringRunner;
+
+@RunWith(SpringRunner.class)
+@SpringBootTest(classes = EventMeshDashboardApplication.class)
+public class TestGroupMapper {
+
+    @Autowired
+    private OprGroupMapper groupMapper;
+
+    public List<GroupEntity> insertGroupData(String name) {
+        List<GroupEntity> groupEntities = new ArrayList<>();
+        for (int i = 0; i < 10; i++) {
+            GroupEntity groupEntity = new GroupEntity(null, (long) i, name, 0, null, 1, "OK", null, null);
+            groupMapper.addGroup(groupEntity);
+            groupEntities.add(groupEntity);
+        }
+        return groupEntities;
+    }
+
+    public List<GroupEntity> getRemovedTimeList(String name) {
+        GroupEntity groupEntity = new GroupEntity();
+        groupEntity.setName(name);
+        List<GroupEntity> groupEntities = groupMapper.selectGroup(groupEntity);
+        for (GroupEntity groupEntity1 : groupEntities) {
+            groupEntity1.setCreateTime(null);
+            groupEntity1.setUpdateTime(null);
+        }
+        return groupEntities;
+    }
+
+    @Test
+    public void testAddGroup() {
+        List<GroupEntity> groupEntities = this.insertGroupData("addGroup");
+        GroupEntity groupEntity = new GroupEntity();
+        groupEntity.setName("addGroup");
+        List<GroupEntity> groupEntities1 = groupMapper.selectGroup(groupEntity);
+        Assert.assertEquals(groupEntities, this.getRemovedTimeList("addGroup"));
+    }
+
+    @Test
+    public void testUpdateGroupById() {
+        List<GroupEntity> groupEntities = this.insertGroupData("updateById2");
+        GroupEntity groupEntity = groupEntities.get(9);
+        groupEntity.setType(3);
+        groupEntity.setMembers("1,");
+        groupEntity.setState("fail");
+        groupEntity.setMemberCount(1);
+        groupMapper.updateGroup(groupEntity);
+        Assert.assertEquals(groupEntities, this.getRemovedTimeList("updateById2"));
+    }
+
+    @Test
+    public void testDeleteGroupById() {
+        List<GroupEntity> groupEntities = this.insertGroupData("deleteById");
+        GroupEntity groupEntity = groupEntities.get(9);
+        groupMapper.deleteGroup(groupEntity);
+        groupEntities.remove(9);
+        Assert.assertEquals(groupEntities, this.getRemovedTimeList("deleteById"));
+    }
+
+    @Test
+    public void testSelectGroupById() {
+        List<GroupEntity> groupEntities = this.insertGroupData("selectById");
+        GroupEntity groupEntity = groupMapper.selectGroupById(groupEntities.get(0));
+        groupEntity.setCreateTime(null);
+        groupEntity.setUpdateTime(null);
+        Assert.assertEquals(groupEntities.get(0), groupEntity);
+    }
+
+    @Test
+    public void testSelectGroupByClusterId() {
+        List<GroupEntity> groupEntities = this.insertGroupData("selectByUnique");
+        GroupEntity groupEntity1 = new GroupEntity();
+        groupEntity1.setClusterId(groupEntities.get(0).getClusterId());
+        groupEntity1.setName(groupEntities.get(0).getName());
+        GroupEntity groupEntity = groupMapper.selectGroupByUnique(groupEntity1);
+        groupEntity.setCreateTime(null);
+        groupEntity.setUpdateTime(null);
+        Assert.assertEquals(groupEntities.get(0), groupEntity);
+    }
+
+    @Test
+    public void testSelectGroup() {
+        List<GroupEntity> groupEntities = this.insertGroupData("selectByDynamic1");
+        Assert.assertEquals(groupEntities, this.getRemovedTimeList("Dynamic1"));
+    }
+}
diff --git a/eventmesh-dashboard-console/src/test/java/org/apache/eventmesh/dashboard/console/unit/groupmember/testGroupMemberMapper.java b/eventmesh-dashboard-console/src/test/java/org/apache/eventmesh/dashboard/console/unit/groupmember/testGroupMemberMapper.java
new file mode 100644
index 0000000..d3a20a0
--- /dev/null
+++ b/eventmesh-dashboard-console/src/test/java/org/apache/eventmesh/dashboard/console/unit/groupmember/testGroupMemberMapper.java
@@ -0,0 +1,141 @@
+package org.apache.eventmesh.dashboard.console.unit.groupmember;
+
+import org.apache.eventmesh.dashboard.console.EventMeshDashboardApplication;
+import org.apache.eventmesh.dashboard.console.entity.groupmember.GroupMemberEntity;
+import org.apache.eventmesh.dashboard.console.mapper.groupmember.OprGroupMemberMapper;
+
+import java.util.ArrayList;
+import java.util.List;
+
+import org.junit.Assert;
+import org.junit.Test;
+import org.junit.runner.RunWith;
+import org.springframework.beans.factory.annotation.Autowired;
+import org.springframework.boot.test.context.SpringBootTest;
+import org.springframework.test.context.junit4.SpringRunner;
+
+@RunWith(SpringRunner.class)
+@SpringBootTest(classes = EventMeshDashboardApplication.class)
+public class testGroupMemberMapper {
+
+    @Autowired
+    OprGroupMemberMapper groupMemberMapper;
+
+    public List<GroupMemberEntity> insertGroupData(String topicName, String groupName) {
+        List<GroupMemberEntity> groupMemberEntities = new ArrayList<>();
+        for (int i = 0; i < 10; i++) {
+            GroupMemberEntity groupMemberEntity = new GroupMemberEntity(null, (long) i, topicName, groupName, "admin", "active", null, null);
+            groupMemberMapper.addGroupMember(groupMemberEntity);
+            groupMemberEntities.add(groupMemberEntity);
+        }
+        return groupMemberEntities;
+    }
+
+    public List<GroupMemberEntity> getRemovedTimeList(String topicName, String groupName) {
+        GroupMemberEntity groupMemberEntity = new GroupMemberEntity();
+        groupMemberEntity.setTopicName(topicName);
+        groupMemberEntity.setGroupName(groupName);
+        List<GroupMemberEntity> groupEntities = groupMemberMapper.selectMember(groupMemberEntity);
+        for (GroupMemberEntity groupEntity1 : groupEntities) {
+            groupEntity1.setCreateTime(null);
+            groupEntity1.setUpdateTime(null);
+        }
+        return groupEntities;
+    }
+
+    @Test
+    public void testAddGroupMember() {
+        List<GroupMemberEntity> add1 = this.insertGroupData("add1", "groupMember");
+        Assert.assertEquals(add1, this.getRemovedTimeList("add1", "groupMember"));
+    }
+
+    @Test
+    public void testGetGroupMemberByClusterId() {
+        List<GroupMemberEntity> add1 = this.insertGroupData("getByCluster", "groupMember");
+        GroupMemberEntity groupMemberEntity = new GroupMemberEntity();
+        groupMemberEntity.setClusterId(add1.get(1).getClusterId());
+        List<GroupMemberEntity> groupByClusterId = groupMemberMapper.getGroupByClusterId(groupMemberEntity);
+        GroupMemberEntity groupMemberEntity1 = groupByClusterId.get(0);
+        groupMemberEntity1.setCreateTime(null);
+        groupMemberEntity1.setUpdateTime(null);
+        Assert.assertEquals(1, groupByClusterId.size());
+        Assert.assertEquals(add1.get(1), groupMemberEntity1);
+    }
+
+    @Test
+    public void testDeleteGroupMemberById() {
+        List<GroupMemberEntity> add1 = this.insertGroupData("getById", "groupMember");
+        GroupMemberEntity groupMemberEntity = new GroupMemberEntity();
+        groupMemberEntity.setId(add1.get(2).getId());
+        GroupMemberEntity groupMemberEntity1 = groupMemberMapper.selectGroupMemberById(groupMemberEntity);
+        groupMemberEntity1.setUpdateTime(null);
+        groupMemberEntity1.setCreateTime(null);
+        Assert.assertEquals(groupMemberEntity1, add1.get(2));
+    }
+
+    @Test
+    public void testUpdateGroupMemberById() {
+        List<GroupMemberEntity> add1 = this.insertGroupData("updateById", "groupMember");
+        GroupMemberEntity groupMemberEntity = new GroupMemberEntity();
+        add1.get(1).setState("fail1");
+        groupMemberEntity.setState("fail1");
+        groupMemberEntity.setId(add1.get(1).getId());
+        groupMemberMapper.updateGroupMember(groupMemberEntity);
+        GroupMemberEntity groupMemberEntity1 = groupMemberMapper.selectGroupMemberById(add1.get(1));
+        groupMemberEntity1.setUpdateTime(null);
+        groupMemberEntity1.setCreateTime(null);
+        Assert.assertEquals(groupMemberEntity1, add1.get(1));
+    }
+
+    @Test
+    public void testSelectGroupMemberByUnique() {
+        List<GroupMemberEntity> groupMemberEntities = this.insertGroupData("selectByUnique", "groupMember");
+        GroupMemberEntity groupMemberEntity = new GroupMemberEntity();
+        groupMemberEntity.setClusterId(groupMemberEntities.get(1).getClusterId());
+        groupMemberEntity.setTopicName(groupMemberEntities.get(1).getTopicName());
+        groupMemberEntity.setGroupName(groupMemberEntities.get(1).getGroupName());
+        GroupMemberEntity groupMemberEntity1 = groupMemberMapper.selectGroupMemberByUnique(groupMemberEntity);
+        groupMemberEntity1.setUpdateTime(null);
+        groupMemberEntity1.setCreateTime(null);
+        Assert.assertEquals(groupMemberEntity1, groupMemberEntities.get(1));
+    }
+
+    @Test
+    public void testSelectGroupMemberByGroup() {
+        List<GroupMemberEntity> groupMemberEntities = this.insertGroupData("selectByGroup1", "groupMember1");
+        List<GroupMemberEntity> removedTimeList = this.getRemovedTimeList(null, "groupMember1");
+        Assert.assertEquals(groupMemberEntities, removedTimeList);
+    }
+
+    @Test
+    public void testSelectGroupMemberByTopic() {
+        List<GroupMemberEntity> groupMemberEntities = this.insertGroupData("selectByTopic1", "groupMember2");
+        List<GroupMemberEntity> removedTimeList = this.getRemovedTimeList("selectByTopic1", null);
+        Assert.assertEquals(groupMemberEntities, removedTimeList);
+    }
+
+    @Test
+    public void testUpdateGroupMemberByTopic() {
+        List<GroupMemberEntity> groupMemberEntities = this.insertGroupData("updateByTopic1", "groupMember2");
+        for (GroupMemberEntity groupMemberEntity : groupMemberEntities) {
+            groupMemberEntity.setState("fail2");
+        }
+        GroupMemberEntity groupMemberEntity = new GroupMemberEntity();
+        groupMemberEntity.setState("fail2");
+        groupMemberEntity.setTopicName("updateByTopic1");
+        groupMemberMapper.updateMemberByTopic(groupMemberEntity);
+        Assert.assertEquals(this.getRemovedTimeList("updateByTopic1", null), groupMemberEntities);
+    }
+
+    @Test
+    public void testSelectGroupMemberById() {
+        List<GroupMemberEntity> groupMemberEntities = this.insertGroupData("updateById1", "groupMember2");
+        GroupMemberEntity groupMemberEntity = new GroupMemberEntity();
+        groupMemberEntity.setId(groupMemberEntities.get(5).getId());
+        GroupMemberEntity groupMemberEntity1 = groupMemberMapper.selectGroupMemberById(groupMemberEntity);
+        groupMemberEntity1.setCreateTime(null);
+        groupMemberEntity1.setUpdateTime(null);
+        Assert.assertEquals(groupMemberEntity1, groupMemberEntities.get(5));
+    }
+
+}
diff --git a/eventmesh-dashboard-console/src/test/java/org/apache/eventmesh/dashboard/console/unit/topic/testTopicMapper.java b/eventmesh-dashboard-console/src/test/java/org/apache/eventmesh/dashboard/console/unit/topic/testTopicMapper.java
new file mode 100644
index 0000000..7472792
--- /dev/null
+++ b/eventmesh-dashboard-console/src/test/java/org/apache/eventmesh/dashboard/console/unit/topic/testTopicMapper.java
@@ -0,0 +1,116 @@
+package org.apache.eventmesh.dashboard.console.unit.topic;
+
+import org.apache.eventmesh.dashboard.console.EventMeshDashboardApplication;
+import org.apache.eventmesh.dashboard.console.entity.topic.TopicEntity;
+import org.apache.eventmesh.dashboard.console.mapper.topic.TopicMapper;
+
+import java.util.ArrayList;
+import java.util.List;
+
+import org.junit.Assert;
+import org.junit.Test;
+import org.junit.runner.RunWith;
+import org.springframework.beans.factory.annotation.Autowired;
+import org.springframework.boot.test.context.SpringBootTest;
+import org.springframework.test.context.junit4.SpringRunner;
+
+@RunWith(SpringRunner.class)
+@SpringBootTest(classes = EventMeshDashboardApplication.class)
+public class testTopicMapper {
+
+    @Autowired
+    private TopicMapper topicMapper;
+
+    public List<TopicEntity> insertGroupData(String topicName) {
+        List<TopicEntity> topicEntities = new ArrayList<>();
+        for (int i = 0; i < 10; i++) {
+            TopicEntity topicEntity = new TopicEntity(null, (long) i, topicName, "10", "10", 100L, 1, "testTopic", null, null);
+            topicMapper.addTopic(topicEntity);
+            topicEntities.add(topicEntity);
+        }
+        return topicEntities;
+    }
+
+    public List<TopicEntity> getRemovedTimeList(String topicName, Long clusterId) {
+        TopicEntity topicEntity = new TopicEntity();
+        topicEntity.setTopicName(topicName);
+        topicEntity.setClusterId(clusterId);
+        List<TopicEntity> topicEntities = topicMapper.getTopicList(topicEntity);
+        for (TopicEntity topic : topicEntities) {
+            topic.setCreateTime(null);
+            topic.setUpdateTime(null);
+        }
+        return topicEntities;
+    }
+
+    @Test
+    public void testSelectTopicByClusterId() {
+        List<TopicEntity> topicEntities = this.insertGroupData("SelectById111");
+        TopicEntity topicEntity = new TopicEntity();
+        topicEntity.setClusterId(topicEntities.get(9).getClusterId());
+        List<TopicEntity> topicEntity1 = topicMapper.getTopicList(topicEntity);
+        topicEntity1.get(0).setCreateTime(null);
+        topicEntity1.get(0).setUpdateTime(null);
+        Assert.assertEquals(topicEntity1.get(0), topicEntities.get(9));
+        Assert.assertEquals(1, topicEntity1.size());
+    }
+
+    @Test
+    public void testAddTopic() {
+        List<TopicEntity> topicEntities = this.insertGroupData("add111");
+        List<TopicEntity> add111 = this.getRemovedTimeList("add111", null);
+        Assert.assertEquals(add111, topicEntities);
+    }
+
+    @Test
+    public void testUpdateTopic() {
+        List<TopicEntity> topicEntities = this.insertGroupData("update2");
+        topicEntities.get(5).setDescription("updateTest1");
+        topicEntities.get(5).setType(-1);
+        TopicEntity topicEntity = new TopicEntity();
+        topicEntity.setDescription("updateTest1");
+        topicEntity.setType(-1);
+        topicEntity.setId(topicEntities.get(5).getId());
+        topicMapper.updateTopic(topicEntity);
+        TopicEntity topicEntity1 = topicMapper.selectTopicById(topicEntity);
+        topicEntity1.setUpdateTime(null);
+        topicEntity1.setCreateTime(null);
+        Assert.assertEquals(topicEntity1, topicEntities.get(5));
+    }
+
+    @Test
+    public void testDeleteTopic() {
+        List<TopicEntity> topicEntities = this.insertGroupData("update72");
+        TopicEntity topicEntity = new TopicEntity();
+        topicEntity.setId(topicEntities.get(5).getId());
+        topicEntity.setClusterId(topicEntities.get(5).getClusterId());
+        topicEntity.setTopicName("update72");
+        topicMapper.deleteTopic(topicEntity);
+        List<TopicEntity> topicEntity1 = topicMapper.getTopicList(topicEntity);
+        Assert.assertEquals(true, topicEntity1.isEmpty());
+    }
+
+    @Test
+    public void testSelectTopicByUnique() {
+        List<TopicEntity> topicEntities = this.insertGroupData("unique11");
+        TopicEntity topicEntity = new TopicEntity();
+        topicEntity.setTopicName("unique11");
+        topicEntity.setClusterId(topicEntities.get(1).getClusterId());
+        TopicEntity topicEntity1 = topicMapper.selectTopicByUnique(topicEntity);
+        topicEntity1.setUpdateTime(null);
+        topicEntity1.setCreateTime(null);
+        Assert.assertEquals(topicEntity1, topicEntities.get(1));
+    }
+
+    @Test
+    public void testSelectTopicById() {
+        List<TopicEntity> topicEntities = this.insertGroupData("id1");
+        TopicEntity topicEntity = new TopicEntity();
+        topicEntity.setId(topicEntities.get(2).getId());
+        TopicEntity topicEntity1 = topicMapper.selectTopicById(topicEntity);
+        topicEntity1.setCreateTime(null);
+        topicEntity1.setUpdateTime(null);
+        Assert.assertEquals(topicEntity1, topicEntities.get(2));
+    }
+
+}