Skip to content

Commit

Permalink
DBZ-8325 Use super method for schema change topic name
Browse files Browse the repository at this point in the history
  • Loading branch information
twthorn committed Oct 22, 2024
1 parent 492d32e commit af9dbc5
Showing 1 changed file with 3 additions and 4 deletions.
Original file line number Diff line number Diff line change
Expand Up @@ -50,9 +50,8 @@ public String dataChangeTopic(TableId id) {
/**
* Return the schema change topic. There are two cases:
* 1. If override schema change topic is specified - use this as the topic name
* 2. If override schema change topic is not specified - return the `topic.prefix` specified by the
* {@link CommonConnectorConfig.TOPIC_PREFIX} config (unique to
* each connector, so it doesn't risk name conflicts)
* 2. If override schema change topic is not specified - call the super method to get the typical
* schema change topic name.
*
* @return String representing the schema change topic name.
*/
Expand All @@ -62,7 +61,7 @@ public String schemaChangeTopic() {
return overrideSchemaChangeTopic;
}
else {
return prefix;
return super.schemaChangeTopic();
}
}
}

0 comments on commit af9dbc5

Please sign in to comment.