ValueTransformer — Stateful Record-by-Record Value Transformation

ValueTransformer is the contract in Kafka Streams for stateful mapping of a value to a new value of an arbitrary type.

package org.apache.kafka.streams.kstream;

interface ValueTransformer<V, VR> {
  void close();
  void init(final ProcessorContext context);
  VR transform(final V value);
  // deprecated
  VR punctuate(final long timestamp);

ValueTransformer is used when a stream (AbstractStream) is requested to toInternalValueTransformerSupplier.

Table 1. ValueTransformer Contract
Method Description


Used when…​FIXME


Used when…​FIXME


Used when…​FIXME


DEPRECATED Use Punctuator interface

results matching ""

    No results matching ""