package org.apache.kafka.clients;

public final class Metadata {
  public interface Listener {
    void onMetadataUpdate(Cluster cluster, Set<String> unavailableTopics);
  }
}