~/talk

Spring Kafka beyond the basics

Talkat J-Fall 2022 · on Thursday, 2022-11-03· [java]
slides:none on file

ING runs Kafka for 7+ years with over 5,000 topics, more than 1,000 developer teams, and ~1M messages per second growth ~10% monthly. Demonstrations use Spring Kafka + Confluent Schema Registry, Kafka Streams, Prometheus/micrometer and Zipkin, plus local tooling (conductor, embedded Kafka, Testcontainers). Shows concrete fixes: configure ErrorHandlingDeserializer to avoid infinite retry poison pills and publish bad records to a dead-letter topic, use the topology test driver for fast Kafka Streams unit tests, and add metrics/tracing to spot consumer lag.

AI-written summary · about

  1. 0:00Introduction and Kafka at ING
  2. 12:32Local Kafka setup and tools
  3. 13:14Poison pill scenario explained
  4. 16:47Fixing poison pill with Spring Kafka
  5. 21:44Dead letter topic recovery
  6. 26:41Exception handling in consumer code
  7. 29:29Demo of consumer exception handling
  8. 31:40Testing Kafka applications
  9. 33:54Kafka Streams unit testing
  10. 37:24Monitoring Kafka with metrics
  11. 38:50Distributed tracing demo
  12. 43:30Lessons learned and wrap-up
  13. 45:41Q&A session
~/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.