THIS IS A TEST INSTANCE. ALL YOUR CHANGES WILL BE LOST!!!!
...
Code Block |
---|
void process( final processor.generic.ProcessorSupplier<? super K, ? super V, Void, Void> processorSupplier, final String... stateStoreNames ) void process( final processor.generic.ProcessorSupplier<? super K, ? super V, Void, Void> processorSupplier, final Named named, final String... stateStoreNames ) |
(unchanged) org.apache.kafka.streams.kstream.Transformer
Just explicitly stating that the Transformer interface 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 means that, as an intermediate state, there would be a `rawtypes` warning on the ProcessorContext parameter to `Transformer.init`.
(modification) org.apache.kafka.streams.kstream.{ValueTransformer, ValueTransformerWithKey}
...