Showing posts with label Confluence. Show all posts
Showing posts with label Confluence. Show all posts

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.