public void ensureActiveGroup() {
        while (!ensureActiveGroup(time.timer(Long.MAX_VALUE))) {
            log.warn("still waiting to ensure active group");
        }
    }
Ensure that the group is active (i.e. joined and synced)
clients/src/main/java/org/apache/kafka/clients/consumer/internals/AbstractCoordinator.java