Refactor ConsumeData, avoid setting Kafka group base, set unique Kafka groups, and put in place a not-yet-working framework for reading update queue data in test