conduktor.io ↗

KIP-478 — Strongly typed Processor API

Accepted Kafka 2.7 Streams

Adds compile-time type safety to the Kafka Streams Processor API by introducing typed `ProcessorSupplier<KIn, VIn, KOut, VOut>`, `FixedKeyProcessorSupplier`, and related interfaces so the processor chain's key-value types are checked at compile time. The original Processor API used raw types for inputs and outputs, allowing type mismatches to fail only at runtime.

Details

AuthorJohn Roesler
StatusAccepted
Kafka Version2.7
JIRAKAFKA-8396
WikiView on Apache Wiki
Created2019-06-15
Last Modified2021-06-16
Explore how this KIP affects the Kafka protocol in the Protocol Explorer, or see the full KIP database.