Skip to content

Commit

Permalink
Update kafka.adoc
Browse files Browse the repository at this point in the history 
Based on https://quarkusio.zulipchat.com/#narrow/stream/187030-users/topic/KafkaCompanion.20does.20not.20produce.20records.3F
  • Loading branch information
@coiouhkc @gastaldi
coiouhkc authored and gastaldi committed Aug 9, 2024
1 parent a2de5a0 commit feee394
Showing 1 changed file with 14 additions and 0 deletions.
14 changes: 14 additions & 0 deletions docs/src/main/asciidoc/kafka.adoc
View file
Original file line number Diff line number Diff line change
Expand Up @@ -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.

Check warning on line 2424 in docs/src/main/asciidoc/kafka.adoc

View workflow job for this annotation

GitHub Actions / Linting with Vale 

[vale] reported by reviewdog 🐶
[Quarkus.Fluff] Depending on the context, consider using 'Rewrite the sentence, or use 'must', instead of' rather than 'need to'.

Raw Output:
{"message": "[Quarkus.Fluff] Depending on the context, consider using 'Rewrite the sentence, or use 'must', instead of' rather than 'need to'.", "location": {"path": "docs/src/main/asciidoc/kafka.adoc", "range": {"start": {"line": 2424, "column": 17}}}, "severity": "INFO"}

Check warning on line 2424 in docs/src/main/asciidoc/kafka.adoc

View workflow job for this annotation

GitHub Actions / Linting with Vale 

[vale] reported by reviewdog 🐶
[Quarkus.TermsSuggestions] Depending on the context, consider using 'because' or 'while' rather than 'as'.

Raw Output:
{"message": "[Quarkus.TermsSuggestions] Depending on the context, consider using 'because' or 'while' rather than 'as'.", "location": {"path": "docs/src/main/asciidoc/kafka.adoc", "range": {"start": {"line": 2424, "column": 39}}}, "severity": "INFO"}


[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].
Expand Down

0 comments on commit feee394

Please sign in to comment.