kafka-jira mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From "Richard Yu (JIRA)" <j...@apache.org>
Subject [jira] [Commented] (KAFKA-3907) Better support for user-specific committing in the Streams DSL
Date Tue, 28 Nov 2017 04:13:01 GMT

    [ 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

View raw message