try fixing the integration test

camunda · Jul 15, 2024 · f746bb3 · f746bb3
1 parent 1d7acfe
commit f746bb3
Showing 1 changed file with 2 additions and 1 deletion.
diff --git a/connectors/kafka/src/test/java/io/camunda/connector/kafka/inbound/KafkaExecutableTest.java b/connectors/kafka/src/test/java/io/camunda/connector/kafka/inbound/KafkaExecutableTest.java
@@ -169,7 +169,8 @@ void testActivateAndDeactivate_consumerThrows() {
     when(mockConsumer.poll(any())).thenThrow(new RuntimeException("Test exception"));
     await()
         .atMost(Duration.ofSeconds(5))
-        .until(() -> !kafkaExecutable.kafkaConnectorConsumer.shouldLoop);
+        .pollInterval(Duration.ofMillis(500))
+        .untilAsserted(() -> assertFalse(kafkaExecutable.kafkaConnectorConsumer.shouldLoop));
     kafkaExecutable.deactivate();
 
     // Then