Started writing a unit test around multiproc consumer with start and end offsets.
WIP:testing offset
A more succinct way of calculating common offset
Rename begin_offset to start_offset
clean up the test.