From 3f3d712a84bdb662500335bf7f249d87c952732f Mon Sep 17 00:00:00 2001 From: Byungjun You Date: Sun, 18 Dec 2022 18:39:55 +0900 Subject: [PATCH] Fix a message index in kafka binder test --- .../cloud/stream/binder/kafka/KafkaBinderTests.java | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/binders/kafka-binder/spring-cloud-stream-binder-kafka/src/test/java/org/springframework/cloud/stream/binder/kafka/KafkaBinderTests.java b/binders/kafka-binder/spring-cloud-stream-binder-kafka/src/test/java/org/springframework/cloud/stream/binder/kafka/KafkaBinderTests.java index f819b62d3..cf44e1c17 100644 --- a/binders/kafka-binder/spring-cloud-stream-binder-kafka/src/test/java/org/springframework/cloud/stream/binder/kafka/KafkaBinderTests.java +++ b/binders/kafka-binder/spring-cloud-stream-binder-kafka/src/test/java/org/springframework/cloud/stream/binder/kafka/KafkaBinderTests.java @@ -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 -> {