Thanks for the quick response Damian. I'll update my processors and
retest. 👍
On Thu, Feb 2, 2017 at 9:27 AM, Damian Guy wrote:
> Hi Matthew,
> You shouldn't close the stores in your custom processors. They are closed
> automatically by the framework during rebalances and shutdown.
> There is a
Hi Matthew,
You shouldn't close the stores in your custom processors. They are closed
automatically by the framework during rebalances and shutdown.
There is a good chance that your closing of the stores is causing the
issue. Of course if you see the exception again then please report back so
we ca
Hey all,
When an instance of a streams Processor is closed, is it supposed to call
close() on any state stores that it retrieved from the ProcessorContext in
its own close()?
I started following the pattern of having every Processor close every state
store based upon this documentation's example
