Collection<CompletableFuture<Void>> getPendingFutures() {
    return pendingFutures;
  }
Gets pending futures. Used by the test.

@return the pending futures
samza-azure/src/main/java/org/apache/samza/system/eventhub/producer/EventHubSystemProducer.java