feat:添加日志上报

recommend-server-service/src/main/java/com/tzld/piaoquan/recommend/server/service/filter/strategy/BlacklistContainer.java

@@ -9,6 +9,7 @@ import com.ctrip.framework.apollo.spring.annotation.ApolloJsonValue;
 import com.google.common.cache.CacheBuilder;
 import com.google.common.cache.CacheLoader;
 import com.google.common.cache.LoadingCache;
+import com.tzld.piaoquan.recommend.server.common.ThreadPoolFactory;
 import com.tzld.piaoquan.recommend.server.repository.WxVideoTagRel;
 import com.tzld.piaoquan.recommend.server.repository.WxVideoTagRelRepository;
 import lombok.Data;
@@ -325,7 +326,15 @@ public class BlacklistContainer {
 
             LogItem logItem = new LogItem();
             logMap.forEach(logItem::PushBack);
-            producer.send(project, logStore, logItem);
+            
+            ThreadPoolFactory.logPool().execute(() -> {
+                try {
+                    producer.send(project, logStore, logItem);
+                } catch (
+                        Exception e) {
+                    LOG.error("log send error: ", e);
+                }
+            });
         } catch (
                 Exception e) {
             LOG.error("blacklist filter upload log error: ", e);