Class AbstractProcessor<K,​V>

    • Constructor Summary

      Constructors 
      Modifier Constructor Description
      protected AbstractProcessor()  
    • Method Summary

      All Methods Instance Methods Concrete Methods 
      Modifier and Type Method Description
      void close()
      Close this processor and clean up any resources.
      protected ProcessorContext context()
      Get the processor's context set during initialization.
      void init​(ProcessorContext context)
      Initialize this processor with the given context.
      • Methods inherited from class java.lang.Object

        clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
      • Methods inherited from interface org.apache.kafka.streams.processor.Processor

        process
    • Constructor Detail

      • AbstractProcessor

        protected AbstractProcessor()
    • Method Detail

      • init

        public void init​(ProcessorContext context)
        Description copied from interface: Processor
        Initialize this processor with the given context. The framework ensures this is called once per processor when the topology that contains it is initialized. When the framework is done with the processor, Processor.close() will be called on it; the framework may later re-use the processor by calling #init() again.

        The provided context can be used to access topology and record meta data, to schedule a method to be called periodically and to access attached StateStores.

        Specified by:
        init in interface Processor<K,​V>
        Parameters:
        context - the context; may not be null
      • close

        public void close()
        Close this processor and clean up any resources.

        This method does nothing by default; if desired, subclasses should override it with custom functionality.

        Specified by:
        close in interface Processor<K,​V>