Uploaded image for project: 'Debezium'
  1. Debezium
  2. DBZ-6071

Use the StreamNameMapper in debezium-server-kafka

XMLWordPrintable

    • Icon: Enhancement Enhancement
    • Resolution: Done
    • Icon: Major Major
    • 2.5.0.CR1
    • None
    • debezium-server
    • 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... 

              Unassigned Unassigned
              rwafer Richard Wafer (Inactive)
              Votes:
              0 Vote for this issue
              Watchers:
              3 Start watching this issue

                Created:
                Updated:
                Resolved: