Change streams act on events in realtime
summary
Demonstrates a working Java pipeline that captures every document change with MongoDB change streams, filters via the aggregation framework, and pushes results through Amazon EventBridge to a Lambda that calls Amazon Comprehend for sentiment; inserts go into a posts collection, analyzed results into a moderated collection, and two WebFlux endpoints stream positive and negative feedback live to browsers. Claims durable, total-ordered delivery with resumable tokens on a three-node replica set, and shows integration options for Kafka and Project Reactor.
AI-written summary · about
chapters (4)
- 0:00Start
- 4:53Characteristics of Change Streams
- 7:33MongoDB Change Streams + Project Reactive
- 9:08Memento - Voting application - Demo
related talks
46mStreaming ETL on the Shoulders of Giants
34mChasing the Stream Processing Utopia
55mChange Streams Don't Work
42mData Streaming for Microservices using Debezium
01h 29mEvent stream processing using Kafka Streams
49mChange Data Capture Pipelines with Debezium and Kafka Streams
01h 01mStream Data Processing for Fun and Profit
41mChange Data Streaming Patterns in Distributed Systems