Guozhang Wang created KAFKA-3907: ------------------------------------ Summary: 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
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.3.4#6332)