Re: Kafka 2.7.0 processor API and streams-test-utils changes

2021-02-07 Thread Upesh Desai
: Saturday, February 6, 2021 at 8:22 PM To: users@kafka.apache.org Subject: Re: Kafka 2.7.0 processor API and streams-test-utils changes Hello Upesh, I’m sorry for the trouble. This was my feature, and my oversight. I will update the docs on Monday. The quick answer is that there is also a new

Re: Kafka 2.7.0 processor API and streams-test-utils changes

2021-02-06 Thread John Roesler
Hello Upesh, I’m sorry for the trouble. This was my feature, and my oversight. I will update the docs on Monday. The quick answer is that there is also a new api.MockProcessorContext, which is compatible with the new interface. That class also provides getStateStoreContext to use with the sta

Re: Kafka 2.7.0 processor API and streams-test-utils changes

2021-02-05 Thread Guozhang Wang
Hello Upesh, Thanks for the report! I think this is overlooked to update the documentation with the new 2.7.0 release. Could you file a JIRA (or even better, provide a PR with the JIRA :) to update the docs? Guozhang On Thu, Feb 4, 2021 at 1:03 PM Upesh Desai wrote: > Hello, > > > > I recentl

Kafka 2.7.0 processor API and streams-test-utils changes

2021-02-04 Thread Upesh Desai
Hello, I recently upgraded our Kafka components to 2.7.0, and noticed the changes to the processor API. Specifically, the additions of: * org.apache.kafka.streams.processor.api.Processor * org.apache.kafka.streams.processor.api.ProcessorContext The old Topology.addProcessor() method ha