cgfork opened a new issue #367:
URL: https://github.com/apache/pulsar-client-go/issues/367
#### Expected behavior
The message should not be delay.
#### Actual behavior
The message was delayed.
#### Steps to reproduce
```go
client, err := pulsar.NewClient(pulsar.ClientOptions{
URL: "pulsar://pulsar-test.com:6650",
ConnectionTimeout: time.Second,
OperationTimeout: time.Second,
})
if err != nil {
panic(err)
}
opts := DefaultOptions()
newProducer, err := client.CreateProducer(pulsar.ProducerOptions{
Topic: "Pulsar-Debug",
Name: "Pulsar-Test",
MaxPendingMessages: opts.Producer.MaxPendingMessages,
BatchingMaxMessages: opts.Producer.BatchingMaxMessages,
})
if err != nil {
panic(err)
}
newProducer.SendAsync(context.TODO(), &pulsar.ProducerMessage{
Payload: []byte("delay - 3"),
DeliverAfter: time.Minute * 10,
}, func(id pulsar.MessageID, message *pulsar.ProducerMessage, err
error) {
fmt.Println("send delay success")
})
newProducer.SendAsync(context.TODO(), &pulsar.ProducerMessage{
Payload: []byte("no delay - 3"),
}, func(id pulsar.MessageID, message *pulsar.ProducerMessage, err
error) {
fmt.Println("send no delay success")
})
time.Sleep(time.Second * 10)
}
```
#### System configuration
**Pulsar version**: 2.5.0
**Client version**: 0.10, 0.2.0
----------------------------------------------------------------
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.
For queries about this service, please contact Infrastructure at:
[email protected]
