As mentioned (and created) in #111, Payloads are passed from the appliance to the CountertopWorker via events, which have no mechanism to communicate backpressure.
We need to either:
Use the temporary approach suggested by @chriszs which allows the event to pass a callback.
Now that we have closed out #119 I believe the memory leak is gone (backpressure is now handled by kafka / kafka won't pass data if things are blocked up in the appliances)
Task
Description
As mentioned (and created) in #111, Payloads are passed from the appliance to the CountertopWorker via events, which have no mechanism to communicate backpressure.
We need to either:
Relevant Resources / Research