This repository contains several examples for implementing Streaming, R2DBC and CDC strategies.
This repository uses Git LFS to store some larger assets.
Kafka Streams applications:
polls: This application will take votes from an HTTP source, and produce results into a topic counting. The counting topic is joined with polls topic, which adds descriptions to the results. These results are then sent to a websocket sink for downstream consumers (maybe cached, single page generation, etc...).
Rather than publishing every datapoint (users, polls, choices, etc..) to streams, this app takes the approach of an existing RDBMS that contains low-cardinality entries, with Change Data Capture to support the streaming backends.
poll-topics: This repository takes CDC updates from a RDBMS then pushes new poll-choices to the 'polls' stream for reference during the results procedure.
Deployable SCS apps bound to specific broker
Spring Kafka Docs useful when configuring kafka connectivity