大数据异常尝试

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

 package cn.quantgroup.xyqb.event;
 
-import java.io.UnsupportedEncodingException;
-
-import org.apache.commons.lang3.exception.ExceptionUtils;
-import org.springframework.context.ApplicationListener;
-import org.springframework.stereotype.Component;
-
-import com.amazonaws.services.kinesis.producer.UserRecordResult;
-import com.fasterxml.jackson.core.JsonProcessingException;
-import com.google.common.util.concurrent.FutureCallback;
-import com.google.common.util.concurrent.Futures;
-import com.google.common.util.concurrent.ListenableFuture;
-
 import cn.qg.ec.kinesis.EnvironmentConfig;
 import cn.qg.ec.kinesis.KinesisProducerClient;
 import cn.qg.ec.model.user.base.UserBaseDetailEvent;
@@ -20,7 +8,17 @@ import cn.quantgroup.xyqb.entity.User;
 import cn.quantgroup.xyqb.exception.PushUserToLkbException;
 import cn.quantgroup.xyqb.model.UserRegisterParam;
 import cn.quantgroup.xyqb.util.JsonUtil;
+import com.amazonaws.services.kinesis.producer.UserRecordResult;
+import com.fasterxml.jackson.core.JsonProcessingException;
+import com.google.common.util.concurrent.FutureCallback;
+import com.google.common.util.concurrent.Futures;
+import com.google.common.util.concurrent.ListenableFuture;
 import lombok.extern.slf4j.Slf4j;
+import org.apache.commons.lang3.exception.ExceptionUtils;
+import org.springframework.context.ApplicationListener;
+import org.springframework.stereotype.Component;
+
+import java.io.UnsupportedEncodingException;
 
 /**
  * 注册成功之后，用户分群数据上报
@@ -77,6 +75,8 @@ public class KinesisRegisteredEventListener implements ApplicationListener<Regis
 		} catch (UnsupportedEncodingException | JsonProcessingException e) {
             log.error("[KinesisRegistered]用户分群数据上报出错, e:{}", e);
             throw new PushUserToLkbException("用户分群数据上报出错");
+		} catch (Exception e) {
+			log.error("[KinesisRegistered]用户分群数据上报出错, e:{}", e);
 		}
 	}