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:
Post a Comment