fix: job

src/main/java/com/winhc/bigdata/task/configuration/KafkaConfiguration.java

@@ -115,7 +115,7 @@ public class KafkaConfiguration {
         // 设置是否自动提交
         props.put(ConsumerConfig.ENABLE_AUTO_COMMIT_CONFIG, autoCommit);
         // 一次拉取消息数量
-        props.put(ConsumerConfig.MAX_POLL_RECORDS_CONFIG, 1000);
+        props.put(ConsumerConfig.MAX_POLL_RECORDS_CONFIG, 10);
         props.put(ConsumerConfig.SESSION_TIMEOUT_MS_CONFIG, 5 * 60 * 1000);
         props.put(ConsumerConfig.REQUEST_TIMEOUT_MS_CONFIG, 5 * 60 * 1000);
         // 最大处理时间

src/main/java/com/winhc/bigdata/task/jobs/DynamicPersonIdUpdateJob.java

@@ -238,12 +238,7 @@ public class DynamicPersonIdUpdateJob {
         try {
             coll.insertOne(document);
         } catch (Exception e) {
-            log.error(e.getMessage(), e);
-        }
-
-        int i = new Random().nextInt(3);
-        if (i == 0) {
-            log.info("riewqujir:\n{} : {}\n{}", keyno, validId, JSON.toJSONString(data));
+//            log.error(e.getMessage(), e);
         }
 
         if (StringUtils.isEmpty(id)) {

src/main/resources/application.yml

@@ -55,7 +55,6 @@ table-to-company:
     company_holder: holder_id
     company_court_open_announcement: defendant_info.litigant_id,plaintiff_info.litigant_id
     company_court_register: defendant_info.litigant_id,plaintiff_info.litigant_id
-    company_lawsuit: defendant_info.litigant_id,litigant_info.litigant_id,plaintiff_info.litigant_id
     company_mortgage_info: company_id
     company_double_random_check_info: company_id
     company_equity_info: pledgee_info.pledgee_id,pledgor_info.pledgor_id,related_company_id