Status

Current state: [ UNDER DISCUSSION | ACCEPTED | REJECTED ]

Discussion thread: <link to mailing list DISCUSS thread>http://mail-archives.apache.org/mod_mbox/samza-dev/201807.mbox/thread

JIRA: SAMZA-TBD1789

Released: 

Problem

In the current implementation of ApplicationRunner, there are a few issues: 

...

ProcessorLifecycleListener: defines the unified processor lifecycle aware methods to allow users to inject customized logic before/after start/stop the StreamProcessor(s) in an application 

public interface ProcessorLifecycleListener { 
  default void beforeStart() {} 
  default void afterStart() {} 
  default void beforeStop() {} 
  default void afterStop() {} 
}

B) Samza framework implemented runtime objects 

...