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 has been deprecated, which is what led 
me to finding the new classes. After porting our code to the updated processor 
API, we noticed issues with the Processor unit tests, which had been written 
follow this documentation exactly:

https://kafka.apache.org/27/documentation/streams/developer-guide/testing.html#unit-testing-processors

However, it seems that the MockProcessorContext and possibly other test suite 
classes have not been updated for the new API changes, such as the following 
methods:

store.init(context, store);
context.register(store, null);

Can someone point me in the right direction if this has indeed been 
changed/fixed or need to raise an issue to have this updated in the next 
release?

Cheers!

Upesh Desai
Senior Software Developer
ude...@itrsgroup.com
www.itrsgroup.com
Internet communications are not secure and therefore the ITRS Group does not 
accept legal responsibility for the contents of this message. Any view or 
opinions presented are solely those of the author and do not necessarily 
represent those of the ITRS Group unless otherwise specifically stated.
[itrs.email.signature]

Disclaimer

The information contained in this communication from the sender is 
confidential. It is intended solely for use by the recipient and others 
authorized to receive it. If you are not the recipient, you are hereby notified 
that any disclosure, copying, distribution or taking action in relation of the 
contents of this information is strictly prohibited and may be unlawful.

This email has been scanned for viruses and malware, and may have been 
automatically archived by Mimecast Ltd, an innovator in Software as a Service 
(SaaS) for business. Providing a safer and more useful place for your human 
generated data. Specializing in; Security, archiving and compliance. To find 
out more visit the Mimecast website.

Reply via email to