apache / apache/pulsar-client-go

producer was blocked when I set too Larger value to DeliverAfter column for delay message

Open
#964 2 comments 0 reactions 0 assignees View on GitHub
Dominant language
Go
Stars
745
Forks
389
Avg merge
3d 20h
Merged PRs (30d)
3

Description

#### Expected behavior

message will DeliverAfter 60000 min

#### Actual behavior

The producer was blocked when I set 60000 min to DeliverAfter column for delay message

The context.WithTimeout is not worked.

I can not send any message to pulsar with this producer

#### Steps to reproduce

&pulsar.ProducerMessage{
Key: "",
Payload: []byte() ,
DeliverAfter: time.Duration(60000)*time.Minute,
}

#### System configuration
github.com/apache/pulsar-client-go v0.8.1
go 1.17.10

Contributor guide

Open the contributing guide

Research direction

Start with the ProducerMessage DeliverAfter handling and the context.WithTimeout path described in the report, then reproduce the issue using a 60000-minute delay. Done means the producer accepts the delay without blocking and can continue sending other messages to Pulsar.

Written by the indexing model from the issue text.

Assessment

Tech stack
go
Domain
distributed-systems
Issue type
Bug
Difficulty
3/5
Estimated time
1-2 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.