diff --git a/src/main/java/com/bw/ocr/service/impl/OcrTaskServiceImpl.java b/src/main/java/com/bw/ocr/service/impl/OcrTaskServiceImpl.java index 6ce2d73..a01f67e 100644 --- a/src/main/java/com/bw/ocr/service/impl/OcrTaskServiceImpl.java +++ b/src/main/java/com/bw/ocr/service/impl/OcrTaskServiceImpl.java @@ -112,6 +112,9 @@ public class OcrTaskServiceImpl implements OcrTaskService { result.put(Constants.MESSAGE, Constants.PARSE_FIAL); result.put(Constants.STATUS, 2); task.put(Constants.RESULT, result); + //发送kafka + springBootKafka.send(topic, JSONObject.toJSONString(task)); + log.info("数据流转至下游-------"); }