Class 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 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)