Kafka Microservices with Kafka plus Akka and Kafka Streams
summary
Kafka is a distributed append-only log (not a transient message broker), gives replayable data, consumer-managed offsets, and ordering guaranteed per partition; Kafka Streams uses a Java API with KStream/KTable duality for transformations and scales by topic partitions but leaves failover and restart scripts to the operator. Akka Streams provides reactive backpressure, Alpakka connectors, actor integration and persistence so per-key work can be parallelized across threads or clusters. A simple scoring pipeline is implemented both ways (code in the repo); both work, Kafka Streams is simpler to deploy in code, Akka needs more orchestration but offers lower latency and richer integration.
AI-written summary · about
chapters (11)
- 0:00Start
- 1:25Why Kafka
- 1:35What Is Kafka
- 6:41Streaming Engines
- 7:45Spark Example
- 8:54Programming Model
- 9:58Kafka Streams
- 12:14Processing Messages in Bulk
- 21:56Kappa Stream Code
- 23:28Scalability
- 24:11Akka Streams
related talks
44mKafka based Microservices with Akka Streams and Kafka Streams
50mIntroduction to Apache Kafka
59mBuilding Data Intensive Microservices with Apache Kafka
55mDemystifying Stream Processing with Apache Kafka
35mBuilding a Real-time Streaming Platform Using Kafka Streams...
47mStream All the Things!
41mApache Kafka simply explained
16mAn introduction to Apache Kafka - this is Event Streaming, not just Messaging
