Skip to content

Commit abc2674

Browse files
committed
fix: increase timeout on test
1 parent 6bcc9ee commit abc2674

File tree

1 file changed

+2
-2
lines changed

1 file changed

+2
-2
lines changed

src/test/java/io/spoud/KafkaSynthClientRecordIgnoreTest.java

Lines changed: 2 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -36,7 +36,7 @@ public class KafkaSynthClientRecordIgnoreTest {
3636
public void testEndToEndLatencyNotRecorded() {
3737
kafkaCompanion.consumeWithDeserializers(ByteArrayDeserializer.class)
3838
.fromTopics(config.topic(), 3)
39-
.awaitCompletion(Duration.ofMillis(5000));
39+
.awaitCompletion(Duration.ofSeconds(5));
4040

4141
var metrics = RestAssured.get("/q/metrics").asString();
4242

@@ -46,7 +46,7 @@ public void testEndToEndLatencyNotRecorded() {
4646
assertThat(metrics).doesNotContain("synth_client_e2e_latency_ms{broker=\"0\",fromRack=\"dc1\",partition=\"0\",toRack=\"dc1\",topic=\"demo.prod.app.kafka-synth.messages\",viaBrokerRack=\"unknown\",quantile=\"0.99\"}");
4747

4848
// ...but eventually they should appear
49-
await().atMost(Duration.ofMillis(2000))
49+
await().atMost(Duration.ofSeconds(5))
5050
.pollInterval(Duration.ofMillis(500))
5151
.untilAsserted(() ->
5252
assertThat(RestAssured.get("/q/metrics").asString()).contains("synth_client_e2e_latency_ms{broker=\"0\",fromRack=\"dc1\",partition=\"0\",toRack=\"dc1\",topic=\"demo.prod.app.kafka-synth.messages\",viaBrokerRack=\"unknown\",quantile=\"0.5\"}")

0 commit comments

Comments
 (0)