This is an automated email from the ASF dual-hosted git repository. orpiske pushed a commit to branch camel-master in repository https://gitbox.apache.org/repos/asf/camel-kafka-connector.git
commit e52977db36e1b774227b4d17184b7681cd1f784a Author: Otavio Rodolfo Piske <[email protected]> AuthorDate: Fri Nov 20 10:30:41 2020 +0100 Work-around Couchbase timeout issue in URL-based test --- .../kafkaconnector/couchbase/sink/CamelSinkCouchbaseITCase.java | 6 ++++++ 1 file changed, 6 insertions(+) diff --git a/tests/itests-couchbase/src/test/java/org/apache/camel/kafkaconnector/couchbase/sink/CamelSinkCouchbaseITCase.java b/tests/itests-couchbase/src/test/java/org/apache/camel/kafkaconnector/couchbase/sink/CamelSinkCouchbaseITCase.java index a37b50d..02d46c9 100644 --- a/tests/itests-couchbase/src/test/java/org/apache/camel/kafkaconnector/couchbase/sink/CamelSinkCouchbaseITCase.java +++ b/tests/itests-couchbase/src/test/java/org/apache/camel/kafkaconnector/couchbase/sink/CamelSinkCouchbaseITCase.java @@ -73,6 +73,8 @@ public class CamelSinkCouchbaseITCase extends AbstractKafkaTest { bucketName = "testBucket" + TestUtils.randomWithRange(0, 100); cluster = Cluster.connect(service.getConnectionString(), service.getUsername(), service.getPassword()); + cluster.ping(); + LOG.debug("Creating a new bucket named {}", bucketName); cluster.buckets().createBucket(BucketSettings.create(bucketName)); LOG.debug("Bucket created"); @@ -193,6 +195,10 @@ public class CamelSinkCouchbaseITCase extends AbstractKafkaTest { .append("bucket", bucketName) .append("username", service.getUsername()) .append("password", service.getPassword()) + .append("connectTimeout", 5000) + .append("queryTimeout", 5000) + .append("producerRetryAttempts", 10) + .append("producerRetryPause", 7500) .buildUrl();
