conduktor.io ↗

KIP-1027 — Add MockFixedKeyProcessorContext and TestFixedKeyRecordFactory

Discussion StreamsTesting

Adds `MockFixedKeyProcessorContext` and `TestFixedKeyRecordFactory` to Kafka Streams test-utils to enable unit testing of `FixedKeyProcessor` topologies introduced in KIP-478/KIP-820. The existing `MockProcessorContext` only supports the general `Processor` API; `FixedKeyProcessor` uses a different context type (`FixedKeyProcessorContext`) which had no test-utils analog, making unit tests for fixed-key topologies impossible without an integration test setup.

Details

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