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

Documentation for implementing StreamNameMapper

XMLWordPrintable

    • Icon: Enhancement Enhancement
    • Resolution: Done
    • Icon: Major Major
    • 1.2.0.CR2
    • 1.2.0.Beta2
    • debezium-server, examples
    • None

      I was able to stream the changes from one table on Postgres to a Kinesis stream of the same name. However I'd like to stream changes from multiple tables to the same Kinesis stream.

      From the documentation I understand that I need to somehow provide an alternative mapper by implementing io.debezium.server.kinesis.StreamNameMapper. I've gone through Quarkus' documentation and so far I'm unable to figure out how to override the default method used for stream name mapping.

      It would be great to have some documentation on how this simple thing can be implemented.

              jpechane Jiri Pechanec
              asultanpur Avinash Sultanpur (Inactive)
              Votes:
              0 Vote for this issue
              Watchers:
              3 Start watching this issue

                Created:
                Updated:
                Resolved: