apache / apache/pulsar-client-go

Client.Subscribe() times out but the broker successfully created the consumer

Open
#187 1 comment 0 reactions 0 assignees View on GitHub
triage/week-15
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

Open the contributing 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

Get new issues in your inbox

A short digest of beginner-friendly GitHub issues.