pulsar-client-go
pulsar-client-go copied to clipboard
producer was blocked when I set too Larger value to DeliverAfter column for delay message
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