~/talk

Kafka Microservices with Kafka plus Akka and Kafka Streams

links:none on file
slides:none on file

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

  1. 0:00Start
  2. 1:25Why Kafka
  3. 1:35What Is Kafka
  4. 6:41Streaming Engines
  5. 7:45Spark Example
  6. 8:54Programming Model
  7. 9:58Kafka Streams
  8. 12:14Processing Messages in Bulk
  9. 21:56Kappa Stream Code
  10. 23:28Scalability
  11. 24:11Akka Streams
~/search
type to search 6,249 conferences, 138,987 speakers and 185,172 talks
~/help
cmdctrl k
search every conference, speaker and series
/
focus the filter search
h
home
c
conferences
s
speakers
e
series
t
light / dark — the status bar button does the same
?
this help
esc
close this, then clear every filter — or just the search, while you are typing in it

Ignored while you are typing. Pages without a filter rail have no search to focus.