From bdb1069b0d31999748a0349b72f87ab22ec047f5 Mon Sep 17 00:00:00 2001 From: Gunnar Morling Date: Fri, 23 Mar 2018 16:38:05 +0100 Subject: [PATCH] DBZ-638 Logging message on TRACE level instead of DEBUG --- .../wal2json/StreamingWal2JsonMessageDecoder.java | 11 ++++++----- 1 file changed, 6 insertions(+), 5 deletions(-) diff --git a/debezium-connector-postgres/src/main/java/io/debezium/connector/postgresql/connection/wal2json/StreamingWal2JsonMessageDecoder.java b/debezium-connector-postgres/src/main/java/io/debezium/connector/postgresql/connection/wal2json/StreamingWal2JsonMessageDecoder.java index a9471052c..8ecd296eb 100644 --- a/debezium-connector-postgres/src/main/java/io/debezium/connector/postgresql/connection/wal2json/StreamingWal2JsonMessageDecoder.java +++ b/debezium-connector-postgres/src/main/java/io/debezium/connector/postgresql/connection/wal2json/StreamingWal2JsonMessageDecoder.java @@ -115,11 +115,11 @@ public void processMessage(ByteBuffer buffer, ReplicationMessageProcessor proces // Extend the array by two as we might need to append two chars and set them to space by default final byte[] content = Arrays.copyOfRange(source, buffer.arrayOffset(), source.length + 2); final int lastPos = content.length - 1; - content[lastPos - 1] = 32; - content[lastPos] = 32; + content[lastPos - 1] = SPACE; + content[lastPos] = SPACE; - if (LOGGER.isDebugEnabled()) { - LOGGER.debug("Chunk arrived from database {}", new String(content)); + if (LOGGER.isTraceEnabled()) { + LOGGER.trace("Chunk arrived from database {}", new String(content)); } if (!messageInProgress) { @@ -200,7 +200,8 @@ private boolean isWhitespace(byte c) { private void doProcessMessage(ReplicationMessageProcessor processor, TypeRegistry typeRegistry, byte[] content, boolean lastMessage) throws IOException, SQLException, InterruptedException { final Document change = DocumentReader.floatNumbersAsTextReader().read(content); - LOGGER.debug("Change arrived for decoding {}", change); + + LOGGER.trace("Change arrived for decoding {}", change); processor.process(new Wal2JsonReplicationMessage(txId, commitTime, change, containsMetadata, lastMessage, typeRegistry)); }