private void setUpClient(CouchbaseContainer container, Consumer<Cluster> consumer) {
        container.start();

        // cluster_creation {
        Cluster cluster = Cluster.connect(
            container.getConnectionString(),
            container.getUsername(),
            container.getPassword()
        );
        // }

        try {
            consumer.accept(cluster);
        } finally {
            cluster.disconnect();
        }
    }
Make sure that the code fails fast if the Eventing service is enabled on the community
edition which is not supported.
modules/couchbase/src/test/java/org/testcontainers/couchbase/CouchbaseContainerTest.java