From db90a717cf9b655b0ef54150e56b012afff7a2ab Mon Sep 17 00:00:00 2001 From: GitHub Action Date: Fri, 8 Nov 2024 02:00:55 +0000 Subject: [PATCH] Sync documentation of main branch --- _versions/main/guides/kafka.adoc | 14 ++++++++++++++ 1 file changed, 14 insertions(+) diff --git a/_versions/main/guides/kafka.adoc b/_versions/main/guides/kafka.adoc index c28e7f54367..ac01aac591d 100644 --- a/_versions/main/guides/kafka.adoc +++ b/_versions/main/guides/kafka.adoc @@ -2453,6 +2453,20 @@ public class OrderProcessorTest { <3> Create consumer task which subscribes to 'orders-processed' topic and consumes 10 records. <4> Await completion of the consumer task. + +[TIP] +==== +You need to configure + +[source,properties] +---- +mp.messaging.incoming.orders.connector=smallrye-kafka +mp.messaging.incoming.orders.auto.offset.reset=earliest +---- + +otherwise you will get an `java.lang.AssertionError: No completion (or failure) event received in the last 10000 ms` in <4> +==== + [TIP] ==== If the Kafka Dev Service is available during tests, `KafkaCompanionResource` uses the created Kafka broker, otherwise it creates a Kafka broker using https://github.com/strimzi/test-container[Strimzi Test Container].