Understanding behaviour of consumer_groups in flow...
# umh-support
p
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?
8 Views