Updated to use blocking as part of investigation of issue apache#215

orpiske · May 20, 2020 · 3eb95cf · 3eb95cf
1 parent 5f7b7c0
commit 3eb95cf
Showing 1 changed file with 1 addition and 1 deletion.
diff --git a/tests/src/test/java/org/apache/camel/kafkaconnector/sink/aws/sqs/CamelSinkAWSSQSITCase.java b/tests/src/test/java/org/apache/camel/kafkaconnector/sink/aws/sqs/CamelSinkAWSSQSITCase.java
@@ -103,7 +103,7 @@ private void produceMessages()  {
 
     public void runTest(ConnectorPropertyFactory connectorPropertyFactory) throws Exception {
         connectorPropertyFactory.log();
-        getKafkaConnectService().initializeConnector(connectorPropertyFactory);
+        getKafkaConnectService().initializeConnectorBlocking(connectorPropertyFactory, 1);
 
         LOG.debug("Creating the consumer ...");
         ExecutorService service = Executors.newCachedThreadPool();