We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
There was an error while loading. Please reload this page.
1 parent cad5646 commit a7e1473Copy full SHA for a7e1473
spring-kafka/src/test/java/org/springframework/kafka/annotation/EnableKafkaIntegrationTests.java
@@ -833,7 +833,8 @@ public void testReplyingBatchListenerReturnCollection() {
833
replies = KafkaTestUtils.getRecords(consumer);
834
assertThat(replies.count()).isGreaterThanOrEqualTo(1);
835
iterator = replies.iterator();
836
- list = (List) iterator.next();
+ value = iterator.next().value();
837
+ list = (List) value;
838
assertThat(list).hasSize(1);
839
assertThat(list.get(0)).isEqualTo("BAR");
840
}
0 commit comments