apache / apache/pulsar-client-go
Client.Subscribe() times out but the broker successfully created the consumer
- Dominant language
- Go
- Stars
- 745
- Forks
- 389
- Avg merge
- 3d 20h
- Merged PRs (30d)
- 3
Description
#### Expected behavior
if the Client.Subscribe times out, the created consumer should be closed
#### Actual behavior
Client.Subscribe() times out.In fact, the broker successfully created the consumer. The time taken by the broker just exceeded the value of the operationTimeout.
#### System configuration
**Pulsar version**: 2.4.0
Contributor guide
Research direction
Start at Client.Subscribe and trace how operationTimeout interacts with the broker's consumer-creation response. Reproduce the case where the broker responds after the timeout, then verify that a consumer created in that situation is closed and that the normal subscription path still works.
Written by the indexing model from the issue text.
Assessment
- Tech stack
- go
- Domain
- distributed-systems
- Issue type
- Bug
- Difficulty
- 4/5
- Estimated time
- 3-5 days
- Activity status
- Stale
- Clarity
- Mostly clear
- Newbie friendliness
- 35/100