调整一下

src/main/java/cn/quantgroup/xyqb/risk/uereventcollecting/UserEventCollectingUtil.java

@@ -2,7 +2,6 @@ package cn.quantgroup.xyqb.risk.uereventcollecting;
 
 import cn.qg.ec.kinesis.KinesisProducerClient;
 import cn.qg.ec.model.base.EventInfo;
-import com.alibaba.fastjson.JSON;
 import com.amazonaws.services.kinesis.producer.UserRecordResult;
 import com.google.common.util.concurrent.FutureCallback;
 import com.google.common.util.concurrent.Futures;
@@ -22,7 +21,7 @@ import java.io.UnsupportedEncodingException;
 @Slf4j
 public class UserEventCollectingUtil {
 
-    private static final MyCallBack<UserRecordResult> CALL_BACK = new MyCallBack<>();
+    private static final FutureCallback<UserRecordResult> CALL_BACK = new MyCallBack();
 
     public static void addEvent(EventInfo eventInfo) {
         KinesisProducerClient client = KinesisProducerClientFactory.getClient();
@@ -37,11 +36,11 @@ public class UserEventCollectingUtil {
     }
 
     @Slf4j
-    public static class MyCallBack<UserRecordResult> implements FutureCallback<UserRecordResult> {
+    public static class MyCallBack implements FutureCallback<UserRecordResult> {
 
         @Override
         public void onSuccess(@Nullable UserRecordResult userRecordResult) {
-            log.info("发送事件成功 o:{}", JSON.toJSONString(userRecordResult));
+            log.info("发送事件成功 SequenceNumber:{}", userRecordResult.getSequenceNumber());
         }
 
         @Override