You are viewing a plain text version of this content. The canonical link for it is here.

Posted to jira@kafka.apache.org by "Jorge Esteban Quilcate Otoya (Jira)" <ji...@apache.org> on 2021/03/23 16:40:00 UTC

[jira] [Updated] (KAFKA-12533) Migrate KStream stateless operators to new Processor API

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

Jorge Esteban Quilcate Otoya updated KAFKA-12533:
-------------------------------------------------
    Description: 
Including these operators:

 
 * KStream#branch
 * KStream#filter
 * KStream#flatMap
 * KStream#flatMapValues
 * KStream#map
 * KStream#mapValues
 * KStream#peek
 * KStream#print
 * KStream#passthrough

 

These operators are left out, waiting for a new Transformer API (https://issues.apache.org/jira/browse/KAFKA-8396):
 * KStream#flatMapTransform
 * KStream#flatMapTransformValues

> Migrate KStream stateless operators to new Processor API
> --------------------------------------------------------
>
>                 Key: KAFKA-12533
>                 URL: https://issues.apache.org/jira/browse/KAFKA-12533
>             Project: Kafka
>          Issue Type: Sub-task
>          Components: streams
>            Reporter: Jorge Esteban Quilcate Otoya
>            Assignee: Jorge Esteban Quilcate Otoya
>            Priority: Major
>
> Including these operators:
>  
>  * KStream#branch
>  * KStream#filter
>  * KStream#flatMap
>  * KStream#flatMapValues
>  * KStream#map
>  * KStream#mapValues
>  * KStream#peek
>  * KStream#print
>  * KStream#passthrough
>  
> These operators are left out, waiting for a new Transformer API (https://issues.apache.org/jira/browse/KAFKA-8396):
>  * KStream#flatMapTransform
>  * KStream#flatMapTransformValues



--
This message was sent by Atlassian Jira
(v8.3.4#803005)