Hey guys, another question:
I am currently experiencing some unexpected behavior regarding consumer groups in my flows when I send messages to UNS and try to listen to them from another flow.
As far as I understand, each flow automatically gets its own consumer group. However, I’ve observed the following:
When a flow fails during startup, it seems that something in the associated consumer group becomes unusable or corrupted.
After such a failure, restarting the flow does not work reliably unless I change the consumer group.
As a workaround, I started explicitly defining the consumer_group in each flow configuration.
If a flow fails again, I increment the group (e.g., v1 → v2) to make it work again.
This behavior feels unusual to me, since rotating consumer groups per failure does not seem like the intended usage.
Could you please help me understand:
What could cause a consumer group to become unusable after a failed start?
Is there a recommended way to recover or reset a consumer group without creating a new one?
Am I missing a best practice here?