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

Matthias J. Sax resolved KAFKA-10603.
-------------------------------------
    Resolution: Fixed

> Re-design KStream.process() and K*.transform*() operations
> ----------------------------------------------------------
>
>                 Key: KAFKA-10603
>                 URL: https://issues.apache.org/jira/browse/KAFKA-10603
>             Project: Kafka
>          Issue Type: New Feature
>            Reporter: John Roesler
>            Priority: Major
>              Labels: needs-kip
>
> After the implementation of KIP-478, we have the ability to reconsider all 
> these APIs, and maybe just replace them with
> {code:java}
> // KStream
> KStream<KOut, VOut> process(ProcessorSupplier<KIn, VIn, KOut, VOut>) 
> // KTable
> KTable<KOut, VOut> process(ProcessorSupplier<KIn, VIn, KOut, VOut>){code}
>  
> but it needs more thought and a KIP for sure.
>  
> This ticket probably supercedes 
> https://issues.apache.org/jira/browse/KAFKA-8396



--
This message was sent by Atlassian Jira
(v8.20.10#820010)

Reply via email to