[KAFKA-13654] Extend KStream process with new Processor API

• Type: Improvement
• Status: Resolved
• Priority: Major
• Resolution: Fixed
• Fix Version/s: 3.3.0
• Labels: kafka-streams kip-required needs-kip streams
• Assignee: Jorge Esteban Quilcate Otoya
• Reporter: Jorge Esteban Quilcate Otoya
• Created: 08/Feb/22 13:00
• Updated: 04/Mar/24 21:51
• Resolved: 19/Apr/22 15:33

Description

Extending KStream#process to use latest Processor API adopted here: https://issues.apache.org/jira/browse/KAFKA-8410

This new API allow typed returned KStream that will allow to chain results from processors, becoming a new way to transform records with more control over whats forwarded.

KIP: https://cwiki.apache.org/confluence/x/yKbkCw

Issue Links

• fixes: KAFKA-10603 Re-design KStream.process() and K*.transform*() operations
• supercedes: KAFKA-8396 Clean up Transformer API
• links to: GitHub Pull Request #11993