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

DBZ-5612 Remove records from being logged at all levels

Browse Source
This commit is contained in:
rajdangwal 2022-09-19 22:46:50 +05:30 committed by Jiri Pechanec
parent ce3531f6d6
commit c03bcf8606
6 changed files with 9 additions and 9 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

2
debezium-connector-mysql/src/main/java/io/debezium/connector/mysql/signal/KafkaSignalThread.java
View File

@ -135,7 +135,7 @@ private void monitorSignals() {
return; return;
} }
catch (final Exception e) { catch (final Exception e) {
LOGGER.error("Skipped signal due to an error '{}'", record, e); LOGGER.error("Skipped signal due to an error", e);
} }
} }
} }

2
debezium-core/src/main/java/io/debezium/connector/base/ChangeEventQueue.java
View File

@ -206,7 +206,7 @@ public void disableBuffering() {
protected void doEnqueue(T record) throws InterruptedException { protected void doEnqueue(T record) throws InterruptedException {
if (LOGGER.isDebugEnabled()) { if (LOGGER.isDebugEnabled()) {
LOGGER.debug("Enqueuing source record '{}'", record); LOGGER.debug("Enqueuing source record");
} }
try { try {

4
debezium-core/src/test/java/io/debezium/kafka/KafkaCluster.java
View File

@ -780,7 +780,7 @@ public <K, V> void produce(String producerName, int messageCount,
ProducerRecord<K, V> record = messageSupplier.get(); ProducerRecord<K, V> record = messageSupplier.get();
producer.send(record); producer.send(record);
producer.flush(); producer.flush();
LOGGER.debug("Producer {}: sent message {}", producerName, record); LOGGER.debug("Producer {}: sent message", producerName);
} }
} }
finally { finally {
@ -926,7 +926,7 @@ public <K, V> void consume(String groupId, String clientId, OffsetResetStrategy
consumer.subscribe(new ArrayList<>(topics)); consumer.subscribe(new ArrayList<>(topics));
while (continuation.getAsBoolean()) { while (continuation.getAsBoolean()) {
consumer.poll(10).forEach(record -> { consumer.poll(10).forEach(record -> {
LOGGER.debug("Consumer {}: consuming message {}", clientId, record); LOGGER.debug("Consumer {}: consuming message", clientId);
consumerFunction.accept(record); consumerFunction.accept(record);
if (offsetCommitCallback != null) { if (offsetCommitCallback != null) {
consumer.commitAsync(offsetCommitCallback); consumer.commitAsync(offsetCommitCallback);

2
debezium-server/debezium-server-redis/src/main/java/io/debezium/server/redis/RedisSchemaHistory.java
View File

@ -150,7 +150,7 @@ protected void storeRecord(HistoryRecord record) throws SchemaHistoryException {
line = writer.write(record.document()); line = writer.write(record.document());
} }
catch (IOException e) { 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"); throw new SchemaHistoryException("Unable to write database schema history record");
} }

4
debezium-storage/debezium-storage-file/src/main/java/io/debezium/storage/file/history/FileSchemaHistory.java
View File

@ -124,7 +124,7 @@ protected void storeRecord(HistoryRecord record) throws SchemaHistoryException {
historyWriter.newLine(); historyWriter.newLine();
} }
catch (IOException e) { 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; return;
} }
} }
@ -133,7 +133,7 @@ protected void storeRecord(HistoryRecord record) throws SchemaHistoryException {
} }
} }
catch (IOException e) { catch (IOException e) {
logger.error("Failed to convert record to string: {}", record, e); logger.error("Failed to convert record to string", e);
} }
}); });
} }

4
debezium-storage/debezium-storage-kafka/src/main/java/io/debezium/storage/kafka/history/KafkaSchemaHistory.java
View File

@ -344,10 +344,10 @@ protected void recoverRecords(Consumer<HistoryRecord> records) {
} }
} }
catch (final IOException e) { 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) { catch (final Exception e) {
LOGGER.error("Unexpected exception while processing record '{}'", record, e); LOGGER.error("Unexpected exception while processing record", e);
throw e; throw e;
} }
} }