Skip to content

Commit db90a71

Browse files
committed
Sync documentation of main branch
1 parent 9bcf72c commit db90a71

File tree

1 file changed

+14
-0
lines changed

1 file changed

+14
-0
lines changed

_versions/main/guides/kafka.adoc

Lines changed: 14 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -2453,6 +2453,20 @@ public class OrderProcessorTest {
24532453
<3> Create consumer task which subscribes to 'orders-processed' topic and consumes 10 records.
24542454
<4> Await completion of the consumer task.
24552455

2456+
2457+
[TIP]
2458+
====
2459+
You need to configure
2460+
2461+
[source,properties]
2462+
----
2463+
mp.messaging.incoming.orders.connector=smallrye-kafka
2464+
mp.messaging.incoming.orders.auto.offset.reset=earliest
2465+
----
2466+
2467+
otherwise you will get an `java.lang.AssertionError: No completion (or failure) event received in the last 10000 ms` in <4>
2468+
====
2469+
24562470
[TIP]
24572471
====
24582472
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].

0 commit comments

Comments
 (0)