alexey.rassokhin/tet123
1
0
Fork 0
Code Issues Pull Requests 1 Packages Projects Releases Wiki Activity

DBZ-638 Logging message on TRACE level instead of DEBUG

Browse Source
This commit is contained in:
Gunnar Morling 2018-03-23 16:38:05 +01:00
parent 363921a7b1
commit bdb1069b0d
1 changed files with 6 additions and 5 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

11
debezium-connector-postgres/src/main/java/io/debezium/connector/postgresql/connection/wal2json/StreamingWal2JsonMessageDecoder.java
View File

@ -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));
}