kafka-streams-ValueTransformerSupplier.adoc

ValueTransformerSupplier — ValueTransformers Object Factory

ValueTransformerSupplier is a single-method interface in Kafka Streams for object factories (aka suppliers) that can create one or many ValueTransformers.

package org.apache.kafka.streams.kstream;

interface ValueTransformerSupplier<V, VR> {
  ValueTransformer<V, VR> get();
}

ValueTransformerSupplier is used exclusively in KStream.transformValues stateful transformation (of record values in a stream) to get a new ValueTransformer where the transformation happens.

FIXME Example of KStream.transformValues

get is used exclusively when AbstractStream is requested for toInternalValueTransformerSupplier