1.加入kafka传电子路单至数据中台

王通
1 parent edc8ae49
Showing 1 changed file with 2 additions and 2 deletions
src/main/java/com/bsth/server_rs/schedule/real/ScheduleRealService.java
@@ -346,7 +346,7 @@ public class ScheduleRealService implements InitializingBean {
                         ObjectMapper mapper = new ObjectMapper();
                         String json = mapper.writeValueAsString(data);
                         logger.info(json);
-                        /*ListenableFuture<SendResult<String, String>> future = kafkaTemplate.send("PDGJ_JQDD", json);
+                        ListenableFuture<SendResult<String, String>> future = kafkaTemplate.send("PDGJ_JQDD", json);
                         future.addCallback(new ListenableFutureCallback<SendResult<String, String>>() {
  
                             @Override
@@ -358,7 +358,7 @@ public class ScheduleRealService implements InitializingBean {
                             public void onFailure(Throwable ex) {
                                 logger.error("kafka发送电子路单异常", ex);
                             }
-                        });*/
+                        });
                     }
                 } catch (Exception e) {
                     logger.error("kafka发电子路单调度异常", e);