Specify a topic delimiter via config

[Yunjoo Park]

Hi, this is Yunjoo Park.
I'm using debezium for MySQL with my company infra. There is the limit that kafka topic cannot include ".".

However, debezium uses dot as the delimiter
So, I'd like to add a feature that specifies a topic delimiter via config.

[jiri.p...@gmail.com]

Hi,

I'd recommend you to use RegexRouter or ByLogicalTableRouter SMT so you can redirect topics from names with dots to names you prefer .

J.

[Yunjoo Park]

Can I contribute?

Use dot as the delimiter in default or custom delimiter if it is specified.

TopicSelector.java

        String delimiter = connectorConfig.getTopicDelimiter();

CommonConnectorConfig.java

    public static final Field TOPIC_DELIMITER = Field.create("topic.delimiter")
            .withDisplayName("topic delimiter")
            .withType(Type.STRING)
            .withGroup(Field.createGroupEntry(Group.ADVANCED, 30))
            .withWidth(Width.MEDIUM)
            .withDefault(DEFAULT_TOPIC_DELIMITER)
            .withDescription("Topic delimiter. Defaults to \"" + DEFAULT_TOPIC_DELIMITER + "\".")
            .withImportance(Importance.LOW);

2022년 1월 4일 화요일 오후 3시 7분 43초 UTC+9에 jiri.p...@gmail.com님이 작성:

[jiri.p...@gmail.com]

Hi,

thanks for the offer. I see you've created a Jira issue which is great. We will decide whether we want to include the functionlita as any new config option is always evaluated.

Let's continue with the discussion there.

Have a nice day

J.