Reproducer for issue 50751 #51312
Open
Reproducer for issue 50751 #51312
+67
−0
Conversation
This file contains hidden or bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
Contributor
Author
|
cc @radcortez @gsmet |
Member
|
@mocenas 👋 the test is failing and requires a fix or it's all fine? |
Contributor
Author
That's weird it passes for me no problem, executing in using What failure do you have with it? |
mocenas
force-pushed
the
kafka_test_donation
branch
from
f809237 to
ad86b8e
Compare
Contributor
Author
|
I rebased the PR on up-to-date main. |
This comment has been minimized.
This comment has been minimized.
mocenas
force-pushed
the
kafka_test_donation
branch
from
ad86b8e to
44de84c
Compare
Member
|
@mocenas it was a question :). But I think you answered it and it's all fine. Basically I wanted to know if it was a reproducer for an issue to fix or an additional test. I understand it's an additional test. |
gsmet
approved these changes
Dec 1, 2025
Status for workflow
|
| Status | Name | Step | Failures | Logs | Raw logs | Build scan |
|---|---|---|---|---|---|---|
| ❌ | JVM Integration Tests - JDK 17 | Build |
Failures | Logs | Raw logs | 🔍 |
| ✔️ | JVM Integration Tests - JDK 17 Windows | Logs | Raw logs | 🔍 | ||
| ❌ | JVM Integration Tests - JDK 21 | Build |
Failures | Logs | Raw logs | 🔍 |
| ❌ | JVM Integration Tests - JDK 21 Semeru | Build |
Failures | Logs | Raw logs | 🔍 |
| ❌ | JVM Integration Tests - JDK 25 | Build |
Failures | Logs | Raw logs | 🔍 |
Full information is available in the Build summary check run.
You can consult the Develocity build scans.
Failures
⚙️ JVM Integration Tests - JDK 17 #
- Failing: integration-tests/reactive-messaging-kafka
📦 integration-tests/reactive-messaging-kafka
❌ io.quarkus.it.kafka.KafkaConnectorTest.testPeople line 45 - History - More details - Source on GitHub
org.awaitility.core.ConditionTimeoutException: Assertion condition defined as a Lambda expression in io.quarkus.it.kafka.KafkaConnectorTest expected: <12> but was: <6> within 10 seconds.
at org.awaitility.core.ConditionAwaiter.await(ConditionAwaiter.java:167)
at org.awaitility.core.AssertionCondition.await(AssertionCondition.java:119)
at org.awaitility.core.AssertionCondition.await(AssertionCondition.java:31)
at org.awaitility.core.ConditionFactory.until(ConditionFactory.java:1160)
at org.awaitility.core.ConditionFactory.untilAsserted(ConditionFactory.java:790)
at io.quarkus.it.kafka.KafkaConnectorTest.testPeople(KafkaConnectorTest.java:45)
at java.base/java.lang.reflect.Method.invoke(Method.java:569)
❌ io.quarkus.it.kafka.KafkaConnectorTest.testPrometheusScrapeEndpointOpenMetrics line 127 - History - More details - Source on GitHub
java.lang.AssertionError:
1 expectation failed.
Response body doesn't match expectation.
Expected: not a string containing "kafka_version=\"unknown\""
Actual: # HELP kafka_producer_node_response_total The total number of responses received
# TYPE kafka_producer_node_response_total counter
kafka_producer_node_response_total{client_id="kafka-producer-data-with-metadata-out",kafka_version="unknown",node_id="node--1",} 3.0
kafka_producer_node_response_total{client_id="kafka-producer-foo.bar-topic",kafka_version="unknown",node_id="node--1",} 3.0
⚙️ JVM Integration Tests - JDK 21 #
- Failing: integration-tests/reactive-messaging-kafka
📦 integration-tests/reactive-messaging-kafka
❌ io.quarkus.it.kafka.KafkaConnectorTest.testPeople line 45 - History - More details - Source on GitHub
org.awaitility.core.ConditionTimeoutException: Assertion condition defined as a Lambda expression in io.quarkus.it.kafka.KafkaConnectorTest expected: <12> but was: <6> within 10 seconds.
at org.awaitility.core.ConditionAwaiter.await(ConditionAwaiter.java:167)
at org.awaitility.core.AssertionCondition.await(AssertionCondition.java:119)
at org.awaitility.core.AssertionCondition.await(AssertionCondition.java:31)
at org.awaitility.core.ConditionFactory.until(ConditionFactory.java:1160)
at org.awaitility.core.ConditionFactory.untilAsserted(ConditionFactory.java:790)
at io.quarkus.it.kafka.KafkaConnectorTest.testPeople(KafkaConnectorTest.java:45)
at java.base/java.lang.reflect.Method.invoke(Method.java:580)
❌ io.quarkus.it.kafka.KafkaConnectorTest.testPrometheusScrapeEndpointOpenMetrics line 127 - History - More details - Source on GitHub
java.lang.AssertionError:
1 expectation failed.
Response body doesn't match expectation.
Expected: not a string containing "kafka_version=\"unknown\""
Actual: # HELP kafka_producer_record_send_rate The average number of records sent per second.
# TYPE kafka_producer_record_send_rate gauge
kafka_producer_record_send_rate{client_id="kafka-producer-data-with-metadata-out",kafka_version="unknown",} 0.05683648144288881
kafka_producer_record_send_rate{client_id="kafka-producer-prices-out2",kafka_version="unknown",} 0.05687095979223143
⚙️ JVM Integration Tests - JDK 21 Semeru #
- Failing: integration-tests/reactive-messaging-kafka
📦 integration-tests/reactive-messaging-kafka
❌ io.quarkus.it.kafka.KafkaConnectorTest.testPeople line 45 - History - More details - Source on GitHub
org.awaitility.core.ConditionTimeoutException: Assertion condition expected: <12> but was: <6> within 10 seconds.
at org.awaitility.core.ConditionAwaiter.await(ConditionAwaiter.java:167)
at org.awaitility.core.AssertionCondition.await(AssertionCondition.java:119)
at org.awaitility.core.AssertionCondition.await(AssertionCondition.java:31)
at org.awaitility.core.ConditionFactory.until(ConditionFactory.java:1160)
at org.awaitility.core.ConditionFactory.untilAsserted(ConditionFactory.java:790)
at io.quarkus.it.kafka.KafkaConnectorTest.testPeople(KafkaConnectorTest.java:45)
at java.base/java.lang.reflect.Method.invoke(Method.java:586)
❌ io.quarkus.it.kafka.KafkaConnectorTest.testPrometheusScrapeEndpointOpenMetrics line 127 - History - More details - Source on GitHub
java.lang.AssertionError:
1 expectation failed.
Response body doesn't match expectation.
Expected: not a string containing "kafka_version=\"unknown\""
Actual: # HELP kafka_consumer_coordinator_assigned_partitions The number of partitions currently assigned to this consumer
# TYPE kafka_consumer_coordinator_assigned_partitions gauge
kafka_consumer_coordinator_assigned_partitions{client_id="kafka-consumer-data-with-metadata-in",kafka_version="4.0.1",} 1.0
kafka_consumer_coordinator_assigned_partitions{client_id="kafka-consumer-people-in",kafka_version="4.0.1",} 1.0
⚙️ JVM Integration Tests - JDK 25 #
- Failing: integration-tests/reactive-messaging-kafka
📦 integration-tests/reactive-messaging-kafka
❌ io.quarkus.it.kafka.KafkaConnectorTest.testPeople line 45 - History - More details - Source on GitHub
org.awaitility.core.ConditionTimeoutException: Assertion condition defined as a Lambda expression in io.quarkus.it.kafka.KafkaConnectorTest expected: <12> but was: <6> within 10 seconds.
at org.awaitility.core.ConditionAwaiter.await(ConditionAwaiter.java:167)
at org.awaitility.core.AssertionCondition.await(AssertionCondition.java:119)
at org.awaitility.core.AssertionCondition.await(AssertionCondition.java:31)
at org.awaitility.core.ConditionFactory.until(ConditionFactory.java:1160)
at org.awaitility.core.ConditionFactory.untilAsserted(ConditionFactory.java:790)
at io.quarkus.it.kafka.KafkaConnectorTest.testPeople(KafkaConnectorTest.java:45)
at java.base/java.lang.reflect.Method.invoke(Method.java:565)
❌ io.quarkus.it.kafka.KafkaConnectorTest.testPrometheusScrapeEndpointOpenMetrics line 127 - History - More details - Source on GitHub
java.lang.AssertionError:
1 expectation failed.
Response body doesn't match expectation.
Expected: not a string containing "kafka_version=\"unknown\""
Actual: # HELP worker_pool_active The number of resources from the pool currently used
# TYPE worker_pool_active gauge
worker_pool_active{pool_name="vert.x-internal-blocking",pool_type="worker",} 0.0
worker_pool_active{pool_name="vert.x-worker-thread",pool_type="worker",} 0.0
Flaky tests - Develocity
⚙️ JVM Integration Tests - JDK 21
📦 integration-tests/reactive-messaging-kafka
❌ io.quarkus.it.kafka.KafkaConnectorTest.testPrices - History
Assertion condition defined as a Lambda expression in io.quarkus.it.kafka.KafkaConnectorTest expected: <8> but was: <6> within 10 seconds.-org.awaitility.core.ConditionTimeoutException
org.awaitility.core.ConditionTimeoutException: Assertion condition defined as a Lambda expression in io.quarkus.it.kafka.KafkaConnectorTest expected: <8> but was: <6> within 10 seconds.
at org.awaitility.core.ConditionAwaiter.await(ConditionAwaiter.java:167)
at org.awaitility.core.AssertionCondition.await(AssertionCondition.java:119)
at org.awaitility.core.AssertionCondition.await(AssertionCondition.java:31)
at org.awaitility.core.ConditionFactory.until(ConditionFactory.java:1160)
at org.awaitility.core.ConditionFactory.untilAsserted(ConditionFactory.java:790)
at io.quarkus.it.kafka.KafkaConnectorTest.testPrices(KafkaConnectorTest.java:74)
at java.base/java.lang.reflect.Method.invoke(Method.java:580)
⚙️ JVM Integration Tests - JDK 25
📦 integration-tests/reactive-messaging-kafka
❌ io.quarkus.it.kafka.KafkaConnectorTest.testPets - History
Assertion condition defined as a Lambda expression in io.quarkus.it.kafka.KafkaConnectorTest expected: <6> but was: <3> within 10 seconds.-org.awaitility.core.ConditionTimeoutException
org.awaitility.core.ConditionTimeoutException: Assertion condition defined as a Lambda expression in io.quarkus.it.kafka.KafkaConnectorTest expected: <6> but was: <3> within 10 seconds.
at org.awaitility.core.ConditionAwaiter.await(ConditionAwaiter.java:167)
at org.awaitility.core.AssertionCondition.await(AssertionCondition.java:119)
at org.awaitility.core.AssertionCondition.await(AssertionCondition.java:31)
at org.awaitility.core.ConditionFactory.until(ConditionFactory.java:1160)
at org.awaitility.core.ConditionFactory.untilAsserted(ConditionFactory.java:790)
at io.quarkus.it.kafka.KafkaConnectorTest.testPets(KafkaConnectorTest.java:59)
at java.base/java.lang.reflect.Method.invoke(Method.java:565)
❌ io.quarkus.it.kafka.KafkaConnectorTest.testPrices - History
Assertion condition defined as a Lambda expression in io.quarkus.it.kafka.KafkaConnectorTest expected: <12> but was: <6> within 10 seconds.-org.awaitility.core.ConditionTimeoutException
org.awaitility.core.ConditionTimeoutException: Assertion condition defined as a Lambda expression in io.quarkus.it.kafka.KafkaConnectorTest expected: <12> but was: <6> within 10 seconds.
at org.awaitility.core.ConditionAwaiter.await(ConditionAwaiter.java:167)
at org.awaitility.core.AssertionCondition.await(AssertionCondition.java:119)
at org.awaitility.core.AssertionCondition.await(AssertionCondition.java:31)
at org.awaitility.core.ConditionFactory.until(ConditionFactory.java:1160)
at org.awaitility.core.ConditionFactory.untilAsserted(ConditionFactory.java:790)
at io.quarkus.it.kafka.KafkaConnectorTest.testPrices(KafkaConnectorTest.java:74)
at java.base/java.lang.reflect.Method.invoke(Method.java:565)
Sign up for free
to join this conversation on GitHub.
Already have an account?
Sign in to comment
2 participants
Add this suggestion to a batch that can be applied as a single commit.
This suggestion is invalid because no changes were made to the code.
Suggestions cannot be applied while the pull request is closed.
Suggestions cannot be applied while viewing a subset of changes.
Only one suggestion per line can be applied in a batch.
Add this suggestion to a batch that can be applied as a single commit.
Applying suggestions on deleted lines is not supported.
You must change the existing code in this line in order to create a valid suggestion.
Outdated suggestions cannot be applied.
This suggestion has been applied or marked resolved.
Suggestions cannot be applied from pending reviews.
Suggestions cannot be applied on multi-line comments.
Suggestions cannot be applied while the pull request is queued to merge.
Suggestion cannot be applied right now. Please check back later.
Adding a tests for #50751 where KafkaCompanionResource got double-quoted channel name.
These tests are used in QE TS, but might also be useful here.