diff --git a/src/test/java/org/springframework/integration/aws/kinesis/KclMessageDrivenChannelAdapterTests.java b/src/test/java/org/springframework/integration/aws/kinesis/KclMessageDrivenChannelAdapterTests.java index 9b83387..d5b757b 100644 --- a/src/test/java/org/springframework/integration/aws/kinesis/KclMessageDrivenChannelAdapterTests.java +++ b/src/test/java/org/springframework/integration/aws/kinesis/KclMessageDrivenChannelAdapterTests.java @@ -123,7 +123,7 @@ void kclChannelAdapterReceivesRecords() { assertThat(streamConsumers).hasSize(0); List tableNames = DYNAMO_DB.listTables().join().tableNames(); - assertThat(tableNames).containsOnly("test_table"); + assertThat(tableNames).contains("test_table"); } @Test