From a683629519292895ff8c4806403aa640583888f1 Mon Sep 17 00:00:00 2001 From: dleibovic Date: Fri, 19 May 2017 12:09:40 -0400 Subject: [PATCH] Change ByLogicalTableRouter logging from info to debug This can be a bit spammy in the info level --- .../main/java/io/debezium/transforms/ByLogicalTableRouter.java | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/debezium-core/src/main/java/io/debezium/transforms/ByLogicalTableRouter.java b/debezium-core/src/main/java/io/debezium/transforms/ByLogicalTableRouter.java index 6b560f10a..16fd2681f 100644 --- a/debezium-core/src/main/java/io/debezium/transforms/ByLogicalTableRouter.java +++ b/debezium-core/src/main/java/io/debezium/transforms/ByLogicalTableRouter.java @@ -145,7 +145,7 @@ public R apply(R record) { return record; } - logger.info("Applying topic name transformation from " + oldTopic + " to " + newTopic + "."); + logger.debug("Applying topic name transformation from " + oldTopic + " to " + newTopic + "."); final Struct oldKey = requireStruct(record.key(), "Updating schema"); final Schema newKeySchema = updateKeySchema(oldKey.schema(), newTopic); final Struct newKey = updateKey(newKeySchema, oldKey, oldTopic);