diff --git a/docs/src/main/asciidoc/kafka.adoc b/docs/src/main/asciidoc/kafka.adoc index 5b64ae38ccb33..2cc369482d072 100644 --- a/docs/src/main/asciidoc/kafka.adoc +++ b/docs/src/main/asciidoc/kafka.adoc @@ -2423,6 +2423,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].