conduktor.io ↗

KIP-1088 — Replace KafkaClientSupplier with KafkaClientInterceptor

Discussion Streams

Replaces the `KafkaClientSupplier` interface in Kafka Streams with a new `KafkaClientInterceptor` that wraps clients after construction rather than supplying them whole, preserving the runtime's ability to build clients using internal APIs. As Kafka Streams moves toward using internal consumer primitives (KIP-1071) it can no longer treat client creation as a black-box user concern without losing the ability to co-develop clients and Streams internals.

Details

AuthorMatthias J. Sax
StatusDiscussion
JIRAKAFKA-17485
WikiView on Apache Wiki
Created2024-09-04
Last Modified2024-10-04
Explore how this KIP affects the Kafka protocol in the Protocol Explorer, or see the full KIP database.