diff --git a/functions/consumer/elasticsearch-consumer/src/test/java/org/springframework/cloud/fn/consumer/elasticsearch/ElasticsearchConsumerApplicationTests.java b/functions/consumer/elasticsearch-consumer/src/test/java/org/springframework/cloud/fn/consumer/elasticsearch/ElasticsearchConsumerApplicationTests.java index 3bd96288..1ca21ad7 100644 --- a/functions/consumer/elasticsearch-consumer/src/test/java/org/springframework/cloud/fn/consumer/elasticsearch/ElasticsearchConsumerApplicationTests.java +++ b/functions/consumer/elasticsearch-consumer/src/test/java/org/springframework/cloud/fn/consumer/elasticsearch/ElasticsearchConsumerApplicationTests.java @@ -248,7 +248,8 @@ public class ElasticsearchConsumerApplicationTests { if (i < properties.getBatchSize() - 1) { log.info("elasticsearchConsumer.accept:{}", message); elasticsearchConsumer.accept(message); - } else { + } + else { // last invocation assertThatIllegalStateException() .isThrownBy(() -> elasticsearchConsumer.accept(message))