The test now runs in one of two modes.  the default which is to read from the topic from the beginning, in which case the test should pick up messages that were dumped to the topic even before the topology started. The other mode is    --fromCurrentOffset, which implies that the topology should only pick up messages that were dumped to the topic after the topology started.