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 } }