Reacting to an Event-Driven World.
summary
Explains how Kafka plus reactive patterns deliver end-to-end non‑blocking systems and shows a working GitHub demo: Open Liberty + MicroProfile Reactive Messaging (system producer emits every 15s via RxJava Flowable; inventory consumer uses manual offset commit), a Vertex port that replaces poll loops with per‑record handlers enabling pause and resume, and config advice: use partitions and consumer groups for elasticity, set acks=all and retries for delivery, run three brokers for leader election, and consider a schema registry for compatibility.
AI-written summary · about
chapters (36)
- 0:00Intro
- 2:59Event Driven Architecture
- 5:23Apache Kafka is an open source, distributed streaming platform
- 6:39Reactive Manifesto
- 9:11Barista Examples
- 14:39Building reactive systems
- 15:35Reactive Architecture design patterns
- 19:05Reactive Programming Patterns
- 20:21Utilising Kafka in reactive systems
- 21:05Message Retention and Data
- 22:02Resilient Katka Clusters
- 25:06Resilient Producers
- 28:18Resilient Consumers
- 29:36Baristas with auto commit
- 32:24Resiliency through decoupling
- 33:31Schemas and Schema Registries
- 34:26Scalability in Katka
- 35:34Elasticity in Consumers
- 36:15Consumer Groups
- 41:30Writing reactive Kafka applications
- 42:06Reactive Frameworks for Kafka
- 42:48Alpakka Katka Connector API
- 44:18Backpressure in Alpakka Katka Connector
- 45:40Eclipse Micro Profile
- 46:12Micro Profile 3.3 Stack
- 47:02MicroProfile Reactive Messaging
- 48:13Backpressure in Micro Profile Reactive Messaging
- 49:11What is Eclipse Vertx?
- 50:00Backpressure in Vert.x Kafka Client
- 50:22Vert.x Demo App
- 52:08Producing Records
- 53:31Consuming and Processing Records
- 55:14Flow Control
- 56:29Additional useful Vert.x features
- 57:37Summary
- 58:30MicroProfile Reactive labs
