Page History

/**
 * Translates remote consumer groups' offsets into corresponding local offsets. Topics are automatically
 *  renamed according to the configured {@link ReplicationPolicy}.
 *  @param properties Map of properties to instantiate a {@link MirrorClient}
 *  @param remoteClusterAlias The alias of the remote cluster
 *  @param consumerGroupPattern The regex pattern specifying the consumer groups to translate offsets for
 *  @param timeout The maximum time to block when consuming from the checkpoints topic
 *  @throws IllegalArgumentException If any of the arguments are null
 */
public static Map<String, Map<TopicPartition, OffsetAndMetadata>> translateOffsets(Map<String, Object> properties, String remoteClusterAlias, Pattern consumerGroupPattern, Duration timeout) {
}

/**
 * Translates remote consumer groups' offsets into corresponding local offsets. Topics are automatically
 * renamed according to the ReplicationPolicy.
 * @param consumerGroupPattern The regex pattern specifying the consumer groups to translate offsets for
 * @param remoteClusterAlias The alias of remote cluster
 * @param timeout The maximum time to block when consuming from the checkpoints topic
 * @throws IllegalArgumentException If any of the arguments are null
 */
public Map<String, Map<TopicPartition, OffsetAndMetadata>> remoteConsumerOffsets(Pattern consumerGroupPattern, String remoteClusterAlias, Duration timeout) {
}