Kafka Monthly Digest: March 2026

Releases

4.0.2

4.1.2

4.3.0

4.2.1

Kafka Improvement Proposals

• KIP-1295: Dead letter queue support for global store/KTable: This KIP extends KIP-1270 which enabled exceptions raised during GlobalKTable record processing to be handled by a ProcessingExceptionHandler. With this new KIP, records which failed during GlobalKTable processing could be sent to a dead letter queue.
   

• KIP-1303: Deprioritize Tiered Storage Followers In Leader Election: From Kafka 4.3.0 (KIP-1023), when adding a new replica to a tiered topic, users can start replication from the earliest pending upload offset, meaning the new replica only copies data that the current leader has not yet sent to remote storage and ignores data on the remote storage. In practice this allows new replicas to become in-sync much faster. The tradeoff is that the new replica hosts a lot less local data so if it becomes the leader it's more likely to have to fetch segments from the remote storage which can degrade performance. KIP-1303 proposes a mechanism to prefer replicas with earlier local-log-start-offset when running leader election for topics with tiered storage enabled.
   

• KIP-1307: SerDe and Interceptor Metrics: Overall Kafka clients are well instrumented and provide many metrics to understand their behavior and assess their performance. However one weak spot is in the execution of SerDes and interceptors. This KIP proposes adding new metrics that track the behavior or Serializers, Deserializers, and Producer and Consumer interceptors with the time spent in each method and their error rate.
   

Community Releases

• strimzi-kafka-operator 0.51: Strimzi is a Kubernetes Operator for running Kafka. This release adds support for Kafka 4.2.0. It also enables configuring connection settings per listener, and server-side applies is now enabled by default for PersistentVolumeClaim, ServiceAccount, Service, Ingress and ConfigMap resources.
   

• kroxylicious 0.19.0: Kroxylicious is an open source pluggable framework for writing network proxies that understand the Apache Kafka protocol. This release also adds support for Kafka 4.2.0. The authorizer filter has been updated to behave like Kafka when checking transactional Ids. Users can now configure idle timeouts on authenticated and unauthenticated connections. 
   

Blogs

• Deep Dive into Kafka Offset Commit with Spring Boot
• Queues for Kafka (KIP-932): The Bridge between Event Streaming and Queuing
• Kafka MirrorMaker 2 for Disaster Recovery and Migration (Part 1)