You signed in with another tab or window. Reload to refresh your session.You signed out in another tab or window. Reload to refresh your session.You switched accounts on another tab or window. Reload to refresh your session.Dismiss alert
In PIP-106 and #660, the Pulsar SDK for Golang has supported NackBackoffPolicy. However, using a topic with 1 partition, the following code may not use the backoff policy:
And in the implementation of Add() method, it's obviously impossible to use the back off policy, since redeliver count is not available, so default back off delay is used.
I'm not sure if my code is using the back off policy in the right way, or this is a bug in the SDK, or our broker is having some issue.
The text was updated successfully, but these errors were encountered:
In PIP-106 and #660, the Pulsar SDK for Golang has supported
NackBackoffPolicy
. However, using a topic with 1 partition, the following code may not use the backoff policy:After some digging I found the following call stack:
Nack
for a message is implemented inpulsar/consumer_impl.go
, it may call the consumer carried by atrackingMessageID
trackingMessageID
definedNack()
atpulsar/impl_message.go
, callingNackID()
NackID()
is implemented atpulsar/consumer_partition.go
, callingAdd()
method for the nack tracker.And in the implementation of
Add()
method, it's obviously impossible to use the back off policy, since redeliver count is not available, so default back off delay is used.I'm not sure if my code is using the back off policy in the right way, or this is a bug in the SDK, or our broker is having some issue.
The text was updated successfully, but these errors were encountered: