Wednesday, August 19, 2020

How KStream, Ktable and Join works?

There were lot of unknowns or at least I was not knowing how KTable, KStreams and Join between them works or behaves when I started using these artifacts from Apache Kafka.

I would like to mention some of the unknowns that were not documented and we ran into issues because of them:

1. KTable stores the mapping as (key, value) pairs. Whenever there is an update to the key, the entire value object is getting replaced and it is not getting updated.

Example:

Key: A0001

Value: {id:001, name:ABC01}


Please keep visiting, will complete the post.

No comments: