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

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

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

12
apache-kafka-2/src/test/java/com/baeldung/kafka/message/ordering/SinglePartitionIntegrationTest.java
View File

@ -97,14 +97,8 @@ public class SinglePartitionIntegrationTest {
receivedUserEventList.add(userEvent);
System.out.println("User Event ID: " + userEvent.getUserEventId());
});
boolean result = true;
for (int count = 0; count <= 9; count++) {
UserEvent sentUserEvent = sentUserEventList.get(count);
UserEvent receivedUserEvent = receivedUserEventList.get(count);
if (!sentUserEvent.equals(receivedUserEvent) && result) {
result = false;
}
}
assertTrue(result);
assertThat(receivedUserEventList)
.isEqualTo(sentUserEventList)
.containsExactlyElementsOf(sentUserEventList);
}
}