Hi Sathya,
MyProcessor does not have access to MySource, because in MySource you
just build the topology that is then executed by Kafka Streams. So you
cannot send anything to MySource, because MyProcessor does not know
anything about MySource.
If you want to stop consumption upon an excepti
Hi there
i m sathya,
i have below requirements in my project , please let me know how to
achieve this requirement.
These are my two kafka stream classes
1. MySource
2. MyProcessor
and Mysource class sends continues stream of data and retrieved in process
method of Myprocessor class.
My requi
