Merge pull request #232 from dasl-/debug
Change ByLogicalTableRouter logging from info to debug
This commit is contained in:
commit
185c35fd46
@ -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);
|
||||
|
Loading…
Reference in New Issue
Block a user