From e7aba47a24b9ce776ac29d3fc2b7b50555ef4bc7 Mon Sep 17 00:00:00 2001 From: Gunnar Morling Date: Wed, 23 Nov 2022 19:00:32 +0100 Subject: [PATCH] DBZ-5874 Making sure trace message gets logged --- .../connection/pgoutput/PgOutputMessageDecoder.java | 12 ++++++++---- 1 file changed, 8 insertions(+), 4 deletions(-) diff --git a/debezium-connector-postgres/src/main/java/io/debezium/connector/postgresql/connection/pgoutput/PgOutputMessageDecoder.java b/debezium-connector-postgres/src/main/java/io/debezium/connector/postgresql/connection/pgoutput/PgOutputMessageDecoder.java index 031a982d3..f794db678 100644 --- a/debezium-connector-postgres/src/main/java/io/debezium/connector/postgresql/connection/pgoutput/PgOutputMessageDecoder.java +++ b/debezium-connector-postgres/src/main/java/io/debezium/connector/postgresql/connection/pgoutput/PgOutputMessageDecoder.java @@ -733,6 +733,8 @@ private static List resolveColumnsFromStreamTupleData(ByteBuffer buffer, final String typeExpression = column.typeExpression(); final boolean optional = column.isOptional(); + final Column replicationMessageColumn; + // Read the sub-message type // 't' : Value is represented as text // 'u' : An unchanged TOAST-ed value, actual value is not sent. @@ -740,7 +742,7 @@ private static List resolveColumnsFromStreamTupleData(ByteBuffer buffer, char type = (char) buffer.get(); if (type == 't') { final String valueStr = readColumnValueAsString(buffer); - columns.add( + replicationMessageColumn = new AbstractReplicationMessageColumn(columnName, columnType, typeExpression, optional) { @Override public Object getValue(PgConnectionSupplier connection, boolean includeUnknownDatatypes) { @@ -755,7 +757,7 @@ public String toString() { }); } else if (type == 'u') { - columns.add( + replicationMessageColumn = new UnchangedToastedReplicationMessageColumn(columnName, columnType, typeExpression, optional) { @Override public String toString() { @@ -764,7 +766,7 @@ public String toString() { }); } else if (type == 'n') { - columns.add( + replicationMessageColumn = new AbstractReplicationMessageColumn(columnName, columnType, typeExpression, true) { @Override public Object getValue(PgConnectionSupplier connection, boolean includeUnknownDatatypes) { @@ -772,9 +774,11 @@ public Object getValue(PgConnectionSupplier connection, boolean includeUnknownDa } }); } + + columns.add(replicationMessageColumn); + LOGGER.trace("Column: {}", replicationMessageColumn)); } - columns.forEach(c -> LOGGER.trace("Column: {}", c)); return columns; }