调试，启动报错

src/main/java/cn/quantgroup/xyqb/Bootstrap.java

 package cn.quantgroup.xyqb;
 
-import cn.quantgroup.tech.db.EnableDynamicDataSource;
-import lombok.extern.slf4j.Slf4j;
 import org.springframework.boot.SpringApplication;
 import org.springframework.boot.autoconfigure.SpringBootApplication;
 import org.springframework.cache.annotation.EnableCaching;
@@ -9,6 +7,10 @@ import org.springframework.context.annotation.ComponentScan;
 import org.springframework.context.annotation.EnableAspectJAutoProxy;
 import org.springframework.scheduling.annotation.EnableAsync;
 
+import lombok.extern.slf4j.Slf4j;
+
+import cn.quantgroup.tech.db.EnableDynamicDataSource;
+
 /**
  * @author Anonymous
  * 本地启动 :
@@ -16,7 +18,7 @@ import org.springframework.scheduling.annotation.EnableAsync;
  * -Denv=dev -Didc=k8s -Dlogging.config=classpath:logback-dev.xml -DNAMESPACE=xxx -Dserver.port=8099
  */
 @Slf4j
-@ComponentScan(basePackages = {"cn.quantgroup.sms", "cn.quantgroup.xyqb"})
+@ComponentScan(basePackages = {"cn.quantgroup"})
 @EnableCaching
 @EnableAsync
 @EnableAspectJAutoProxy

src/main/java/cn/quantgroup/xyqb/controller/external/user/InnerController.java

@@ -27,7 +27,7 @@ import com.alibaba.fastjson.JSONObject;
 import com.alibaba.fastjson.TypeReference;
 import com.google.common.base.MoreObjects;
 import com.google.common.collect.Maps;
-import com.quantgroup.acolyte.buddhistscriptures.pojo.Login;
+import cn.quantgroup.acolyte.buddhistscriptures.pojo.Login;
 import io.swagger.annotations.ApiOperation;
 import io.swagger.annotations.ApiParam;
 import io.swagger.annotations.ApiResponse;

src/main/java/cn/quantgroup/xyqb/event/DetailRegisteredEventListener.java

@@ -10,7 +10,7 @@ import org.springframework.context.ApplicationEventPublisher;
 import org.springframework.context.ApplicationListener;
 import org.springframework.stereotype.Component;
 
-import com.quantgroup.acolyte.buddhistscriptures.pojo.UserRealInfo;
+import cn.quantgroup.acolyte.buddhistscriptures.pojo.UserRealInfo;
 import lombok.extern.slf4j.Slf4j;
 
 import cn.quantgroup.xyqb.entity.User;

src/main/java/cn/quantgroup/xyqb/event/KafkaUserEventListener.java

@@ -4,10 +4,11 @@ import java.util.Objects;
 
 import javax.annotation.Resource;
 
+import org.springframework.beans.factory.annotation.Value;
 import org.springframework.context.ApplicationListener;
 import org.springframework.stereotype.Component;
 
-import com.quantgroup.acolyte.buddhistscriptures.ingester.UserIngest;
+import cn.quantgroup.acolyte.buddhistscriptures.ingester.UserIngest;
 
 /**
  * 发送到Kafka - 综合统计中心 - 登录
@@ -19,6 +20,20 @@ import com.quantgroup.acolyte.buddhistscriptures.ingester.UserIngest;
 public class KafkaUserEventListener implements ApplicationListener<StatisticsEvent> {
     @Resource
     private UserIngest userIngest;
+    @Value("${kafka.connect}")
+    private String kafka_connect;
+    @Value("${batch.size}")
+    private int batch_size;
+    @Value("${linger.ms}")
+    private int linger_ms;
+    @Value("${reconnect.backoff.ms}")
+    private int reconnect_backoff_ms;
+    @Value("${retry.backoff.ms}")
+    private int retry_backoff_ms;
+    @Value("${buffer.memory}")
+    private int buffer_memory;
+    @Value("${max.block.ms}")
+    private int max_block_ms;
 
     @Override
     public void onApplicationEvent(StatisticsEvent event) {

src/main/java/cn/quantgroup/xyqb/event/MQRegisteredEventListener.java

@@ -6,7 +6,7 @@ import org.springframework.context.ApplicationEventPublisher;
 import org.springframework.context.ApplicationListener;
 import org.springframework.stereotype.Component;
 
-import com.quantgroup.acolyte.buddhistscriptures.pojo.Register;
+import cn.quantgroup.acolyte.buddhistscriptures.pojo.Register;
 
 import cn.quantgroup.xyqb.entity.User;
 import cn.quantgroup.xyqb.model.UserRegisterParam;

src/main/java/cn/quantgroup/xyqb/event/StatisticsEvent.java

@@ -2,12 +2,13 @@ package cn.quantgroup.xyqb.event;
 
 import org.springframework.context.ApplicationEvent;
 
-import com.quantgroup.acolyte.buddhistscriptures.pojo.Login;
-import com.quantgroup.acolyte.buddhistscriptures.pojo.Register;
-import com.quantgroup.acolyte.buddhistscriptures.pojo.UserRealInfo;
 import lombok.Getter;
 import lombok.Setter;
 
+import cn.quantgroup.acolyte.buddhistscriptures.pojo.Login;
+import cn.quantgroup.acolyte.buddhistscriptures.pojo.Register;
+import cn.quantgroup.acolyte.buddhistscriptures.pojo.UserRealInfo;
+
 /**
  * 统计事件
  *

src/main/java/cn/quantgroup/xyqb/service/session/impl/SessionServiceImpl.java

@@ -19,7 +19,7 @@ import org.springframework.web.context.request.RequestContextHolder;
 import org.springframework.web.context.request.ServletRequestAttributes;
 
 import com.alibaba.fastjson.JSON;
-import com.quantgroup.acolyte.buddhistscriptures.pojo.Login;
+import cn.quantgroup.acolyte.buddhistscriptures.pojo.Login;
 import lombok.extern.slf4j.Slf4j;
 
 import cn.quantgroup.xyqb.Constants;