Class NewClusterLink

java.lang.Object

org.apache.kafka.clients.admin.NewClusterLink

public class NewClusterLink
extends Object

A new cluster link to be created via ConfluentAdmin.createClusterLinks(Collection, CreateClusterLinksOptions).

Constructor Summary

Constructors

Constructor	Description
NewClusterLink(String linkName, String clusterId, Map<String,String> configs)	Creates a new cluster link with the specified configs.
NewClusterLink(String linkName, String clusterId, Map<String,String> configs, Uuid linkId)

Method Summary

Modifier and Type	Method	Description
String	clusterId()	The ID of the cluster link, or null if not provided.
Map<String,String>	configs()	The configuration for the new cluster link.
boolean	equals(Object o)
int	hashCode()
Uuid	linkId()	The link id for a source or bi-directional cluster link.
String	linkName()	The name of the cluster link to be created.
String	toString()

Methods inherited from class java.lang.Object

getClass, notify, notifyAll, wait, wait, wait

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