C0urante commented on code in PR #13367:
URL: https://github.com/apache/kafka/pull/13367#discussion_r1142683836
##########
connect/mirror/src/test/java/org/apache/kafka/connect/mirror/integration/MirrorConnectorsIntegrationBaseTest.java:
##########
@@ -416,6 +417,15 @@ public void testReplicationWithEmptyPartition() throws
Exception {
@Test
public void testOneWayReplicationWithAutoOffsetSync() throws
InterruptedException {
+ testOneWayReplicationWithOffsetSyncs(OFFSET_LAG_MAX);
+ }
+
+ @Test
+ public void testOneWayReplicationWithFrequentOffsetSyncs() throws
InterruptedException {
+ testOneWayReplicationWithOffsetSyncs(0);
+ }
+
+ public void testOneWayReplicationWithOffsetSyncs(int offsetLagMax) throws
InterruptedException {
Review Comment:
Nit: this may make more sense as `protected`
--
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
