Guozhang Wang created KAFKA-3907:
------------------------------------
Summary: Better support for user-specific committing in the
Streams DSL
Key: KAFKA-3907
URL: https://issues.apache.org/jira/browse/KAFKA-3907
Project: Kafka
Issue Type: Bug
Components: streams
Reporter: Guozhang Wang
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.
--
This message was sent by Atlassian JIRA
(v6.3.4#6332)
