public void ensureActive(Supplier<UncheckedCloseable> onPoll) {
        coordinator.poll(0, onPoll);
    }
Ensure that the connection to the broker coordinator is up and that the worker is an
active member of the group.
connect/runtime/src/main/java/org/apache/kafka/connect/runtime/distributed/WorkerGroupMember.java