Streaming Live Updates From a Reactive Spring Data Repository

Here's an example implementation of streaming updates from a database to other components

This post details a naive implementation of streaming updates from a database to any other components that are interested in that data. More precisely, we look at how to alter a Spring Data R2DBC repository to emit events to relevant subscribers.

You may also like: Reactive Streams With Spring Data and MongoDB

A little bit of background knowledge of R2DBC and Spring will be helpful for this post. My previous writings: Asynchronous RDBMS access with Spring Data R2DBC and Spring Data R2DBC for Microsoft SQL Server — these should help in that regard.