Class ClusterLinkDescription.Builder
java.lang.Object
org.apache.kafka.clients.admin.ClusterLinkDescription.Builder
- Enclosing class:
ClusterLinkDescription
-
Constructor Summary
Constructors -
Method Summary
Modifier and TypeMethodDescriptionbuild()setClusterLinkError(ClusterLinkError clusterLinkError) setConnectionMode(ClusterLinkDescription.ConnectionMode connectionMode) setLinkCoordinator(Node linkCoordinator) setLinkCoordinatorPartitionId(int linkCoordinatorPartitionId) setLinkErrorMessage(String linkErrorMessage) setLinkMode(ClusterLinkDescription.LinkMode linkMode) setLinkName(String linkName) setLinkState(ClusterLinkDescription.LinkState linkState) setLocalClusterId(String localClusterId) setPartitionStateCategoryCounts(Map<org.apache.kafka.common.replica.ReplicaStatus.MirrorInfo.StateCategory, Integer> partitionStateCategoryCounts) setRemoteClusterId(String remoteClusterId) setRemoteLinkError(ClusterLinkError remoteLinkError) setRemoteLinkErrorMessage(String remoteLinkErrorMessage) setRemoteLinkState(ClusterLinkDescription.LinkState remoteLinkState) setRemoteLinkStateTimeMs(long remoteLinkStateTimeMs) setTaskDescriptions(List<ClusterLinkTaskDescription> taskDescriptions) setTopics(Collection<String> topics)
-
Constructor Details
-
Builder
public Builder()
-
-
Method Details
-
setLinkName
-
setLinkId
-
setRemoteClusterId
-
setLocalClusterId
-
setTopics
-
setLinkState
-
setLinkMode
-
setConnectionMode
public ClusterLinkDescription.Builder setConnectionMode(ClusterLinkDescription.ConnectionMode connectionMode) -
setClusterLinkError
-
setLinkErrorMessage
-
setRemoteLinkState
public ClusterLinkDescription.Builder setRemoteLinkState(ClusterLinkDescription.LinkState remoteLinkState) -
setRemoteLinkError
-
setRemoteLinkErrorMessage
-
setRemoteLinkStateTimeMs
-
setTaskDescriptions
public ClusterLinkDescription.Builder setTaskDescriptions(List<ClusterLinkTaskDescription> taskDescriptions) -
setLinkCoordinator
-
setPartitionStateCategoryCounts
public ClusterLinkDescription.Builder setPartitionStateCategoryCounts(Map<org.apache.kafka.common.replica.ReplicaStatus.MirrorInfo.StateCategory, Integer> partitionStateCategoryCounts) -
setLinkCoordinatorPartitionId
-
build
-