CODEWITHSUNDEEP
apache-pulsarpulsarpython-pulsar
user3863316
user3863316

Reputation: 13

Pulsar producer send_async() with callback function acknowledging the sent message

I have a use case where messages from an input_topic gets consumed and sent to a list of topics. I'm using producers[i].send_async(msg, callback=callback) where callback = lambda res, msg: consumer.acknowledge(msg). In this case, consumer is subscribed to the input_topic. I checked the backlog of input_topic and it has not decreased at all. Would appreciate if you could point out how to deal with this? What would be the best alternative?

Thanks in advance!

Upvotes: 1

Views: 734

Answers (1)

Penghui Li
Penghui Li

Reputation: 111

Have you checked the consumer.acknowledge(msg) has actually been called? One possibility is the producer cannot write messages to the topic, and if the producer with infinite send timeout, you will never get the callback.

Upvotes: 1

Related Questions