We do change-data-capture using debezium on our main database. These changes are written to kafka. We have a use-case for something along these lines:
What users belong to what teams (users can belong to multiple teams).
id
String (key)user_id
Stringgroup_id
String