!51 V_1.1.5

Merge pull request !51 from AE86/V_1.0.0_Beta

README.md

@@ -43,7 +43,7 @@ DBSyncer是一款开源的数据同步中间件，提供Mysql、Oracle、SqlServ
             </tr>
             <tr>
                 <td>Kafka</td>
-                <td></td>
+                <td>开发中</td>
                 <td>✔️</td>
                 <td>2.10-0.9.0.0以上</td>
             </tr>
@@ -55,7 +55,7 @@ DBSyncer是一款开源的数据同步中间件，提供Mysql、Oracle、SqlServ
             </tr>
             <tr>
                 <td>最近计划</td>
-                <td colspan="3">Kafka(开发中)、PostgreSQL(设计中)、Redis</td>
+                <td colspan="3">PostgreSQL(设计中)、Redis</td>
             </tr>
         </tbody>
     </table>

dbsyncer-parser/src/main/java/org/dbsyncer/parser/strategy/AbstractFlushStrategy.java

@@ -36,12 +36,12 @@ public abstract class AbstractFlushStrategy implements FlushStrategy {
     protected void flush(String metaId, Result writer, String event, List<Map> data) {
         refreshTotal(metaId, writer, data);
 
-        boolean fail = 0 < writer.getFail().get();
-        if (fail) {
+        boolean success = 0 == writer.getFail().get();
+        if (!success) {
             data.clear();
             data.addAll(writer.getFailData());
         }
-        flushService.asyncWrite(metaId, event, fail, data, writer.getError().toString());
+        flushService.asyncWrite(metaId, event, success, data, writer.getError().toString());
     }
 
     protected void refreshTotal(String metaId, Result writer, List<Map> data){