You are viewing a plain text version of this content. The canonical link for it is here.
Posted to jira@kafka.apache.org by "Sagar Rao (Jira)" <ji...@apache.org> on 2020/10/22 04:04:00 UTC

[jira] [Commented] (KAFKA-10603) Re-design KStream.process() and K*.transform*() operations

    [ https://issues.apache.org/jira/browse/KAFKA-10603?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17218723#comment-17218723 ] 

Sagar Rao commented on KAFKA-10603:
-----------------------------------

Hey [~vvcephei], I know this task requires a understanding of the new changes in the KIP.. Just curious, is it something that I can pick up?

> 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.3.4#803005)