public interface StreamOperatorTaskFactory extends TaskFactory<AsyncStreamTask>
AsyncStreamTask instances.
Implementations should return a new instance of AsyncStreamTask for each TaskFactory.createInstance() invocation.
Note: It returns an AsyncStreamTask since StreamOperatorTask is not part of samza-api. It is
a temporary hack introduced for SAMZA-2172 and will eventually go away with SAMZA-2203
createInstance