Class ProcessorContextUtils
- java.lang.Object
-
- org.apache.kafka.streams.processor.internals.ProcessorContextUtils
-
public final class ProcessorContextUtils extends java.lang.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 org.apache.kafka.common.serialization.Deserializer<?>
getKeyDeserializer(ProcessorContext processorContext)
static org.apache.kafka.common.serialization.Serializer<?>
getKeySerializer(ProcessorContext processorContext)
static org.apache.kafka.common.serialization.Deserializer<?>
getValueDeserializer(ProcessorContext processorContext)
static org.apache.kafka.common.serialization.Serializer<?>
getValueSerializer(ProcessorContext processorContext)
-
-
-
Method Detail
-
getKeySerializer
public static org.apache.kafka.common.serialization.Serializer<?> getKeySerializer(ProcessorContext processorContext)
-
getValueSerializer
public static org.apache.kafka.common.serialization.Serializer<?> getValueSerializer(ProcessorContext processorContext)
-
getKeyDeserializer
public static org.apache.kafka.common.serialization.Deserializer<?> getKeyDeserializer(ProcessorContext processorContext)
-
getValueDeserializer
public static org.apache.kafka.common.serialization.Deserializer<?> getValueDeserializer(ProcessorContext processorContext)
-
-