pulsar-client-node
pulsar-client-node copied to clipboard
send delayed message, but consume immediately
pulsar-server 3.0.1 pulsar-client 1.9.0 node v19.6.0
I cannot send delayed messages.
producer.send({
data: Buffer.from(JSON.stringify(Date.now())),
deliverAfter: 30000
});
Is there some thing wrong?
Can you check your broker configuration?
https://pulsar.apache.org/docs/3.1.x/concepts-messaging/#broker
Delayed message delivery is enabled.
delayedDeliveryEnabled=true
delayedDeliveryTrackerFactoryClassName=org.apache.pulsar.broker.delayed.InMemoryDelayedDeliveryTrackerFactory
delayedDeliveryTickTimeMillis=1000
I think broker configs is ok.
Golang client works.
https://github.com/shibd/pulsar-node-delayed-test
You can refer to this repository for testing.