[jira] [Assigned] (KAFKA-3907) Better support for user-specific committing in the Streams DSL

["Jeyhun Karimov (JIRA)" <ji...@apache.org>]

     [ https://issues.apache.org/jira/browse/KAFKA-3907?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ]

Jeyhun Karimov reassigned KAFKA-3907:
-------------------------------------

    Assignee: Jeyhun Karimov

> 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
>            Assignee: Jeyhun Karimov
>              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)