using handcrafted messages instead of Ensembles produced by protobuf
minimizing gc load, using buffers and serialized Points as much as possible
adopting serialized points passing
use more convenient range builder 'until' instead of 'to'
fixed wrong stream usage
properly encode message key
fixed test
wrong points number assigned to PartitionBuffer in case of full consuming
moving test to the right place
moving around
moving around test case
remove noisy logging
extracting test utilites
bug fixing and optimization for points queue
renaming PendingPoints to PointsQueue