Page History

...

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
)

(modification) org.apache.kafka.streams.kstream.{

...

ValueTransformer, ValueTransformerWithKey}

• These changes are fully backward compatible. Existing implementations will start to get a warning, since they are now using a "raw type" of a generically typed class.

...

public interface ValueTransformer*Transformer*<K, V, VR> {
- void init(final ProcessorContext context);
+ void init(final ProcessorContext<Void, Void> context);
}

...

• KStream#process : would swap out the package and then add the <Void, Void> output type, which has the side benefit of notifying the user if they were pointlessly and erroneously calling context.forward.
• Transformer ValueTransformer (and company): would add <Void, Void> bounds to their ProcessorContext, which add the side benefit of notifying the user if they were pointlessly and erroneously calling context.forward.

...