DUE TO SPAM, SIGN-UP IS DISABLED. Goto Selfserve wiki signup and request an account.
| Table of Contents |
|---|
Status
Current state: Under DiscussionAccepted
Discussion thread: here
Voting thread:here
JIRA: TODO KAFKA-20229
Please keep the discussion on the mailing list rather than commenting on the wiki (wiki discussions get unwieldy fast).
...
| Code Block | ||
|---|---|---|
| ||
/**
* 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) {
} |
...
| Code Block | ||
|---|---|---|
| ||
/** * 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) { } |
...