public boolean isDone() {
            return futures.stream().allMatch(Future::isDone);
        }
Wrapper class to aggregate producer futures and abstract away the record metadata from the
Connect user.
connect/runtime/src/main/java/org/apache/kafka/connect/runtime/errors/WorkerErrantRecordReporter.java