[
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)
