From ad57c6187a237529b8ab0e4c22a785b868022a46 Mon Sep 17 00:00:00 2001 From: Artem Bilan Date: Mon, 21 Dec 2020 17:31:45 -0500 Subject: [PATCH] Fix MessageSourceTest for the latest spring-kafka Related to: https://github.com/spring-projects/spring-kafka/issues/1659 --- .../integration/kafka/inbound/MessageSourceTests.java | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/spring-integration-kafka/src/test/java/org/springframework/integration/kafka/inbound/MessageSourceTests.java b/spring-integration-kafka/src/test/java/org/springframework/integration/kafka/inbound/MessageSourceTests.java index cf07465e28..bbc7b1f7cd 100644 --- a/spring-integration-kafka/src/test/java/org/springframework/integration/kafka/inbound/MessageSourceTests.java +++ b/spring-integration-kafka/src/test/java/org/springframework/integration/kafka/inbound/MessageSourceTests.java @@ -591,7 +591,7 @@ class MessageSourceTests { captor = ArgumentCaptor.forClass(LogMessage.class); inOrder.verify(log2).warn(captor.capture()); assertThat(captor.getValue().toString()) - .contains("Cannot commit offset for ConsumerRecord") + .contains("Cannot commit offset for") .contains("; an earlier offset was rolled back"); inOrder.verify(consumer).poll(any(Duration.class)); inOrder.verify(consumer).commitSync(Collections.singletonMap(topicPartition, new OffsetAndMetadata(1L)));