Spring Kafka beyond the basics
summary
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
chapters (13)
- 0:00Introduction and Kafka at ING
- 12:32Local Kafka setup and tools
- 13:14Poison pill scenario explained
- 16:47Fixing poison pill with Spring Kafka
- 21:44Dead letter topic recovery
- 26:41Exception handling in consumer code
- 29:29Demo of consumer exception handling
- 31:40Testing Kafka applications
- 33:54Kafka Streams unit testing
- 37:24Monitoring Kafka with metrics
- 38:50Distributed tracing demo
- 43:30Lessons learned and wrap-up
- 45:41Q&A session
related talks
48mSpring for Apache Kafka the advanced features
01h 29mEvent stream processing using Kafka Streams
40mEvent Streaming Applications with Kafka Streams, Spring Kafka and Actuator
01h 44mData processing with Kafka Streams and Spring Framework.
01h 11mBootiful Stream Processing!
50mStream processing with Kafka in Big Data environments
57mWhen Everything Went Kafka
27mStream processing with Kafka streams
