OmniaGM commented on code in PR #15999: URL: https://github.com/apache/kafka/pull/15999#discussion_r1608666902
########## connect/mirror/src/main/java/org/apache/kafka/connect/mirror/MirrorSourceTask.java: ########## @@ -112,12 +115,15 @@ public void start(Map<String, String> props) { @Override public void commit() { - // Offset syncs which were not emitted immediately due to their offset spacing should be sent periodically - // This ensures that low-volume topics aren't left with persistent lag at the end of the topic - promoteDelayedOffsetSyncs(); - // Publish any offset syncs that we've queued up, but have not yet been able to publish - // (likely because we previously reached our limit for number of outstanding syncs) - firePendingOffsetSyncs(); + // Handle delayed and pending offset syncs only when emit.offset-syncs.enabled set to true + if (emitOffsetSyncEnabled) { + // Offset syncs which were not emitted immediately due to their offset spacing should be sent periodically + // This ensures that low-volume topics aren't left with persistent lag at the end of the topic + promoteDelayedOffsetSyncs(); + // Publish any offset syncs that we've queued up, but have not yet been able to publish + // (likely because we previously reached our limit for number of outstanding syncs) + firePendingOffsetSyncs(); Review Comment: resolved in https://github.com/apache/kafka/pull/15999/commits/10eb256b97cb55c309b8a682e252acc53eb9b6cb -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to go to the specific comment. To unsubscribe, e-mail: jira-unsubscr...@kafka.apache.org For queries about this service, please contact Infrastructure at: us...@infra.apache.org