merlimat commented on issue #2298: Wait for consumer “creation” to be completed before start delivering URL: https://github.com/apache/incubator-pulsar/issues/2298#issuecomment-410890925 @zubchenok While I have seen that this issue might happen with multi-topic subscribe (which is in 2.x anyway), I don't see it happening when subscribing to either single or partitioned topics. At https://github.com/apache/incubator-pulsar/blob/c9a369936af3b3ecc663b86ae959a3fbfa627aca/pulsar-client/src/main/java/org/apache/pulsar/client/impl/ConsumerImpl.java#L586-589 is where first the future is completed and then, the client will send "permits" to have broker to start message delivery. Since you mentioned `subscribeAsync()`, are you processing the result of that future from same thread or spawing to a different thread? (eg: `thenAccept()` vs `thenAcceptAsync()`. Then 2nd will use a background thread to execute, so there would be no ordering of when it will be invoked.
---------------------------------------------------------------- This is an automated message from the Apache Git Service. To respond to the message, please log on GitHub and use the URL above to go to the specific comment. For queries about this service, please contact Infrastructure at: [email protected] With regards, Apache Git Services
