This is due to partitions you are consuming from. Documentation section explains what needs to be done.
On 10 August 2017 at 11:43, Ascot Moss <[email protected]> wrote: > A question: > > (input order) > test1 > test2 > test3 > test 2017-08-10 > |2017-08-10 test1 > 2017-08-10 test2 > > > If get them using > *--from-beginning* > (received order) > test1 > test 2017-08-10 > 2017-08-10 test1 > test2 > test3 > 2017-08-10 test2 > > Any idea how to get the message in the original order as input? >
