commit | 5b9c9e752d36f1f2c0a1d949fe1f1909a20e1b65 | [log] [tgz] |
---|---|---|
author | Matteo Merli <mmerli@yahoo-inc.com> | Thu Nov 10 23:42:54 2016 -0800 |
committer | Matteo Merli <mmerli@apache.org> | Tue Dec 13 15:51:52 2016 -0800 |
tree | d0fddd08bc8d31f37fd5572d26c080ac64b77081 | |
parent | 5ed70a91895d70bceedd6976e2ac7df7eef68ea0 [diff] |
Use receiveAsync() to aggregate messages into shared queue for partitioned consumer
Pulsar is a distributed pub-sub messaging platform with a very flexible messaging model and an intuitive client API.
Copyright 2016 Yahoo Inc.
Licensed under the Apache License, Version 2.0: http://www.apache.org/licenses/LICENSE-2.0