Reliable AWS Lambda Data Pipelines with AsyncAPI Specification
summary
Builds a Kafka→AWS Lambda order-cancellation pipeline (XML in → JSON out) and uses AsyncAPI as executable contract plus Specmatic+LocalStack to auto-generate contract tests that run against an isolated Kotlin Lambda. Tests use AsyncAPI channels, reference XSD/Avro schemas, and examples to pump messages; a deliberate enum change ("stuck" vs allowed "in progress"/"failed") causes a precise schema-validation failure. Demonstrates both passing and failing runs, plus mocking of Kafka for isolated verification.
AI-written summary · about
chapters (7)
- 0:00Intro
- 0:35Context: Data pipeline
- 2:25Focusing on 1 Lambda
- 3:10AsyncAPI specification
- 6:24Demo
- 16:45Recap
- 18:48Outro
related talks
39mIntroduction to AsyncAPI for Apache Kafka
39mThinking Asynchronously
30mAsyncAPI v3: Streamlining Event-Driven API Design
42mBuilding real-time serverless data applications
31mA day in the life of a serverless developer
31mUnifying OpenAPI & AsyncAPI : Designing JSON Schemas+Examples.
23mBroadening the API Landscape: AsyncAPI and CloudEvents in the Enterprise
12mServerless Stream Processing with Confluent Cloud, Kafka and AWS Lambda