SpringCloud/spring-cloud-stream
1
0
Fork 0
Code Issues Packages Projects Releases Wiki Activity

Fix a message index in kafka binder test

Browse Source
This commit is contained in:
Byungjun You
2022-12-18 18:39:55 +09:00
committed by Soby Chacko
parent 9e31e2eae1
commit 3f3d712a84
1 changed files with 1 additions and 1 deletions
Download Patch File Download Diff File Expand all files Collapse all files

2
binders/kafka-binder/spring-cloud-stream-binder-kafka/src/test/java/org/springframework/cloud/stream/binder/kafka/KafkaBinderTests.java
View File

@@ -1769,7 +1769,7 @@ public class KafkaBinderTests extends
assertThat(messages[0]).isNotNull();
assertThat(messages[1]).isNotNull();
assertThat(messages[1]).isNotNull();
assertThat(messages[2]).isNotNull();
assertThat(messages).extracting("payload").containsExactlyInAnyOrder(
testPayload1.getBytes(), testPayload2.getBytes(), testPayload3.getBytes());
Arrays.asList(messages).forEach(message -> {