hepyu commented on issue #12800: URL: https://github.com/apache/pulsar/issues/12800#issuecomment-975290026
> 附： pulsar push方式的实现原理： https://pulsar.apache.org/docs/zh-CN/next/develop-binary-protocol/#%E6%B5%81%E9%87%8F%E6%8E%A7%E5%88%B6 > > 我们最终采取的方案是：不使用client提供的方案，自己实现。 每个key_shard用一个thread消费，从receiveQueue中取出消息扔到一个阻塞队列，这个阻塞队列的长度是1，这样就可以规避这个issue的问题了：真正的根据消费能力通知pulsar-broker往consumer推送消息。 @wangjialing218 @hpvd @codelipenghui 强烈建议pulsar-client提供一个这样的类似机制。很实用。 -- 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]
