Illegal character in topic name

[Andrei S.]

Hi, guys!

How to resolve a problem with Illegal character in topic name?
For example:
Table name is IDS.C#Table
I can't create a topic with name blabla.IDS.C#Table beacause kafka don't support character # in topic name.

[Chris Cranford]

Hi Andrei -

You could use the ByLogicalTableRouter [1] to reroute the events for that table to a topic name that doesn't have the "#" character.

[1]: https://debezium.io/documentation/reference/stable/transformations/topic-routing.html

--
You received this message because you are subscribed to the Google Groups "debezium" group.
To unsubscribe from this group and stop receiving emails from it, send an email to debezium+u...@googlegroups.com.
To view this discussion on the web visit https://groups.google.com/d/msgid/debezium/322bd51f-015b-4c35-9448-3b79d705e71cn%40googlegroups.com.

[Gunnar Morling]

Hi,

The connectors themselves should replace any disallowed character with an "_" in topic names. I.e. that table name would show up as "IDS.C_Table" in the corresponding topic name. Alternatively, the topic naming strategy SPI in Debezium 2.0 could be of use too:

    https://debezium.io/documentation/reference/stable/connectors/postgresql.html#postgresql-property-topic-naming-strategy

Hth,

--Gunnar

To view this discussion on the web visit https://groups.google.com/d/msgid/debezium/124a32c6-0af8-0720-b943-b958740e5a6a%40gmail.com.