-
Enhancement
-
Resolution: Done
-
Major
-
None
-
None
-
False
-
None
-
False
As a developer, when using the debezium with kafka configured as a sink, I would like to control the prefix on the topic names so the behaviour is the same as with the integration with Apache Pulsar.
Which use case/requirement will be addressed by the proposed feature?
Allow adding a prefix on the topic names when injecting an implementation of the StreamNameMapper.
Here's a linke to one of the example that shows how to use the StreamNameMapper:
debezium-examples/debezium-server-name-mapper at aa29ebbe6da6f41794f8647d07540a1db2a064f6 · debezium/debezium-examples (github.com)
Implementation ideas
For pulsar implementation it's already using the StreamNameMapper:
debezium-server/PulsarChangeConsumer.java at main · debezium/debezium-server (github.com)
Just add a line in the KafkaChangeConsumer to use the injected StreamNameMapper, fix the broken tests and add tests.
I'm trying it rigth now...