zbentley commented on issue #15704: URL: https://github.com/apache/pulsar/issues/15704#issuecomment-1134705707
While I don't know much about this area of the code, that sounds fine to me. Other solutions that may make sense: - Document that a zero queue size with a partitioned topic would potentially buffer up to N messages (where N is the number of partitions on the topic). - Sequentially loop over the internal receive calls for each partition, returning when a message is found on any. The interactions with the timeout and missed deliveries might be undesirable here though. -- 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]
