By the end of this guide, we will have a functioning Streams app that will take input from a topic that Debezium feeds into, make a simple arithmetic operation on one of the columns, then output the result into a new topic.
In this guide, we will use Postgres, Kafka, Kafka Connect, Debezium, and ZooKeeper to create a small API that keeps track of your stock & crypto purchases over time.
When solving a problem that requires you to link a user's session data to their actual user object, Postgres comes in handy.
Using pg_notify in Postgres alongside the NOTIFY and LISTEN syntax is all that's needed to build a real time updating dashboard.
SQL triggers are less common but can be a great solution for certain situations. I'll provide examples for how to use triggers to enforce data integrity and track changes to a database.
