[GitHub] [pulsar] MarvinCai opened a new issue #10222: [Bug] Message can arrive out of order for MultiTopicConsumer

[GitBox <gi...@apache.org>]

MarvinCai opened a new issue #10222:
URL: https://github.com/apache/pulsar/issues/10222


   See #10173 for more detail and instruction to reproduce.
   
   Seems the root cause is, for `MultiTopicConsumer`, when it tries to receive messages from an underlying Consumer `C` for a single topic partition, if `C.incomingMessages` (consumer's receiver queue) has message, then message will be processed by the "pulsar-client-internal" executor, if `C.incomingMessages` doesn't have message, then it'll queued as pending request and when message arrives it'll be picked up and process by the "pulsar-external-listener" executor, which could cause nondeterministic order even for a single partition.


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

[GitHub] [pulsar] codelipenghui closed issue #10222: [Bug] Message can arrive out of order for MultiTopicConsumer

[GitBox <gi...@apache.org>]

codelipenghui closed issue #10222:
URL: https://github.com/apache/pulsar/issues/10222


   


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