[ https://issues.apache.org/jira/browse/KAFKA-3907?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16268084#comment-16268084 ]
Richard Yu commented on KAFKA-3907: ----------------------------------- [~guozhang] Do you have any specific interface or class where one would add a new method(s) to support this API (like {{KStream}})? On another note, could you describe what information is assumed by the method to be already known by the user? For example,{{ProcessorSupplier}} could be a input argument. > 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 > Labels: api > > 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.4.14#64029)