From 70811bfe898f96687e670762040d549833bf7818 Mon Sep 17 00:00:00 2001 From: maojian <550076202@qq.com> Date: Wed, 2 Apr 2025 17:58:27 +0800 Subject: [PATCH] =?UTF-8?q?bug=E4=BF=AE=E5=A4=8D?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- src/main/java/com/bw/ocr/service/impl/OcrTaskServiceImpl.java | 3 +++ 1 file changed, 3 insertions(+) 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("数据流转至下游-------"); }