alexey.rassokhin/tet123
1
0
Fork 0
Code Issues Pull Requests 1 Packages Projects Releases Wiki Activity

DBZ-5471 Missing the regex properties validation before start connector of DefaultRegexTopicNamingStrategy

Browse Source
This commit is contained in:
harveyyue 2022-08-03 12:19:43 +08:00 committed by Chris Cranford
parent ea7219a2c8
commit 2481172309
1 changed files with 7 additions and 0 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

7
debezium-core/src/main/java/io/debezium/schema/DefaultRegexTopicNamingStrategy.java
View File

@ -10,6 +10,7 @@
import java.util.regex.Pattern;
import org.apache.kafka.common.config.ConfigDef;
import org.apache.kafka.connect.errors.ConnectException;
import org.slf4j.Logger;
import org.slf4j.LoggerFactory;
@ -87,6 +88,12 @@ public DefaultRegexTopicNamingStrategy(Properties props) {
public void configure(Properties props) {
super.configure(props);
Configuration config = Configuration.from(props);
final Field.Set regexConfigFields = Field.setOf(TOPIC_REGEX, TOPIC_REPLACEMENT);
if (!config.validateAndRecord(regexConfigFields, LOGGER::error)) {
throw new ConnectException("Unable to validate config.");
}
topicRegex = Pattern.compile(config.getString(TOPIC_REGEX));
topicReplacement = config.getString(TOPIC_REPLACEMENT);
}