DUE TO SPAM, SIGN-UP IS DISABLED. Goto Selfserve wiki signup and request an account.
...
| Code Block | ||
|---|---|---|
| ||
/**
* Translates remote consumer groups' offsets into corresponding local offsets. Topics are automatically
* renamed according to the ReplicationPolicy.
* @param consumerGroupIds The set of consumer group Ids
* @param remoteClusterAlias The alias of remote cluster
* @param timeout The maximum time to block when consuming from the checkpoints topic
*/
public Map<String, Map<TopicPartition, OffsetAndMetadata>> remoteConsumerOffsets(Set<String> consumerGroupIds, String remoteClusterAlias, Duration timeout) {
} |
For both methods, in case there are no offsets for a group, the Map will still contain an entry with the group Id as the key but the value will be an empty Map.
Proposed Changes
The existing MirrorClient.remoteConsumerOffsets() will invoke the new method with a Set containing just a single consumer group Id.
...