diff --git a/client-adapter/launcher/src/main/java/com/alibaba/otter/canal/adapter/launcher/loader/AdapterProcessor.java b/client-adapter/launcher/src/main/java/com/alibaba/otter/canal/adapter/launcher/loader/AdapterProcessor.java index 30a267da..05d2e035 100644 --- a/client-adapter/launcher/src/main/java/com/alibaba/otter/canal/adapter/launcher/loader/AdapterProcessor.java +++ b/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); } else { canalMsgConsumer.ack(); - logger.error(e.getMessage() + " Error sync but ACK!"); + logger.error(e.getMessage() + " Error sync but ACK!", e); } } Thread.sleep(500); diff --git a/client/src/main/java/com/alibaba/otter/canal/client/CanalMessageDeserializer.java b/client/src/main/java/com/alibaba/otter/canal/client/CanalMessageDeserializer.java index 9d24a23b..94c26e95 100644 --- a/client/src/main/java/com/alibaba/otter/canal/client/CanalMessageDeserializer.java +++ b/client/src/main/java/com/alibaba/otter/canal/client/CanalMessageDeserializer.java @@ -51,7 +51,7 @@ public class CanalMessageDeserializer { } } } catch (Exception e) { - throw new CanalClientException("deserializer failed", e); + throw new CanalClientException("deserializer failed by " + e.getMessage(), e); } } } diff --git a/connector/core/src/main/java/com/alibaba/otter/canal/connector/core/util/CanalMessageSerializerUtil.java b/connector/core/src/main/java/com/alibaba/otter/canal/connector/core/util/CanalMessageSerializerUtil.java index 5fac0e67..14317b52 100644 --- a/connector/core/src/main/java/com/alibaba/otter/canal/connector/core/util/CanalMessageSerializerUtil.java +++ b/connector/core/src/main/java/com/alibaba/otter/canal/connector/core/util/CanalMessageSerializerUtil.java @@ -79,7 +79,7 @@ public class CanalMessageSerializerUtil { } } } 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; } @@ -125,7 +125,7 @@ public class CanalMessageSerializerUtil { } } } catch (Exception e) { - throw new CanalClientException("deserializer failed", e); + throw new CanalClientException("deserializer failed by " + e.getMessage(), e); } } }