getReplicateInfo()

This operation gets replication checkpoint information for a target physical channel. Use it before dumping messages or diagnosing cross-cluster replication progress.

public GetReplicateInfoResp getReplicateInfo(GetReplicateInfoReq request)

Request Syntax

getReplicateInfo(GetReplicateInfoReq.builder()
    .sourceClusterId(String sourceClusterId)
    .targetPchannel(String targetPchannel)
    .build());

BUILDER METHODS:

• sourceClusterId(String sourceClusterId)

  The source cluster ID to inspect.

• targetPchannel(String targetPchannel)

  The target physical channel whose replicate checkpoint should be returned.

RETURNS:

GetReplicateInfoResp

EXCEPTIONS:

• MilvusClientException

  This exception will be raised when validation fails or the server returns an error for this operation.

Example

MilvusClientV2 client = new MilvusClientV2(ConnectConfig.builder()
    .uri("http://localhost:19530")
    .token("root:Milvus")
    .build());

GetReplicateInfoResp resp = client.getReplicateInfo(GetReplicateInfoReq.builder()
    .sourceClusterId("cluster-a")
    .targetPchannel("by-dev-rootcoord-dml_0_123v0")
    .build());
System.out.println(resp.getCheckpoint());