diff --git a/debezium-embedded/src/main/java/io/debezium/embedded/async/AsyncEmbeddedEngine.java b/debezium-embedded/src/main/java/io/debezium/embedded/async/AsyncEmbeddedEngine.java index f9b7a6af0..a3b493374 100644 --- a/debezium-embedded/src/main/java/io/debezium/embedded/async/AsyncEmbeddedEngine.java +++ b/debezium-embedded/src/main/java/io/debezium/embedded/async/AsyncEmbeddedEngine.java @@ -807,7 +807,7 @@ private static boolean commitOffsets(final OffsetStorageWriter offsetWriter, fin throw e; } catch (ExecutionException | TimeoutException e) { - LOGGER.warn("Flush of the offsets failed, canceling the flush."); + LOGGER.warn("Flush of the offsets failed, canceling the flush.", e); offsetWriter.cancelFlush(); return false; }