...
The "process" method will continue to accept the old Processor<K,V> interface. Replacing this method with a new Processor<KIn, VIn, KOut, VOut> will better be done in a follow-on KIP that also proposes a way to update/replace the Transformer operations.
This future work is tracked as
| Jira | ||||||
|---|---|---|---|---|---|---|
|
(unchanged) org.apache.kafka.streams.kstream.{Transformer, ValueTransformer, ValueTransformerWithKey}
Just explicitly stating that the Transformer interfaces would not be changed at all. The generics case for Transformer is a little more complicated, and I'd like to give it the consideration it really deserves within the scope of https://issues.apache.org/jira/browse/KAFKA-8396 .
This future work is tracked as
| Jira | ||||||
|---|---|---|---|---|---|---|
|
(new class) (test-utils) org.apache.kafka.streams.processor.api.MockProcessorContext
...