yujunjun/datahub
2
0
Fork 0
mirror of https://github.com/datahub-project/datahub.git synced 2025-10-04 13:36:46 +00:00
Code Issues Packages Projects Releases Wiki Activity

fix(metadata-service): fix debug logging in MAE producer (#3626)

Browse Source 
closes: https://github.com/linkedin/datahub/issues/3625
This commit is contained in:
Claudio Benfatto 2021-11-29 06:07:42 +01:00 committed by GitHub
parent 842c05980b
commit f9bc3b32c4
No known key found for this signature in database
GPG Key ID: 4AEE18F83AFDEB23
1 changed files with 4 additions and 2 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

6
metadata-dao-impl/kafka-producer/src/main/java/com/linkedin/metadata/dao/producer/EntityKafkaMetadataEventProducer.java
View File

@ -88,7 +88,8 @@ public class EntityKafkaMetadataEventProducer implements EntityEventProducer {
GenericRecord record; GenericRecord record;
try { 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())); metadataAuditEvent.toString()));
record = EventUtils.pegasusToAvroMAE(metadataAuditEvent); record = EventUtils.pegasusToAvroMAE(metadataAuditEvent);
} catch (IOException e) { } catch (IOException e) {
@ -121,7 +122,8 @@ public class EntityKafkaMetadataEventProducer implements EntityEventProducer {
@Nonnull final MetadataChangeLog metadataChangeLog) { @Nonnull final MetadataChangeLog metadataChangeLog) {
GenericRecord record; GenericRecord record;
try { 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())); metadataChangeLog.toString()));
record = EventUtils.pegasusToAvroMCL(metadataChangeLog); record = EventUtils.pegasusToAvroMCL(metadataChangeLog);
} catch (IOException e) { } catch (IOException e) {