From f9bc3b32c4f5bb94bc4404a39a22d4e1540e42b4 Mon Sep 17 00:00:00 2001 From: Claudio Benfatto Date: Mon, 29 Nov 2021 06:07:42 +0100 Subject: [PATCH] fix(metadata-service): fix debug logging in MAE producer (#3626) closes: https://github.com/linkedin/datahub/issues/3625 --- .../dao/producer/EntityKafkaMetadataEventProducer.java | 6 ++++-- 1 file changed, 4 insertions(+), 2 deletions(-) diff --git a/metadata-dao-impl/kafka-producer/src/main/java/com/linkedin/metadata/dao/producer/EntityKafkaMetadataEventProducer.java b/metadata-dao-impl/kafka-producer/src/main/java/com/linkedin/metadata/dao/producer/EntityKafkaMetadataEventProducer.java index 1cd263d474..77a8ea9807 100644 --- a/metadata-dao-impl/kafka-producer/src/main/java/com/linkedin/metadata/dao/producer/EntityKafkaMetadataEventProducer.java +++ b/metadata-dao-impl/kafka-producer/src/main/java/com/linkedin/metadata/dao/producer/EntityKafkaMetadataEventProducer.java @@ -88,7 +88,8 @@ public class EntityKafkaMetadataEventProducer implements EntityEventProducer { GenericRecord record; try { - log.debug(String.format(String.format("Converting Pegasus snapshot to Avro snapshot urn %s", urn), + log.debug(String.format("Converting Pegasus snapshot to Avro snapshot urn %s\nMetadataAuditEvent: %s", + urn, metadataAuditEvent.toString())); record = EventUtils.pegasusToAvroMAE(metadataAuditEvent); } catch (IOException e) { @@ -121,7 +122,8 @@ public class EntityKafkaMetadataEventProducer implements EntityEventProducer { @Nonnull final MetadataChangeLog metadataChangeLog) { GenericRecord record; try { - log.debug(String.format(String.format("Converting Pegasus snapshot to Avro snapshot urn %s", urn), + log.debug(String.format("Converting Pegasus snapshot to Avro snapshot urn %s\nMetadataChangeLog: %s", + urn, metadataChangeLog.toString())); record = EventUtils.pegasusToAvroMCL(metadataChangeLog); } catch (IOException e) {