From feee39443564f8cf3d1d948701bc214d2b59d7da Mon Sep 17 00:00:00 2001 From: Alexei Bratuhin Date: Tue, 10 Oct 2023 18:09:34 +0200 Subject: [PATCH] Update kafka.adoc Based on https://quarkusio.zulipchat.com/#narrow/stream/187030-users/topic/KafkaCompanion.20does.20not.20produce.20records.3F --- docs/src/main/asciidoc/kafka.adoc | 14 ++++++++++++++ 1 file changed, 14 insertions(+) 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].