Class ClusterLinkDescription.Builder
java.lang.Object
org.apache.kafka.clients.admin.ClusterLinkDescription.Builder
- Enclosing class:
ClusterLinkDescription
Constructor Summary
ConstructorsMethod 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