MINOR: Log consumer groups mirrored by checkpoint tasks (#13389)

Reviewers: Chris Egerton <fearthecellos@gmail.com>
This commit is contained in:
Mickael Maison 2023-03-16 14:22:36 +01:00 committed by GitHub
parent 79b5f7f1ce
commit 34ec6bdef8
No known key found for this signature in database
GPG Key ID: 4AEE18F83AFDEB23
1 changed files with 2 additions and 0 deletions

View File

@ -109,6 +109,8 @@ public class MirrorCheckpointTask extends SourceTask {
scheduler.scheduleRepeatingDelayed(this::syncGroupOffset, config.syncGroupOffsetsInterval(),
"sync idle consumer group offset from source to target");
}, "starting offset sync store");
log.info("{} checkpointing {} consumer groups {}->{}: {}.", Thread.currentThread().getName(),
consumerGroups.size(), sourceClusterAlias, config.targetClusterAlias(), consumerGroups);
}
@Override