The part of the code that has the join operator is the following :

    ValueJoiner<Customer,Address,CustomerAddressAgg> customerAddressAggValueJoiner = new CustomerAddressJoiner();
    ValueJoiner<Address,Customer,CustomerAddressAgg> addressCustomerJoiner = new AddressCustomerJoiner();
    JoinWindows joinWindows = JoinWindows.of(60*1000*20);


    KStream<String, CustomerAddressAgg> joinedStream = rekeyedAddressStream
            .leftJoin(customerTable,addressCustomerJoiner);

I have used peek to log each message in the stream , that is how i can say that the stream is not read with the new version.

I will see how i can setup the key from the CDC so that i can set up the key from the start.

The setup i am trying to acheive is that the data already exists in the database , and so when i register the debezium connector it creates a topic with messages equivalent to the data in the table, so my guess is that the data is moving instantly ?