org.apache.kafka.clients.admin

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 and Description
NewClusterLink(String linkName, String clusterId, Map<String,String> configs) Creates a new cluster link with the specified configs.

Method Summary

Modifier and Type	Method and 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()
String	linkName() The name of the cluster link to be created.
String	toString()

Methods inherited from class java.lang.Object

clone, finalize, getClass, notify, notifyAll, wait, wait, wait

Constructor Detail

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

Method Detail

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.

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