diff --git a/src/main/java/com/bfd/qanda/process/QandaPorcess.java b/src/main/java/com/bfd/qanda/process/QandaPorcess.java
index f046dcc..3da542f 100644
--- a/src/main/java/com/bfd/qanda/process/QandaPorcess.java
+++ b/src/main/java/com/bfd/qanda/process/QandaPorcess.java
@@ -71,6 +71,8 @@ public class QandaPorcess implements Runnable {
                 String answerStr = qandaRequest(authorization, model, temperature, topP, prompt, data);
                 log.info("answerStr:" + answerStr);
                 Map<String, Object> answer = JSONObject.parseObject(answerStr);
+                Map<String, Object> results = new HashMap<String, Object>(16);
+                results.put(Constants.ID, UUID.randomUUID().toString());
                 try {
                     //请求成功，正常解析
                     List<Map<String, Object>> choices = (List<Map<String, Object>>) answer.get(Constants.CHOICES);
@@ -79,10 +81,17 @@ public class QandaPorcess implements Runnable {
                 } catch (Exception e) {
                     log.error("问答接口响应体异常:{}", answerStr, e);
                     // TODO: handle exception
+                    results.put("isLast", 1);
+                    results.put("content", e.getMessage());
+                    result.put(Constants.RESULTS, JSONObject.toJSONString(results));
+                    result.put(Constants.MESSAGE, "异常");
+                    result.put(Constants.STATUS, 2);
+                    task.put(Constants.RESULT, result);
+                    //发送kafka
+                    springBootKafka.send(topic, JSONObject.toJSONString(task));
+                    log.info("数据流转至下游-------");
                     continue;
                 }
-                Map<String, Object> results = new HashMap<String, Object>(16);
-                results.put(Constants.ID, UUID.randomUUID().toString());
                 results.put(Constants.CONTENT, chatContent.toString());
                 if (fieldType != 0) {
                     results.remove(Constants.CONTENT);
@@ -96,6 +105,15 @@ public class QandaPorcess implements Runnable {
                     } catch (Exception e) {
                         log.error("问答接口响应体异常:{}", answerStr, e);
                         // TODO: handle exception
+                        results.put("isLast", 1);
+                        results.put("content", e.getMessage());
+                        result.put(Constants.RESULTS, JSONObject.toJSONString(results));
+                        result.put(Constants.MESSAGE, "异常");
+                        result.put(Constants.STATUS, 2);
+                        task.put(Constants.RESULT, result);
+                        //发送kafka
+                        springBootKafka.send(topic, JSONObject.toJSONString(task));
+                        log.info("数据流转至下游-------");
                         continue;
                     }
                 }
diff --git a/src/main/resources/logback-spring.xml b/src/main/resources/logback-spring.xml
index 549c5ae..e7b4886 100644
--- a/src/main/resources/logback-spring.xml
+++ b/src/main/resources/logback-spring.xml
@@ -3,12 +3,12 @@
     <springProperty scope="context" name="logging.path"  source="logging.path"/>
     <springProperty scope="context" name="logging.level" source="logging.level.com.bfd"/>
     <!-- 默认的控制台日志输出，一般生产环境都是后台启动，这个没太大作用 -->
-     <appender name="STDOUT"
+    <!-- <appender name="STDOUT"
         class="ch.qos.logback.core.ConsoleAppender">
         <encoder class="ch.qos.logback.classic.encoder.PatternLayoutEncoder">
             <Pattern>%d{yyyy-MM-dd HH:mm:ss.SSS} [%thread] %line %-5level %logger{50} - %msg%n</Pattern>
         </encoder>
-    </appender>
+    </appender>-->
     
     <appender name="GLMAPPER-LOGGERONE"
     class="ch.qos.logback.core.rolling.RollingFileAppender">
@@ -31,6 +31,6 @@
     
     <root level="info">
         <appender-ref ref="GLMAPPER-LOGGERONE"/>
-         <appender-ref ref="STDOUT"/>
+         <!--<appender-ref ref="STDOUT"/>-->
     </root>
 </configuration>