Re: Processor API in 2.7

2021-03-22 Thread John Roesler
Hi Ross, Thanks for the feedback! For some "context," the change you mention was: https://cwiki.apache.org/confluence/display/KAFKA/KIP-478+-+Strongly+typed+Processor+API In addition to the spec on that page, there are links to the discussion and voting mailing list threads. The primary motivat

Processor API in 2.7

2021-03-21 Thread Ross Black
Hi, I wanted to provide some feedback about the new API introduced in Kafka streaming 2.7 for adding a Processor to the Topology (using PAPI). Prior to 2.7, the Processor was typed only by the input key values , and the ProcessorContext was untyped. In 2.7 ProcessorSupplier & Processor now have