tree d0fddd08bc8d31f37fd5572d26c080ac64b77081
parent 5ed70a91895d70bceedd6976e2ac7df7eef68ea0
author Matteo Merli <mmerli@yahoo-inc.com> 1478850174 -0800
committer Matteo Merli <mmerli@apache.org> 1481673112 -0800

Use receiveAsync() to aggregate messages into shared queue for partitioned consumer