-
Notifications
You must be signed in to change notification settings - Fork 368
Open
Description
This CI failure exposed the issue: https://github.com/apache/pulsar-client-go/actions/runs/15014358114/job/42188862912#step:6:2767
Actual behavior
Consumer will fail immediately without any retry for the subscription fence error.
time="2025-05-14T07:09:02Z" level=error msg="Failed to create consumer" consumerID=8 error="server error: ServiceNotReady: Subscription is fenced" name=ypbxo subscription=my-sub topic="persistent://public/default/my-topic-437318013-partition-0"
consumer_test.go:2346:
Error Trace: /pulsar/pulsar-client-go/pulsar/consumer_test.go:2346
Error: Expected nil, but got: &errors.errorString{s:"server error: ServiceNotReady: Subscription is fenced"}
Test: TestConsumerAddTopicPartitions
Expected behavior
Consumer should retry for the subscription fence error
Metadata
Metadata
Assignees
Labels
No labels