: 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
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
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
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