Major Description
Currently for user-specifically committing the current processing state, users can make use of the ProcessorContext object, which is exposed in the Processor API. Other than that, the application will also automatically committing the processing state based on the configured interval.
Hence in the Streams DSL, if a user wants to explicitly call commit, she needs to use a process(ProcessorSupplier) API to get a customized processor instance in order to access the ProcessorContext. We should think of a better way to support user-specific committing interfaces inside the high-level Streams DSL.