docs: public static LeaderConnectionInfo retrieveLeaderConnectionInfo(
  			LeaderRetrievalService leaderRetrievalService,
  			FiniteDuration timeout
  	) throws LeaderRetrievalException {
  		LeaderConnectionInfoListener listener = new LeaderConnectionInfoListener();
  
  		try {
  			leaderRetrievalService.start(listener);
  
  			Future<LeaderConnectionInfo> connectionInfoFuture = listener.getLeaderConnectionInfoFuture();
  
  			return Await.result(connectionInfoFuture, timeout);
  		} catch (Exception e) {
  			throw new LeaderRetrievalException("Could not retrieve the leader address and leader " +
  					"session ID.", e);
  		} finally {
  			try {
  				leaderRetrievalService.stop();
  			} catch (Exception fe) {
  				LOG.warn("Could not stop the leader retrieval service.", fe);
  			}
  		}
  	}