数据处理模块新增

.gitignore

@@ -19,7 +19,6 @@ out
 .project
 .settings
 .springBeans
-*.yml
 
 ### IntelliJ IDEA ###
 .idea

cloud-modules/cloud-data/src/main/java/com/muyu/data/config/MyKafkaListenerErrorHandler.java

@@ -0,0 +1,36 @@
+package com.muyu.data.config;
+
+
+import lombok.NonNull;
+import org.apache.kafka.clients.consumer.Consumer;
+import org.springframework.kafka.annotation.KafkaListener;
+import org.springframework.kafka.listener.KafkaListenerErrorHandler;
+import org.springframework.kafka.listener.ListenerExecutionFailedException;
+import org.springframework.kafka.support.Acknowledgment;
+import org.springframework.messaging.Message;
+import org.springframework.stereotype.Component;
+
+@Component
+public class MyKafkaListenerErrorHandler implements KafkaListenerErrorHandler {
+
+    @Override
+    @NonNull
+    public Object handleError(@NonNull Message<?> message,
+                              ListenerExecutionFailedException exception) {
+        return new Object();
+    }
+
+    @Override
+    @NonNull
+    public Object handleError(@NonNull Message<?> message,
+                              @NonNull ListenerExecutionFailedException exception,
+                              Consumer<?, ?> consumer) {
+        System.out.println("消息详情："+ message);
+        System.out.println("异常信息："+ exception);
+        System.out.println("消费者详情：" +consumer.groupMetadata());
+        System.out.println("监听主题："+ consumer.listTopics());
+        return KafkaListenerErrorHandler.super.handleError(message, exception, consumer);
+    }
+
+
+}

cloud-modules/cloud-saas/src/main/resources/bootstrap.yml

@@ -0,0 +1,56 @@
+# Tomcat
+server:
+  port: 9523
+
+# nacos线上地址
+nacos:
+  addr: 47.101.53.251:8848
+  user-name: nacos
+  password: nacos
+  namespace: four
+
+# Spring
+spring:
+  application:
+    # 应用名称
+    name: cloud-saas
+  profiles:
+    # 环境配置
+    active: dev
+  cloud:
+    nacos:
+      discovery:
+        # 服务注册地址
+        server-addr: ${nacos.addr}
+        # nacos用户名
+        username: ${nacos.user-name}
+        # nacos密码
+        password: ${nacos.password}
+        # 命名空间
+        namespace: ${nacos.namespace}
+      config:
+        # 服务注册地址
+        server-addr: ${nacos.addr}
+        # nacos用户名
+        username: ${nacos.user-name}
+        # nacos密码
+        password: ${nacos.password}
+        # 命名空间
+        namespace: ${nacos.namespace}
+        # 配置文件格式
+        file-extension: yml
+        # 共享配置
+        shared-configs:
+          # 系统共享配置
+          - application-${spring.profiles.active}.${spring.cloud.nacos.config.file-extension}
+          # 系统环境Config共享配置
+          - application-config-${spring.profiles.active}.${spring.cloud.nacos.config.file-extension}
+          # xxl-job 配置文件
+          - application-xxl-config-${spring.profiles.active}.${spring.cloud.nacos.config.file-extension}
+          # rabbit 配置文件
+          - application-rabbit-config-${spring.profiles.active}.${spring.cloud.nacos.config.file-extension}
+
+logging:
+  level:
+    com.muyu.system.mapper: DEBUG
+