kafka-jira mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From "Jeyhun Karimov (JIRA)" <j...@apache.org>
Subject [jira] [Assigned] (KAFKA-3907) Better support for user-specific committing in the Streams DSL
Date Tue, 31 Oct 2017 23:03:00 GMT

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

Jeyhun Karimov reassigned KAFKA-3907:

    Assignee:     (was: 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
>              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

View raw message