From 9eea0512e9997e9e680f3dcef87b42cce768cbad Mon Sep 17 00:00:00 2001 From: Guillermo Calvo Date: Fri, 4 Aug 2023 14:59:42 +0200 Subject: [PATCH] Update test to reflect current behavior Previous behavior was buggy. It was fixed by: https://github.com/micronaut-projects/micronaut-kafka/pull/771 --- .../DefaultKafkaListenerExceptionHandlerSpec.groovy | 4 ++-- 1 file changed, 2 insertions(+), 2 deletions(-) diff --git a/kafka/src/test/groovy/io/micronaut/configuration/kafka/exceptions/DefaultKafkaListenerExceptionHandlerSpec.groovy b/kafka/src/test/groovy/io/micronaut/configuration/kafka/exceptions/DefaultKafkaListenerExceptionHandlerSpec.groovy index 401908259..3a72fd25a 100644 --- a/kafka/src/test/groovy/io/micronaut/configuration/kafka/exceptions/DefaultKafkaListenerExceptionHandlerSpec.groovy +++ b/kafka/src/test/groovy/io/micronaut/configuration/kafka/exceptions/DefaultKafkaListenerExceptionHandlerSpec.groovy @@ -57,9 +57,9 @@ class DefaultKafkaListenerExceptionHandlerSpec extends AbstractEmbeddedServerSpe when: "A producer sends a message with wrong serialization" stringProducer.sendToDoNothingTopic("not-a-uuid") - then: "The message is neither skipped nor committed" + then: "The message is skipped, but not committed" conditions.eventually { - consumer.currentPosition == 0 + consumer.currentPosition > 0 consumer.committedOffset == 0 } }