diff --git a/src/test/java/org/springframework/integration/aws/outbound/KplMessageHandlerTests.java b/src/test/java/org/springframework/integration/aws/outbound/KplMessageHandlerTests.java
index 263d455..f707369 100644
--- a/src/test/java/org/springframework/integration/aws/outbound/KplMessageHandlerTests.java
+++ b/src/test/java/org/springframework/integration/aws/outbound/KplMessageHandlerTests.java
@@ -181,7 +181,7 @@ void testKPLMessageHandler_raw_payload_backpressure_failure_test() {
 			assertThat(ex).isNotNull();
 			assertThat(ex.getCause()).isNotNull();
 			assertThat(ex.getCause().getClass()).isEqualTo(RuntimeException.class);
-			assertThat(ex.getCause().getMessage()).isEqualTo("KPL Buffer already at max capacity.");
+			assertThat(ex.getCause().getMessage()).isEqualTo("Buffer already at max capacity.");
 		}
 
 		verify(this.kinesisProducer, Mockito.times(0)).addUserRecord(any(UserRecord.class));