RegexRouter

The following provides Confluent usage information for the Apache Kafka SMT org.apache.kafka.connect.transforms.RegexRouter.

Description

Update the record’s topic using the configured regular expression and replacement string.

Under the hood, the regex is compiled to a java.util.regex.Pattern. If the pattern matches the input topic, java.util.regex.Matcher#replaceFirst() is used with the replacement string to obtain the new topic.

Examples

The following examples show how to configure and use RegexRouter.

Remove a Topic Prefix

This configuration snippet shows how to remove the prefix soe- from the beginning of a topic.

"transforms":"dropPrefix",
"transforms.dropPrefix.type":"org.apache.kafka.connect.transforms.RegexRouter",
"transforms.dropPrefix.regex":"soe-(.*)",
"transforms.dropPrefix.replacement":"$1"

Before: soe-Order

After: Order

Add a Topic Prefix

This configuration snippet shows how to add the prefix acme_ to the beginning of a topic.

"transforms=AddPrefix"
"transforms.AddPrefix.type"="org.apache.kafka.connect.transforms.RegexRouter"
"transforms.AddPrefix.regex=.*"
"transforms.AddPrefix.replacement=acme_$0"

Before: Order

After: acme_Order

Properties

Name Description Type Default Valid Values Importance
regex Regular expression to use for matching. string   valid regex high
replacement Replacement string. string     high