Package org.apache.kafka.connect.mirror

Class RemoteClusterUtils

java.lang.Object

org.apache.kafka.connect.mirror.RemoteClusterUtils

public final class RemoteClusterUtils
extends Object

Convenience methods for multi-cluster environments. Wraps MirrorClient

Properties passed to these methods are used to construct internal Admin and Consumer clients. Sub-configs like "admin.xyz" are also supported. For example:

      bootstrap.servers = host1:9092
      consumer.client.id = mm2-client
  

See Also:

• for additional properties used by the internal MirrorClient.

Method Summary

Modifier and Type	Method	Description
static Set<String>	checkpointTopics(Map<String,Object> properties)	Find all checkpoint topics
static Set<String>	heartbeatTopics(Map<String,Object> properties)	Find all heartbeat topics
static int	replicationHops(Map<String,Object> properties, String upstreamClusterAlias)	Find shortest number of hops from an upstream cluster.
static Map<TopicPartition,OffsetAndMetadata>	translateOffsets(Map<String,Object> properties, String remoteClusterAlias, String consumerGroupId, Duration timeout)	Translate a remote consumer group's offsets into corresponding local offsets.
static Set<String>	upstreamClusters(Map<String,Object> properties)	Find all upstream clusters

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Method Details

replicationHops

public static int replicationHops(Map<String,Object> properties,
 String upstreamClusterAlias)
                           throws InterruptedException,
TimeoutException

Find shortest number of hops from an upstream cluster. Returns -1 if the cluster is unreachable

Throws:

InterruptedException

TimeoutException

heartbeatTopics

public static Set<String> heartbeatTopics(Map<String,Object> properties)
                                   throws InterruptedException,
TimeoutException

Find all heartbeat topics

Throws:

InterruptedException

TimeoutException

checkpointTopics

public static Set<String> checkpointTopics(Map<String,Object> properties)
                                    throws InterruptedException,
TimeoutException

Find all checkpoint topics

Throws:

InterruptedException

TimeoutException

upstreamClusters

public static Set<String> upstreamClusters(Map<String,Object> properties)
                                    throws InterruptedException,
TimeoutException

Find all upstream clusters

Throws:

InterruptedException

TimeoutException

translateOffsets

public static Map<TopicPartition,OffsetAndMetadata> translateOffsets(Map<String,Object> properties,
 String remoteClusterAlias,
 String consumerGroupId,
 Duration timeout)
                                                              throws InterruptedException,
TimeoutException

Translate a remote consumer group's offsets into corresponding local offsets. Topics are automatically renamed according to the ReplicationPolicy.

Parameters:

properties - MirrorClientConfig properties to instantiate a MirrorClient

consumerGroupId - group ID of remote consumer group

remoteClusterAlias - alias of remote cluster

timeout - timeout

Throws:

InterruptedException

TimeoutException