life is too short for a diary



Posts Tagged: kafka

Handling Kafka Poison Pills in Reactive Spring Boot Applications
A single malformed Kafka message can silently halt your entire consumer group. If you've ever been paged at 2 AM because messages stopped processing and your consumer lag was climbing, there's a good chance you were dealing with a poison pill. Here's how to handle it in a reactive Spring Boot application...

Continue reading → kafka spring-boot reactive


Kafka Consumers with Reactive OAuth2 in Non-HTTP Contexts
When integrating Kafka consumers with reactive OAuth2 for securing outbound HTTP calls, a common pitfall arises: Kafka processing typically operates in a background, non-HTTP context. This means there's no `ServerWebExchange` available, which is a core component of the reactive web stack that exposes the current HTTP request/response and request-scoped attributes...

Continue reading → kafka spring reactive oauth2


Publish / Subscribe to Kafka locally
Apache Kafka is a distributed streaming platform designed for building real-time data pipelines and streaming applications. Originally developed by LinkedIn, Kafka excels at handling high-throughput, fault-tolerant publish-subscribe messaging between systems...

Continue reading → kafka kcat docker