Class ProcessorContextUtils
- java.lang.Object
-
- org.apache.kafka.streams.processor.internals.ProcessorContextUtils
-
public final class ProcessorContextUtils extends Object
This class bridges the gap for components that _should_ be compatible with the public ProcessorContext interface, but have come to depend on features in InternalProcessorContext. In theory, all the features adapted here could migrate to the public interface, so each method in this class should reference the ticket that would ultimately obviate it.
-
-
Method Summary
All Methods Static Methods Concrete Methods Modifier and Type Method Description static Deserializer<?>
getKeyDeserializer(ProcessorContext processorContext)
static Serializer<?>
getKeySerializer(ProcessorContext processorContext)
static Deserializer<?>
getValueDeserializer(ProcessorContext processorContext)
static Serializer<?>
getValueSerializer(ProcessorContext processorContext)
-
-
-
Method Detail
-
getKeySerializer
public static Serializer<?> getKeySerializer(ProcessorContext processorContext)
-
getValueSerializer
public static Serializer<?> getValueSerializer(ProcessorContext processorContext)
-
getKeyDeserializer
public static Deserializer<?> getKeyDeserializer(ProcessorContext processorContext)
-
getValueDeserializer
public static Deserializer<?> getValueDeserializer(ProcessorContext processorContext)
-
-