void checkListenerCall(DataNodeConfigChangeListener listener, Set<DataNodeConfig> expectedConfigs) {
    verify(listener, timeout(500)).onDataNodeConfigChange(argThat(configs -> {
      Set<DataNodeConfig> configsReceived = new HashSet<>();
      configs.forEach(configsReceived::add);
      return configsReceived.equals(expectedConfigs);
    }));
  }
Check that {@link DataNodeConfigChangeListener#onDataNodeConfigChange} was called with the specified configs
within a short period of time.
@param listener the {@link DataNodeConfigChangeListener} to check.
@param expectedConfigs the set of configs expected.
ambry-clustermap/src/test/java/com/github/ambry/clustermap/DataNodeConfigSourceTestBase.java