TakaHiR07 commented on issue #17040: URL: https://github.com/apache/pulsar/issues/17040#issuecomment-1214544142
I have added many log in the code, and found that it is blocked in topic.checkIfTransactionBufferRecoverCompletely in handleProducer(). Then I found that the object transactionBufferFuture in TopicTransactionBuffer was not completed, because it did not finish TopicTransactionBufferRecover#run(). The problem was blocked in the reader.readNext() method. I found that reader can read the 1,2,3 message successfully, but when reader read the 4th message, it would block and thus over the 30s timeout.  -- 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. To unsubscribe, e-mail: [email protected] For queries about this service, please contact Infrastructure at: [email protected]
