Class NewClusterLink

java.lang.Object
org.apache.kafka.clients.admin.NewClusterLink
public class NewClusterLinkextends Object
A new cluster link to be created via ConfluentAdmin.createClusterLinks(Collection, CreateClusterLinksOptions).

  • Constructor Details

    • NewClusterLink

      public NewClusterLink(String linkName, String clusterId, Map<String,String> configs)
      Creates a new cluster link with the specified configs.
      Parameters:
      linkName - the name assigned to the cluster link
      clusterId - the ID of the cluster link, or null if not validated
      configs - the initial configuration values

    • NewClusterLink

      public NewClusterLink(String linkName, String clusterId, Map<String,String> configs, Uuid linkId)

  • Method Details

    • linkName

      public String linkName()
      The name of the cluster link to be created.

    • clusterId

      public String clusterId()
      The ID of the cluster link, or null if not provided.

    • linkId

      public Uuid linkId()
      The link id for a source or bi-directional cluster link. If provided, a link with this id must exist on the remote cluster.

    • configs

      public Map<String,String> configs()
      The configuration for the new cluster link.

    • toString

      public String toString()
      Overrides:
      toString in class Object

    • equals

      public boolean equals(Object o)
      Overrides:
      equals in class Object

    • hashCode

      public int hashCode()
      Overrides:
      hashCode in class Object