Interface LinkManager

public interface LinkManager
A service to manage Kafka links.

  • Method Details

    • listLinks

      CompletableFuture<List<Link>> listLinks(String clusterId)
      Returns the list of Kafka links belonging to the Cluster with the given clusterId.

    • getLink

      CompletableFuture<Optional<Link>> getLink(String clusterId, String linkName, @Nullable Boolean includeTasks)
      Returns the specific Kafka links belonging to the Cluster with the given clusterId and the given linkName.

    • createLink

      CompletableFuture<Void> createLink(String localClusterId, Optional<String> srcClusterId, Optional<String> destClusterId, Optional<String> remoteClusterId, Optional<String> clusterLinkId, String linkName, Map<String,String> configs, boolean validateLink, boolean validateOnly)
      Creates a new Kafka link. srcClusterId and destClusterId are deprecated and remoteClusterId should be used instead.
      Parameters:
      localClusterId - the local cluster id
      srcClusterId - deprecated. Only relevant when creating link at destination cluster
      destClusterId - deprecated. Only relevant when creating link at source cluster
      remoteClusterId - the remote cluster ID.
      clusterLinkId - the link id for a source or bi-directional cluster link.

    • deleteLink

      CompletableFuture<Void> deleteLink(String clusterId, String linkName, boolean force, boolean validateOnly)
      Deletes the Kafka link with the given linkName.