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

Documentation for implementing StreamNameMapper

    XMLWordPrintable

Details

    Description

      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.

      Attachments

        Activity

          People

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

            Dates

              Created:
              Updated:
              Resolved: