iSharkFly-Docs/java-tutorials
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

Update apache-kafka-2/src/test/java/com/baeldung/kafka/message/ordering/ExtSeqWithTimeWindowIntegrationTest.java

Browse Source 
Co-authored-by: Liam Williams <liam.williams@zoho.com>
This commit is contained in:
Amol Gote 2023-11-04 16:57:32 -04:00 committed by GitHub
parent 33b18c0ca4
commit 3e2975196d
1 changed files with 3 additions and 10 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

13
apache-kafka-2/src/test/java/com/baeldung/kafka/message/ordering/ExtSeqWithTimeWindowIntegrationTest.java
View File

@ -102,16 +102,9 @@ public class ExternalSequenceWithTimeWindowIntegrationTest {
buffer.add(record.value()); buffer.add(record.value());
}); });
} }
for (int insertPosition = 0; insertPosition <= receivedUserEventList.size() - 1; insertPosition++) { assertThat(receivedUserEventList)
if (isOrderMaintained){ .isEqualTo(sentUserEventList)
UserEvent sentUserEvent = sentUserEventList.get(insertPosition); .containsExactlyElementsOf(sentUserEventList);
UserEvent receivedUserEvent = receivedUserEventList.get(insertPosition);
if (!sentUserEvent.equals(receivedUserEvent)) {
isOrderMaintained = false;
}
}
}
assertTrue(isOrderMaintained);
} }
private static void processBuffer(List<UserEvent> buffer, List<UserEvent> receivedUserEventList) { private static void processBuffer(List<UserEvent> buffer, List<UserEvent> receivedUserEventList) {