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

• Type: New Feature
• Status: Resolved
• Priority: Major
• Resolution: Fixed
• Labels: needs-kip
• Assignee: Unassigned
• Reporter: John Roesler
• Created: 13/Oct/20 03:12
• Updated: 04/Mar/24 21:51
• Resolved: 04/Mar/24 21:51

Description

After the implementation of KIP-478, we have the ability to reconsider all these APIs, and maybe just replace them with

// KStream
KStream<KOut, VOut> process(ProcessorSupplier<KIn, VIn, KOut, VOut>) 

// KTable
KTable<KOut, VOut> process(ProcessorSupplier<KIn, VIn, KOut, VOut>)

 

but it needs more thought and a KIP for sure.

 

This ticket probably supercedes https://issues.apache.org/jira/browse/KAFKA-8396

Issue Links

• is fixed by: KAFKA-13654 Extend KStream process with new Processor API
• is related to: KAFKA-8396 Clean up Transformer API
• supercedes: KAFKA-10536 KIP-478: Implement KStream changes
• mentioned in: Page Loading...