0005319: SymmetricDS Not Properly Handling Unable to Write Batch to

Kafka Error
JumpMind · Jun 1, 2022 · a5d1cc0 · a5d1cc0
1 parent df2dec1
commit a5d1cc0
Showing 1 changed file with 2 additions and 1 deletion.
diff --git a/symmetric-core/src/main/java/org/jumpmind/symmetric/load/KafkaWriterFilter.java b/symmetric-core/src/main/java/org/jumpmind/symmetric/load/KafkaWriterFilter.java
@@ -477,7 +477,8 @@ public void batchComplete(DataContext context) {
                 } 
             } catch (Exception e) {
                 log.warn("Unable to write batch to Kafka " + batchFileName, e);
-                e.printStackTrace();
+                throw new RuntimeException(e);
+//                e.printStackTrace();
             } finally {
                 context.put(KAFKA_TEXT_CACHE, new HashMap<String, List<String>>());
                 tableNameCache.clear();