Browse Source

fixed issue #5029 , add deserializer message

jianghang.loujh 1 year ago
parent
commit
348d218120

+ 1 - 1
client-adapter/launcher/src/main/java/com/alibaba/otter/canal/adapter/launcher/loader/AdapterProcessor.java

@@ -224,7 +224,7 @@ public class AdapterProcessor {
                                     logger.error("finish turn off switch of destination:" + canalDestination);
                                     logger.error("finish turn off switch of destination:" + canalDestination);
                                 } else {
                                 } else {
                                     canalMsgConsumer.ack();
                                     canalMsgConsumer.ack();
-                                    logger.error(e.getMessage() + " Error sync but ACK!");
+                                    logger.error(e.getMessage() + " Error sync but ACK!", e);
                                 }
                                 }
                             }
                             }
                             Thread.sleep(500);
                             Thread.sleep(500);

+ 1 - 1
client/src/main/java/com/alibaba/otter/canal/client/CanalMessageDeserializer.java

@@ -51,7 +51,7 @@ public class CanalMessageDeserializer {
                 }
                 }
             }
             }
         } catch (Exception e) {
         } catch (Exception e) {
-            throw new CanalClientException("deserializer failed", e);
+            throw new CanalClientException("deserializer failed by " + e.getMessage(), e);
         }
         }
     }
     }
 }
 }

+ 2 - 2
connector/core/src/main/java/com/alibaba/otter/canal/connector/core/util/CanalMessageSerializerUtil.java

@@ -79,7 +79,7 @@ public class CanalMessageSerializerUtil {
                 }
                 }
             }
             }
         } catch (Exception e) {
         } catch (Exception e) {
-            throw new RuntimeException("Error when serializing message to byte[] ");
+            throw new RuntimeException("Error when serializing message to byte[] by " + e.getMessage() , e);
         }
         }
         return null;
         return null;
     }
     }
@@ -125,7 +125,7 @@ public class CanalMessageSerializerUtil {
                 }
                 }
             }
             }
         } catch (Exception e) {
         } catch (Exception e) {
-            throw new CanalClientException("deserializer failed", e);
+            throw new CanalClientException("deserializer failed by " + e.getMessage(), e);
         }
         }
     }
     }
 }
 }