try fixing the integration test

camunda · Jul 15, 2024 · 8685720 · 8685720
1 parent deae842
commit 8685720
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
@@ -15,6 +15,7 @@
 import static org.mockito.ArgumentMatchers.any;
 import static org.mockito.ArgumentMatchers.argThat;
 import static org.mockito.Mockito.doNothing;
+import static org.mockito.Mockito.doThrow;
 import static org.mockito.Mockito.mock;
 import static org.mockito.Mockito.times;
 import static org.mockito.Mockito.verify;
@@ -166,7 +167,7 @@ void testActivateAndDeactivate_consumerThrows() {
 
     // When
     kafkaExecutable.activate(context);
-    when(mockConsumer.poll(any())).thenThrow(new RuntimeException("Test exception"));
+    doThrow(new RuntimeException("Test exception")).when(mockConsumer).poll(any());
     await()
         .atMost(Duration.ofSeconds(5))
         .pollInterval(Duration.ofMillis(500))