Hey Peter
Try clearing the local state -- if you have stateful tasks then by default
Streams will use rocksdb to
store records locally in directories specific to/named after that task.
This is presumably why you're
seeing errors related to "the task for peek node missing in old nodes"
You can del
Hello,
I am looking for help regarding topologies and tasks in KS. Mostly where
this information is stored outside of KS app.
My case is upgrading the KS topology from v1 to v2, the topology is
different (f.e adding peek node in v2). I made a change in code, prepared a
jar and deployed.
The iss
