congbobo184 commented on issue #11002:
URL: https://github.com/apache/pulsar/issues/11002#issuecomment-867631436


   now, transaction delete marker is an asynchronous operation, if new messages 
continue produce and ack message continue, there will not produce problem. in 
some race condition, ack message1 the `delete marker` in process and ack 
message2 will not in `delete marker` process, in this time the producer don't 
send new message to broker and will not process the ack operation. the sub may 
not delete the message1 commit marker. So we should start a timer task in 
broker to check the sub `delete transaction marker`.


-- 
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:
us...@infra.apache.org


Reply via email to