org.apache.kafka.clients.admin

Class ClusterLinkDescription

java.lang.Object

org.apache.kafka.clients.admin.ClusterLinkDescription

public class ClusterLinkDescription
extends Object

A description of a cluster that's linked.

Nested Class Summary

Nested Classes

Modifier and Type	Class and Description
static class	ClusterLinkDescription.ConnectionMode
static class	ClusterLinkDescription.LinkMode
static class	ClusterLinkDescription.LinkState

Constructor Summary

Constructors

Constructor and Description
ClusterLinkDescription(String linkName, Uuid linkId, String remoteClusterId, String localClusterId, Collection<String> topics, ClusterLinkDescription.LinkState linkState, ClusterLinkDescription.LinkMode linkMode, ClusterLinkDescription.ConnectionMode connectionMode) Creates a cluster link description.

Method Summary

Modifier and Type	Method and Description
Uuid	clusterLinkId()
ClusterLinkDescription.ConnectionMode	connectionMode() Connection mode.
boolean	equals(Object o)
int	hashCode()
ClusterLinkDescription.LinkMode	linkMode() Link mode.
String	linkName() The link name for the cluster link.
ClusterLinkDescription.LinkState	linkState()
String	localClusterId()
String	remoteClusterId()
Optional<Collection<String>>	topics() The topics that are linked with the cluster link, otherwise if empty, then the topics weren't requested.
String	toString()

Methods inherited from class java.lang.Object

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

Constructor Detail

ClusterLinkDescription

public ClusterLinkDescription(String linkName,
                              Uuid linkId,
                              String remoteClusterId,
                              String localClusterId,
                              Collection<String> topics,
                              ClusterLinkDescription.LinkState linkState,
                              ClusterLinkDescription.LinkMode linkMode,
                              ClusterLinkDescription.ConnectionMode connectionMode)

Creates a cluster link description.

Parameters:

linkName - The link name for the cluster link

linkId - The UUID associated with the cluster link

remoteClusterId - linked cluster's ID, or null if not known.

localClusterId - Local cluster id.

topics - The topics that are linked with the cluster link, otherwise if null, then the topics weren't requested.

linkState - The link state.

linkMode - The link mode. Can be unknown if link state is failed.

connectionMode - The connection mode. Can be unknown if the link state is failed.

Method Detail

linkName

public String linkName()

The link name for the cluster link.

clusterLinkId

public Uuid clusterLinkId()

remoteClusterId

public String remoteClusterId()

localClusterId

public String localClusterId()

topics

public Optional<Collection<String>> topics()

The topics that are linked with the cluster link, otherwise if empty, then the topics weren't requested.

linkState

public ClusterLinkDescription.LinkState linkState()

linkMode

public ClusterLinkDescription.LinkMode linkMode()

Link mode. Can be unknown if link state is failed.

connectionMode

public ClusterLinkDescription.ConnectionMode connectionMode()

Connection mode. Can be unknown if link state is failed.

equals

public boolean equals(Object o)

Overrides:

equals in class Object

hashCode

public int hashCode()

Overrides:

hashCode in class Object

toString

public String toString()

Overrides:

toString in class Object