Hello Ashhar, Could you elaborate a bit more on why you'd like to perform a stream-stream join than a stream-table join, or even a table-table join with Streams? What's the joining streams for, are they both changelog streams from Debezium/Postgres? What's the session window needed for?
Guozhang On Wed, Feb 27, 2019 at 11:14 PM Ashhar Hasan <[email protected]> wrote: > I'm using Debezium to perform CDC on Postgres. Debezium provides some > metadata about each event including the transaction timestamp, transaction > id etc. > > I want to generate consistent aggregates using Kafka Streams by performing > KStream-KStream joins with a Session Window. I'll be using a custom > TimestampExtractor which uses the transaction id as the event time and > hence all events from the same transaction will be joined. > > Has anyone tried something similar before or can let me know some > alternative ways to implement this? > > Regards, > Ashhar Hasan -- -- Guozhang
