-
Enhancement
-
Resolution: Done
-
Major
-
1.2.0.Beta2
-
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.