From c03bcf8606e0ba78b878bfbdf8c1d4fee22d487a Mon Sep 17 00:00:00 2001 From: rajdangwal Date: Mon, 19 Sep 2022 22:46:50 +0530 Subject: [PATCH] DBZ-5612 Remove records from being logged at all levels --- .../io/debezium/connector/mysql/signal/KafkaSignalThread.java | 2 +- .../java/io/debezium/connector/base/ChangeEventQueue.java | 2 +- .../src/test/java/io/debezium/kafka/KafkaCluster.java | 4 ++-- .../java/io/debezium/server/redis/RedisSchemaHistory.java | 2 +- .../io/debezium/storage/file/history/FileSchemaHistory.java | 4 ++-- .../io/debezium/storage/kafka/history/KafkaSchemaHistory.java | 4 ++-- 6 files changed, 9 insertions(+), 9 deletions(-) diff --git a/debezium-connector-mysql/src/main/java/io/debezium/connector/mysql/signal/KafkaSignalThread.java b/debezium-connector-mysql/src/main/java/io/debezium/connector/mysql/signal/KafkaSignalThread.java index 0cdc3f98c..d698551e9 100644 --- a/debezium-connector-mysql/src/main/java/io/debezium/connector/mysql/signal/KafkaSignalThread.java +++ b/debezium-connector-mysql/src/main/java/io/debezium/connector/mysql/signal/KafkaSignalThread.java @@ -135,7 +135,7 @@ private void monitorSignals() { return; } catch (final Exception e) { - LOGGER.error("Skipped signal due to an error '{}'", record, e); + LOGGER.error("Skipped signal due to an error", e); } } } diff --git a/debezium-core/src/main/java/io/debezium/connector/base/ChangeEventQueue.java b/debezium-core/src/main/java/io/debezium/connector/base/ChangeEventQueue.java index 27d04bd90..a08b88ee0 100644 --- a/debezium-core/src/main/java/io/debezium/connector/base/ChangeEventQueue.java +++ b/debezium-core/src/main/java/io/debezium/connector/base/ChangeEventQueue.java @@ -206,7 +206,7 @@ public void disableBuffering() { protected void doEnqueue(T record) throws InterruptedException { if (LOGGER.isDebugEnabled()) { - LOGGER.debug("Enqueuing source record '{}'", record); + LOGGER.debug("Enqueuing source record"); } try { diff --git a/debezium-core/src/test/java/io/debezium/kafka/KafkaCluster.java b/debezium-core/src/test/java/io/debezium/kafka/KafkaCluster.java index 18cacb5b8..92bb0639a 100644 --- a/debezium-core/src/test/java/io/debezium/kafka/KafkaCluster.java +++ b/debezium-core/src/test/java/io/debezium/kafka/KafkaCluster.java @@ -780,7 +780,7 @@ public void produce(String producerName, int messageCount, ProducerRecord record = messageSupplier.get(); producer.send(record); producer.flush(); - LOGGER.debug("Producer {}: sent message {}", producerName, record); + LOGGER.debug("Producer {}: sent message", producerName); } } finally { @@ -926,7 +926,7 @@ public void consume(String groupId, String clientId, OffsetResetStrategy consumer.subscribe(new ArrayList<>(topics)); while (continuation.getAsBoolean()) { consumer.poll(10).forEach(record -> { - LOGGER.debug("Consumer {}: consuming message {}", clientId, record); + LOGGER.debug("Consumer {}: consuming message", clientId); consumerFunction.accept(record); if (offsetCommitCallback != null) { consumer.commitAsync(offsetCommitCallback); diff --git a/debezium-server/debezium-server-redis/src/main/java/io/debezium/server/redis/RedisSchemaHistory.java b/debezium-server/debezium-server-redis/src/main/java/io/debezium/server/redis/RedisSchemaHistory.java index d45292b98..8e8f2bfc9 100644 --- a/debezium-server/debezium-server-redis/src/main/java/io/debezium/server/redis/RedisSchemaHistory.java +++ b/debezium-server/debezium-server-redis/src/main/java/io/debezium/server/redis/RedisSchemaHistory.java @@ -150,7 +150,7 @@ protected void storeRecord(HistoryRecord record) throws SchemaHistoryException { line = writer.write(record.document()); } catch (IOException e) { - LOGGER.error("Failed to convert record to string: {}", record, e); + LOGGER.error("Failed to convert record to string", e); throw new SchemaHistoryException("Unable to write database schema history record"); } diff --git a/debezium-storage/debezium-storage-file/src/main/java/io/debezium/storage/file/history/FileSchemaHistory.java b/debezium-storage/debezium-storage-file/src/main/java/io/debezium/storage/file/history/FileSchemaHistory.java index f01a607b1..47d15b4d2 100644 --- a/debezium-storage/debezium-storage-file/src/main/java/io/debezium/storage/file/history/FileSchemaHistory.java +++ b/debezium-storage/debezium-storage-file/src/main/java/io/debezium/storage/file/history/FileSchemaHistory.java @@ -124,7 +124,7 @@ protected void storeRecord(HistoryRecord record) throws SchemaHistoryException { historyWriter.newLine(); } catch (IOException e) { - logger.error("Failed to add record to history at {}: {}", path, record, e); + logger.error("Failed to add record to history at {}", path, e); return; } } @@ -133,7 +133,7 @@ protected void storeRecord(HistoryRecord record) throws SchemaHistoryException { } } catch (IOException e) { - logger.error("Failed to convert record to string: {}", record, e); + logger.error("Failed to convert record to string", e); } }); } diff --git a/debezium-storage/debezium-storage-kafka/src/main/java/io/debezium/storage/kafka/history/KafkaSchemaHistory.java b/debezium-storage/debezium-storage-kafka/src/main/java/io/debezium/storage/kafka/history/KafkaSchemaHistory.java index 13e5464ea..b273d7b6f 100644 --- a/debezium-storage/debezium-storage-kafka/src/main/java/io/debezium/storage/kafka/history/KafkaSchemaHistory.java +++ b/debezium-storage/debezium-storage-kafka/src/main/java/io/debezium/storage/kafka/history/KafkaSchemaHistory.java @@ -344,10 +344,10 @@ protected void recoverRecords(Consumer records) { } } catch (final IOException e) { - LOGGER.error("Error while deserializing history record '{}'", record, e); + LOGGER.error("Error while deserializing history record", e); } catch (final Exception e) { - LOGGER.error("Unexpected exception while processing record '{}'", record, e); + LOGGER.error("Unexpected exception while processing record", e); throw e; } }