messageMaxBytes) {
+ $.messageMaxBytes = messageMaxBytes;
+ return this;
+ }
+
+ /**
+ * @param messageMaxBytes The maximum size of message that the server can receive.
+ *
+ * @return builder
+ *
+ */
+ public Builder messageMaxBytes(Integer messageMaxBytes) {
+ return messageMaxBytes(Output.of(messageMaxBytes));
+ }
+
+ public DatabaseKafkaConfigArgs build() {
+ if ($.clusterId == null) {
+ throw new MissingRequiredPropertyException("DatabaseKafkaConfigArgs", "clusterId");
+ }
+ return $;
+ }
+ }
+
+}
diff --git a/sdk/java/src/main/java/com/pulumi/digitalocean/DatabaseMongodbConfig.java b/sdk/java/src/main/java/com/pulumi/digitalocean/DatabaseMongodbConfig.java
new file mode 100644
index 00000000..79eb024c
--- /dev/null
+++ b/sdk/java/src/main/java/com/pulumi/digitalocean/DatabaseMongodbConfig.java
@@ -0,0 +1,225 @@
+// *** WARNING: this file was generated by pulumi-java-gen. ***
+// *** Do not edit by hand unless you're certain you know what you are doing! ***
+
+package com.pulumi.digitalocean;
+
+import com.pulumi.core.Output;
+import com.pulumi.core.annotations.Export;
+import com.pulumi.core.annotations.ResourceType;
+import com.pulumi.core.internal.Codegen;
+import com.pulumi.digitalocean.DatabaseMongodbConfigArgs;
+import com.pulumi.digitalocean.Utilities;
+import com.pulumi.digitalocean.inputs.DatabaseMongodbConfigState;
+import java.lang.Integer;
+import java.lang.String;
+import javax.annotation.Nullable;
+
+/**
+ * Provides a virtual resource that can be used to change advanced configuration
+ * options for a DigitalOcean managed MongoDB database cluster.
+ *
+ * > **Note** MongoDB configurations are only removed from state when destroyed. The remote configuration is not unset.
+ *
+ * ## Example Usage
+ *
+ * <!--Start PulumiCodeChooser -->
+ *
+ * {@code
+ * package generated_program;
+ *
+ * import com.pulumi.Context;
+ * import com.pulumi.Pulumi;
+ * import com.pulumi.core.Output;
+ * import com.pulumi.digitalocean.DatabaseCluster;
+ * import com.pulumi.digitalocean.DatabaseClusterArgs;
+ * import com.pulumi.digitalocean.DatabaseMongodbConfig;
+ * import com.pulumi.digitalocean.DatabaseMongodbConfigArgs;
+ * import java.util.List;
+ * import java.util.ArrayList;
+ * import java.util.Map;
+ * import java.io.File;
+ * import java.nio.file.Files;
+ * import java.nio.file.Paths;
+ *
+ * public class App {
+ * public static void main(String[] args) {
+ * Pulumi.run(App::stack);
+ * }
+ *
+ * public static void stack(Context ctx) {
+ * var exampleDatabaseCluster = new DatabaseCluster("exampleDatabaseCluster", DatabaseClusterArgs.builder()
+ * .name("example-mongodb-cluster")
+ * .engine("mongodb")
+ * .version("7")
+ * .size("db-s-1vcpu-1gb")
+ * .region("nyc3")
+ * .nodeCount(1)
+ * .build());
+ *
+ * var example = new DatabaseMongodbConfig("example", DatabaseMongodbConfigArgs.builder()
+ * .clusterId(exampleDatabaseCluster.id())
+ * .defaultReadConcern("majority")
+ * .defaultWriteConcern("majority")
+ * .transactionLifetimeLimitSeconds(100)
+ * .slowOpThresholdMs(100)
+ * .verbosity(3)
+ * .build());
+ *
+ * }
+ * }
+ * }
+ *
+ * <!--End PulumiCodeChooser -->
+ *
+ * ## Import
+ *
+ * A MongoDB database cluster's configuration can be imported using the `id` the parent cluster, e.g.
+ *
+ * ```sh
+ * $ pulumi import digitalocean:index/databaseMongodbConfig:DatabaseMongodbConfig example 4b62829a-9c42-465b-aaa3-84051048e712
+ * ```
+ *
+ */
+@ResourceType(type="digitalocean:index/databaseMongodbConfig:DatabaseMongodbConfig")
+public class DatabaseMongodbConfig extends com.pulumi.resources.CustomResource {
+ /**
+ * The ID of the target MongoDB cluster.
+ *
+ */
+ @Export(name="clusterId", refs={String.class}, tree="[0]")
+ private Output clusterId;
+
+ /**
+ * @return The ID of the target MongoDB cluster.
+ *
+ */
+ public Output clusterId() {
+ return this.clusterId;
+ }
+ /**
+ * Specifies the default consistency behavior of reads from the database. Data that is returned from the query with may or may not have been acknowledged by all nodes in the replicaset depending on this value. Learn more [here](https://www.mongodb.com/docs/manual/reference/read-concern/).
+ *
+ */
+ @Export(name="defaultReadConcern", refs={String.class}, tree="[0]")
+ private Output defaultReadConcern;
+
+ /**
+ * @return Specifies the default consistency behavior of reads from the database. Data that is returned from the query with may or may not have been acknowledged by all nodes in the replicaset depending on this value. Learn more [here](https://www.mongodb.com/docs/manual/reference/read-concern/).
+ *
+ */
+ public Output defaultReadConcern() {
+ return this.defaultReadConcern;
+ }
+ /**
+ * Describes the level of acknowledgment requested from MongoDB for write operations clusters. This field can set to either `majority` or a number`0...n` which will describe the number of nodes that must acknowledge the write operation before it is fully accepted. Setting to `0` will request no acknowledgement of the write operation. Learn more [here](https://www.mongodb.com/docs/manual/reference/write-concern/).
+ *
+ */
+ @Export(name="defaultWriteConcern", refs={String.class}, tree="[0]")
+ private Output defaultWriteConcern;
+
+ /**
+ * @return Describes the level of acknowledgment requested from MongoDB for write operations clusters. This field can set to either `majority` or a number`0...n` which will describe the number of nodes that must acknowledge the write operation before it is fully accepted. Setting to `0` will request no acknowledgement of the write operation. Learn more [here](https://www.mongodb.com/docs/manual/reference/write-concern/).
+ *
+ */
+ public Output defaultWriteConcern() {
+ return this.defaultWriteConcern;
+ }
+ /**
+ * Operations that run for longer than this threshold are considered slow which are then recorded to the diagnostic logs. Higher log levels (verbosity) will record all operations regardless of this threshold on the primary node. <em>Changing this parameter will lead to a restart of the MongoDB service.</em> Learn more [here](https://www.mongodb.com/docs/manual/reference/configuration-options/#mongodb-setting-operationProfiling.slowOpThresholdMs).
+ *
+ */
+ @Export(name="slowOpThresholdMs", refs={Integer.class}, tree="[0]")
+ private Output slowOpThresholdMs;
+
+ /**
+ * @return Operations that run for longer than this threshold are considered slow which are then recorded to the diagnostic logs. Higher log levels (verbosity) will record all operations regardless of this threshold on the primary node. <em>Changing this parameter will lead to a restart of the MongoDB service.</em> Learn more [here](https://www.mongodb.com/docs/manual/reference/configuration-options/#mongodb-setting-operationProfiling.slowOpThresholdMs).
+ *
+ */
+ public Output slowOpThresholdMs() {
+ return this.slowOpThresholdMs;
+ }
+ /**
+ * Specifies the lifetime of multi-document transactions. Transactions that exceed this limit are considered expired and will be aborted by a periodic cleanup process. The cleanup process runs every `transactionLifetimeLimitSeconds/2 seconds` or at least once every 60 seconds. <em>Changing this parameter will lead to a restart of the MongoDB service.</em> Learn more [here](https://www.mongodb.com/docs/manual/reference/parameters/#mongodb-parameter-param.transactionLifetimeLimitSeconds).
+ *
+ */
+ @Export(name="transactionLifetimeLimitSeconds", refs={Integer.class}, tree="[0]")
+ private Output transactionLifetimeLimitSeconds;
+
+ /**
+ * @return Specifies the lifetime of multi-document transactions. Transactions that exceed this limit are considered expired and will be aborted by a periodic cleanup process. The cleanup process runs every `transactionLifetimeLimitSeconds/2 seconds` or at least once every 60 seconds. <em>Changing this parameter will lead to a restart of the MongoDB service.</em> Learn more [here](https://www.mongodb.com/docs/manual/reference/parameters/#mongodb-parameter-param.transactionLifetimeLimitSeconds).
+ *
+ */
+ public Output transactionLifetimeLimitSeconds() {
+ return this.transactionLifetimeLimitSeconds;
+ }
+ /**
+ * The log message verbosity level. The verbosity level determines the amount of Informational and Debug messages MongoDB outputs. 0 includes informational messages while 1...5 increases the level to include debug messages. <em>Changing this parameter will lead to a restart of the MongoDB service.</em> Learn more [here](https://www.mongodb.com/docs/manual/reference/configuration-options/#mongodb-setting-systemLog.verbosity).
+ *
+ */
+ @Export(name="verbosity", refs={Integer.class}, tree="[0]")
+ private Output verbosity;
+
+ /**
+ * @return The log message verbosity level. The verbosity level determines the amount of Informational and Debug messages MongoDB outputs. 0 includes informational messages while 1...5 increases the level to include debug messages. <em>Changing this parameter will lead to a restart of the MongoDB service.</em> Learn more [here](https://www.mongodb.com/docs/manual/reference/configuration-options/#mongodb-setting-systemLog.verbosity).
+ *
+ */
+ public Output verbosity() {
+ return this.verbosity;
+ }
+
+ /**
+ *
+ * @param name The _unique_ name of the resulting resource.
+ */
+ public DatabaseMongodbConfig(java.lang.String name) {
+ this(name, DatabaseMongodbConfigArgs.Empty);
+ }
+ /**
+ *
+ * @param name The _unique_ name of the resulting resource.
+ * @param args The arguments to use to populate this resource's properties.
+ */
+ public DatabaseMongodbConfig(java.lang.String name, DatabaseMongodbConfigArgs args) {
+ this(name, args, null);
+ }
+ /**
+ *
+ * @param name The _unique_ name of the resulting resource.
+ * @param args The arguments to use to populate this resource's properties.
+ * @param options A bag of options that control this resource's behavior.
+ */
+ public DatabaseMongodbConfig(java.lang.String name, DatabaseMongodbConfigArgs args, @Nullable com.pulumi.resources.CustomResourceOptions options) {
+ super("digitalocean:index/databaseMongodbConfig:DatabaseMongodbConfig", name, makeArgs(args, options), makeResourceOptions(options, Codegen.empty()), false);
+ }
+
+ private DatabaseMongodbConfig(java.lang.String name, Output id, @Nullable DatabaseMongodbConfigState state, @Nullable com.pulumi.resources.CustomResourceOptions options) {
+ super("digitalocean:index/databaseMongodbConfig:DatabaseMongodbConfig", name, state, makeResourceOptions(options, id), false);
+ }
+
+ private static DatabaseMongodbConfigArgs makeArgs(DatabaseMongodbConfigArgs args, @Nullable com.pulumi.resources.CustomResourceOptions options) {
+ if (options != null && options.getUrn().isPresent()) {
+ return null;
+ }
+ return args == null ? DatabaseMongodbConfigArgs.Empty : args;
+ }
+
+ private static com.pulumi.resources.CustomResourceOptions makeResourceOptions(@Nullable com.pulumi.resources.CustomResourceOptions options, @Nullable Output id) {
+ var defaultOptions = com.pulumi.resources.CustomResourceOptions.builder()
+ .version(Utilities.getVersion())
+ .build();
+ return com.pulumi.resources.CustomResourceOptions.merge(defaultOptions, options, id);
+ }
+
+ /**
+ * Get an existing Host resource's state with the given name, ID, and optional extra
+ * properties used to qualify the lookup.
+ *
+ * @param name The _unique_ name of the resulting resource.
+ * @param id The _unique_ provider ID of the resource to lookup.
+ * @param state
+ * @param options Optional settings to control the behavior of the CustomResource.
+ */
+ public static DatabaseMongodbConfig get(java.lang.String name, Output id, @Nullable DatabaseMongodbConfigState state, @Nullable com.pulumi.resources.CustomResourceOptions options) {
+ return new DatabaseMongodbConfig(name, id, state, options);
+ }
+}
diff --git a/sdk/java/src/main/java/com/pulumi/digitalocean/DatabaseMongodbConfigArgs.java b/sdk/java/src/main/java/com/pulumi/digitalocean/DatabaseMongodbConfigArgs.java
new file mode 100644
index 00000000..5ca9cb4b
--- /dev/null
+++ b/sdk/java/src/main/java/com/pulumi/digitalocean/DatabaseMongodbConfigArgs.java
@@ -0,0 +1,273 @@
+// *** WARNING: this file was generated by pulumi-java-gen. ***
+// *** Do not edit by hand unless you're certain you know what you are doing! ***
+
+package com.pulumi.digitalocean;
+
+import com.pulumi.core.Output;
+import com.pulumi.core.annotations.Import;
+import com.pulumi.exceptions.MissingRequiredPropertyException;
+import java.lang.Integer;
+import java.lang.String;
+import java.util.Objects;
+import java.util.Optional;
+import javax.annotation.Nullable;
+
+
+public final class DatabaseMongodbConfigArgs extends com.pulumi.resources.ResourceArgs {
+
+ public static final DatabaseMongodbConfigArgs Empty = new DatabaseMongodbConfigArgs();
+
+ /**
+ * The ID of the target MongoDB cluster.
+ *
+ */
+ @Import(name="clusterId", required=true)
+ private Output clusterId;
+
+ /**
+ * @return The ID of the target MongoDB cluster.
+ *
+ */
+ public Output clusterId() {
+ return this.clusterId;
+ }
+
+ /**
+ * Specifies the default consistency behavior of reads from the database. Data that is returned from the query with may or may not have been acknowledged by all nodes in the replicaset depending on this value. Learn more [here](https://www.mongodb.com/docs/manual/reference/read-concern/).
+ *
+ */
+ @Import(name="defaultReadConcern")
+ private @Nullable Output defaultReadConcern;
+
+ /**
+ * @return Specifies the default consistency behavior of reads from the database. Data that is returned from the query with may or may not have been acknowledged by all nodes in the replicaset depending on this value. Learn more [here](https://www.mongodb.com/docs/manual/reference/read-concern/).
+ *
+ */
+ public Optional> defaultReadConcern() {
+ return Optional.ofNullable(this.defaultReadConcern);
+ }
+
+ /**
+ * Describes the level of acknowledgment requested from MongoDB for write operations clusters. This field can set to either `majority` or a number`0...n` which will describe the number of nodes that must acknowledge the write operation before it is fully accepted. Setting to `0` will request no acknowledgement of the write operation. Learn more [here](https://www.mongodb.com/docs/manual/reference/write-concern/).
+ *
+ */
+ @Import(name="defaultWriteConcern")
+ private @Nullable Output defaultWriteConcern;
+
+ /**
+ * @return Describes the level of acknowledgment requested from MongoDB for write operations clusters. This field can set to either `majority` or a number`0...n` which will describe the number of nodes that must acknowledge the write operation before it is fully accepted. Setting to `0` will request no acknowledgement of the write operation. Learn more [here](https://www.mongodb.com/docs/manual/reference/write-concern/).
+ *
+ */
+ public Optional> defaultWriteConcern() {
+ return Optional.ofNullable(this.defaultWriteConcern);
+ }
+
+ /**
+ * Operations that run for longer than this threshold are considered slow which are then recorded to the diagnostic logs. Higher log levels (verbosity) will record all operations regardless of this threshold on the primary node. <em>Changing this parameter will lead to a restart of the MongoDB service.</em> Learn more [here](https://www.mongodb.com/docs/manual/reference/configuration-options/#mongodb-setting-operationProfiling.slowOpThresholdMs).
+ *
+ */
+ @Import(name="slowOpThresholdMs")
+ private @Nullable Output slowOpThresholdMs;
+
+ /**
+ * @return Operations that run for longer than this threshold are considered slow which are then recorded to the diagnostic logs. Higher log levels (verbosity) will record all operations regardless of this threshold on the primary node. <em>Changing this parameter will lead to a restart of the MongoDB service.</em> Learn more [here](https://www.mongodb.com/docs/manual/reference/configuration-options/#mongodb-setting-operationProfiling.slowOpThresholdMs).
+ *
+ */
+ public Optional> slowOpThresholdMs() {
+ return Optional.ofNullable(this.slowOpThresholdMs);
+ }
+
+ /**
+ * Specifies the lifetime of multi-document transactions. Transactions that exceed this limit are considered expired and will be aborted by a periodic cleanup process. The cleanup process runs every `transactionLifetimeLimitSeconds/2 seconds` or at least once every 60 seconds. <em>Changing this parameter will lead to a restart of the MongoDB service.</em> Learn more [here](https://www.mongodb.com/docs/manual/reference/parameters/#mongodb-parameter-param.transactionLifetimeLimitSeconds).
+ *
+ */
+ @Import(name="transactionLifetimeLimitSeconds")
+ private @Nullable Output transactionLifetimeLimitSeconds;
+
+ /**
+ * @return Specifies the lifetime of multi-document transactions. Transactions that exceed this limit are considered expired and will be aborted by a periodic cleanup process. The cleanup process runs every `transactionLifetimeLimitSeconds/2 seconds` or at least once every 60 seconds. <em>Changing this parameter will lead to a restart of the MongoDB service.</em> Learn more [here](https://www.mongodb.com/docs/manual/reference/parameters/#mongodb-parameter-param.transactionLifetimeLimitSeconds).
+ *
+ */
+ public Optional> transactionLifetimeLimitSeconds() {
+ return Optional.ofNullable(this.transactionLifetimeLimitSeconds);
+ }
+
+ /**
+ * The log message verbosity level. The verbosity level determines the amount of Informational and Debug messages MongoDB outputs. 0 includes informational messages while 1...5 increases the level to include debug messages. <em>Changing this parameter will lead to a restart of the MongoDB service.</em> Learn more [here](https://www.mongodb.com/docs/manual/reference/configuration-options/#mongodb-setting-systemLog.verbosity).
+ *
+ */
+ @Import(name="verbosity")
+ private @Nullable Output verbosity;
+
+ /**
+ * @return The log message verbosity level. The verbosity level determines the amount of Informational and Debug messages MongoDB outputs. 0 includes informational messages while 1...5 increases the level to include debug messages. <em>Changing this parameter will lead to a restart of the MongoDB service.</em> Learn more [here](https://www.mongodb.com/docs/manual/reference/configuration-options/#mongodb-setting-systemLog.verbosity).
+ *
+ */
+ public Optional> verbosity() {
+ return Optional.ofNullable(this.verbosity);
+ }
+
+ private DatabaseMongodbConfigArgs() {}
+
+ private DatabaseMongodbConfigArgs(DatabaseMongodbConfigArgs $) {
+ this.clusterId = $.clusterId;
+ this.defaultReadConcern = $.defaultReadConcern;
+ this.defaultWriteConcern = $.defaultWriteConcern;
+ this.slowOpThresholdMs = $.slowOpThresholdMs;
+ this.transactionLifetimeLimitSeconds = $.transactionLifetimeLimitSeconds;
+ this.verbosity = $.verbosity;
+ }
+
+ public static Builder builder() {
+ return new Builder();
+ }
+ public static Builder builder(DatabaseMongodbConfigArgs defaults) {
+ return new Builder(defaults);
+ }
+
+ public static final class Builder {
+ private DatabaseMongodbConfigArgs $;
+
+ public Builder() {
+ $ = new DatabaseMongodbConfigArgs();
+ }
+
+ public Builder(DatabaseMongodbConfigArgs defaults) {
+ $ = new DatabaseMongodbConfigArgs(Objects.requireNonNull(defaults));
+ }
+
+ /**
+ * @param clusterId The ID of the target MongoDB cluster.
+ *
+ * @return builder
+ *
+ */
+ public Builder clusterId(Output clusterId) {
+ $.clusterId = clusterId;
+ return this;
+ }
+
+ /**
+ * @param clusterId The ID of the target MongoDB cluster.
+ *
+ * @return builder
+ *
+ */
+ public Builder clusterId(String clusterId) {
+ return clusterId(Output.of(clusterId));
+ }
+
+ /**
+ * @param defaultReadConcern Specifies the default consistency behavior of reads from the database. Data that is returned from the query with may or may not have been acknowledged by all nodes in the replicaset depending on this value. Learn more [here](https://www.mongodb.com/docs/manual/reference/read-concern/).
+ *
+ * @return builder
+ *
+ */
+ public Builder defaultReadConcern(@Nullable Output defaultReadConcern) {
+ $.defaultReadConcern = defaultReadConcern;
+ return this;
+ }
+
+ /**
+ * @param defaultReadConcern Specifies the default consistency behavior of reads from the database. Data that is returned from the query with may or may not have been acknowledged by all nodes in the replicaset depending on this value. Learn more [here](https://www.mongodb.com/docs/manual/reference/read-concern/).
+ *
+ * @return builder
+ *
+ */
+ public Builder defaultReadConcern(String defaultReadConcern) {
+ return defaultReadConcern(Output.of(defaultReadConcern));
+ }
+
+ /**
+ * @param defaultWriteConcern Describes the level of acknowledgment requested from MongoDB for write operations clusters. This field can set to either `majority` or a number`0...n` which will describe the number of nodes that must acknowledge the write operation before it is fully accepted. Setting to `0` will request no acknowledgement of the write operation. Learn more [here](https://www.mongodb.com/docs/manual/reference/write-concern/).
+ *
+ * @return builder
+ *
+ */
+ public Builder defaultWriteConcern(@Nullable Output defaultWriteConcern) {
+ $.defaultWriteConcern = defaultWriteConcern;
+ return this;
+ }
+
+ /**
+ * @param defaultWriteConcern Describes the level of acknowledgment requested from MongoDB for write operations clusters. This field can set to either `majority` or a number`0...n` which will describe the number of nodes that must acknowledge the write operation before it is fully accepted. Setting to `0` will request no acknowledgement of the write operation. Learn more [here](https://www.mongodb.com/docs/manual/reference/write-concern/).
+ *
+ * @return builder
+ *
+ */
+ public Builder defaultWriteConcern(String defaultWriteConcern) {
+ return defaultWriteConcern(Output.of(defaultWriteConcern));
+ }
+
+ /**
+ * @param slowOpThresholdMs Operations that run for longer than this threshold are considered slow which are then recorded to the diagnostic logs. Higher log levels (verbosity) will record all operations regardless of this threshold on the primary node. <em>Changing this parameter will lead to a restart of the MongoDB service.</em> Learn more [here](https://www.mongodb.com/docs/manual/reference/configuration-options/#mongodb-setting-operationProfiling.slowOpThresholdMs).
+ *
+ * @return builder
+ *
+ */
+ public Builder slowOpThresholdMs(@Nullable Output slowOpThresholdMs) {
+ $.slowOpThresholdMs = slowOpThresholdMs;
+ return this;
+ }
+
+ /**
+ * @param slowOpThresholdMs Operations that run for longer than this threshold are considered slow which are then recorded to the diagnostic logs. Higher log levels (verbosity) will record all operations regardless of this threshold on the primary node. <em>Changing this parameter will lead to a restart of the MongoDB service.</em> Learn more [here](https://www.mongodb.com/docs/manual/reference/configuration-options/#mongodb-setting-operationProfiling.slowOpThresholdMs).
+ *
+ * @return builder
+ *
+ */
+ public Builder slowOpThresholdMs(Integer slowOpThresholdMs) {
+ return slowOpThresholdMs(Output.of(slowOpThresholdMs));
+ }
+
+ /**
+ * @param transactionLifetimeLimitSeconds Specifies the lifetime of multi-document transactions. Transactions that exceed this limit are considered expired and will be aborted by a periodic cleanup process. The cleanup process runs every `transactionLifetimeLimitSeconds/2 seconds` or at least once every 60 seconds. <em>Changing this parameter will lead to a restart of the MongoDB service.</em> Learn more [here](https://www.mongodb.com/docs/manual/reference/parameters/#mongodb-parameter-param.transactionLifetimeLimitSeconds).
+ *
+ * @return builder
+ *
+ */
+ public Builder transactionLifetimeLimitSeconds(@Nullable Output transactionLifetimeLimitSeconds) {
+ $.transactionLifetimeLimitSeconds = transactionLifetimeLimitSeconds;
+ return this;
+ }
+
+ /**
+ * @param transactionLifetimeLimitSeconds Specifies the lifetime of multi-document transactions. Transactions that exceed this limit are considered expired and will be aborted by a periodic cleanup process. The cleanup process runs every `transactionLifetimeLimitSeconds/2 seconds` or at least once every 60 seconds. <em>Changing this parameter will lead to a restart of the MongoDB service.</em> Learn more [here](https://www.mongodb.com/docs/manual/reference/parameters/#mongodb-parameter-param.transactionLifetimeLimitSeconds).
+ *
+ * @return builder
+ *
+ */
+ public Builder transactionLifetimeLimitSeconds(Integer transactionLifetimeLimitSeconds) {
+ return transactionLifetimeLimitSeconds(Output.of(transactionLifetimeLimitSeconds));
+ }
+
+ /**
+ * @param verbosity The log message verbosity level. The verbosity level determines the amount of Informational and Debug messages MongoDB outputs. 0 includes informational messages while 1...5 increases the level to include debug messages. <em>Changing this parameter will lead to a restart of the MongoDB service.</em> Learn more [here](https://www.mongodb.com/docs/manual/reference/configuration-options/#mongodb-setting-systemLog.verbosity).
+ *
+ * @return builder
+ *
+ */
+ public Builder verbosity(@Nullable Output verbosity) {
+ $.verbosity = verbosity;
+ return this;
+ }
+
+ /**
+ * @param verbosity The log message verbosity level. The verbosity level determines the amount of Informational and Debug messages MongoDB outputs. 0 includes informational messages while 1...5 increases the level to include debug messages. <em>Changing this parameter will lead to a restart of the MongoDB service.</em> Learn more [here](https://www.mongodb.com/docs/manual/reference/configuration-options/#mongodb-setting-systemLog.verbosity).
+ *
+ * @return builder
+ *
+ */
+ public Builder verbosity(Integer verbosity) {
+ return verbosity(Output.of(verbosity));
+ }
+
+ public DatabaseMongodbConfigArgs build() {
+ if ($.clusterId == null) {
+ throw new MissingRequiredPropertyException("DatabaseMongodbConfigArgs", "clusterId");
+ }
+ return $;
+ }
+ }
+
+}
diff --git a/sdk/java/src/main/java/com/pulumi/digitalocean/inputs/DatabaseKafkaConfigState.java b/sdk/java/src/main/java/com/pulumi/digitalocean/inputs/DatabaseKafkaConfigState.java
new file mode 100644
index 00000000..ed93a4e3
--- /dev/null
+++ b/sdk/java/src/main/java/com/pulumi/digitalocean/inputs/DatabaseKafkaConfigState.java
@@ -0,0 +1,714 @@
+// *** WARNING: this file was generated by pulumi-java-gen. ***
+// *** Do not edit by hand unless you're certain you know what you are doing! ***
+
+package com.pulumi.digitalocean.inputs;
+
+import com.pulumi.core.Output;
+import com.pulumi.core.annotations.Import;
+import java.lang.Boolean;
+import java.lang.Integer;
+import java.lang.String;
+import java.util.Objects;
+import java.util.Optional;
+import javax.annotation.Nullable;
+
+
+public final class DatabaseKafkaConfigState extends com.pulumi.resources.ResourceArgs {
+
+ public static final DatabaseKafkaConfigState Empty = new DatabaseKafkaConfigState();
+
+ /**
+ * Enable auto creation of topics.
+ *
+ */
+ @Import(name="autoCreateTopicsEnable")
+ private @Nullable Output autoCreateTopicsEnable;
+
+ /**
+ * @return Enable auto creation of topics.
+ *
+ */
+ public Optional> autoCreateTopicsEnable() {
+ return Optional.ofNullable(this.autoCreateTopicsEnable);
+ }
+
+ /**
+ * The ID of the target Kafka cluster.
+ *
+ */
+ @Import(name="clusterId")
+ private @Nullable Output clusterId;
+
+ /**
+ * @return The ID of the target Kafka cluster.
+ *
+ */
+ public Optional> clusterId() {
+ return Optional.ofNullable(this.clusterId);
+ }
+
+ /**
+ * The amount of time, in milliseconds, the group coordinator will wait for more consumers to join a new group before performing the first rebalance. A longer delay means potentially fewer rebalances, but increases the time until processing begins. The default value for this is 3 seconds. During development and testing it might be desirable to set this to 0 in order to not delay test execution time.
+ *
+ */
+ @Import(name="groupInitialRebalanceDelayMs")
+ private @Nullable Output groupInitialRebalanceDelayMs;
+
+ /**
+ * @return The amount of time, in milliseconds, the group coordinator will wait for more consumers to join a new group before performing the first rebalance. A longer delay means potentially fewer rebalances, but increases the time until processing begins. The default value for this is 3 seconds. During development and testing it might be desirable to set this to 0 in order to not delay test execution time.
+ *
+ */
+ public Optional> groupInitialRebalanceDelayMs() {
+ return Optional.ofNullable(this.groupInitialRebalanceDelayMs);
+ }
+
+ /**
+ * The maximum allowed session timeout for registered consumers. Longer timeouts give consumers more time to process messages in between heartbeats at the cost of a longer time to detect failures.
+ *
+ */
+ @Import(name="groupMaxSessionTimeoutMs")
+ private @Nullable Output groupMaxSessionTimeoutMs;
+
+ /**
+ * @return The maximum allowed session timeout for registered consumers. Longer timeouts give consumers more time to process messages in between heartbeats at the cost of a longer time to detect failures.
+ *
+ */
+ public Optional> groupMaxSessionTimeoutMs() {
+ return Optional.ofNullable(this.groupMaxSessionTimeoutMs);
+ }
+
+ /**
+ * The minimum allowed session timeout for registered consumers. Longer timeouts give consumers more time to process messages in between heartbeats at the cost of a longer time to detect failures.
+ *
+ */
+ @Import(name="groupMinSessionTimeoutMs")
+ private @Nullable Output groupMinSessionTimeoutMs;
+
+ /**
+ * @return The minimum allowed session timeout for registered consumers. Longer timeouts give consumers more time to process messages in between heartbeats at the cost of a longer time to detect failures.
+ *
+ */
+ public Optional> groupMinSessionTimeoutMs() {
+ return Optional.ofNullable(this.groupMinSessionTimeoutMs);
+ }
+
+ /**
+ * How long are delete records retained?
+ *
+ */
+ @Import(name="logCleanerDeleteRetentionMs")
+ private @Nullable Output logCleanerDeleteRetentionMs;
+
+ /**
+ * @return How long are delete records retained?
+ *
+ */
+ public Optional> logCleanerDeleteRetentionMs() {
+ return Optional.ofNullable(this.logCleanerDeleteRetentionMs);
+ }
+
+ /**
+ * The minimum time a message will remain uncompacted in the log. Only applicable for logs that are being compacted.
+ *
+ */
+ @Import(name="logCleanerMinCompactionLagMs")
+ private @Nullable Output logCleanerMinCompactionLagMs;
+
+ /**
+ * @return The minimum time a message will remain uncompacted in the log. Only applicable for logs that are being compacted.
+ *
+ */
+ public Optional> logCleanerMinCompactionLagMs() {
+ return Optional.ofNullable(this.logCleanerMinCompactionLagMs);
+ }
+
+ /**
+ * The maximum time in ms that a message in any topic is kept in memory before flushed to disk. If not set, the value in log.flush.scheduler.interval.ms is used.
+ *
+ */
+ @Import(name="logFlushIntervalMs")
+ private @Nullable Output logFlushIntervalMs;
+
+ /**
+ * @return The maximum time in ms that a message in any topic is kept in memory before flushed to disk. If not set, the value in log.flush.scheduler.interval.ms is used.
+ *
+ */
+ public Optional> logFlushIntervalMs() {
+ return Optional.ofNullable(this.logFlushIntervalMs);
+ }
+
+ /**
+ * The interval with which Kafka adds an entry to the offset index.
+ *
+ */
+ @Import(name="logIndexIntervalBytes")
+ private @Nullable Output logIndexIntervalBytes;
+
+ /**
+ * @return The interval with which Kafka adds an entry to the offset index.
+ *
+ */
+ public Optional> logIndexIntervalBytes() {
+ return Optional.ofNullable(this.logIndexIntervalBytes);
+ }
+
+ /**
+ * This configuration controls whether down-conversion of message formats is enabled to satisfy consume requests.
+ *
+ */
+ @Import(name="logMessageDownconversionEnable")
+ private @Nullable Output logMessageDownconversionEnable;
+
+ /**
+ * @return This configuration controls whether down-conversion of message formats is enabled to satisfy consume requests.
+ *
+ */
+ public Optional> logMessageDownconversionEnable() {
+ return Optional.ofNullable(this.logMessageDownconversionEnable);
+ }
+
+ /**
+ * The maximum difference allowed between the timestamp when a broker receives a message and the timestamp specified in the message.
+ *
+ */
+ @Import(name="logMessageTimestampDifferenceMaxMs")
+ private @Nullable Output logMessageTimestampDifferenceMaxMs;
+
+ /**
+ * @return The maximum difference allowed between the timestamp when a broker receives a message and the timestamp specified in the message.
+ *
+ */
+ public Optional> logMessageTimestampDifferenceMaxMs() {
+ return Optional.ofNullable(this.logMessageTimestampDifferenceMaxMs);
+ }
+
+ /**
+ * Controls whether to preallocate a file when creating a new segment.
+ *
+ */
+ @Import(name="logPreallocate")
+ private @Nullable Output logPreallocate;
+
+ /**
+ * @return Controls whether to preallocate a file when creating a new segment.
+ *
+ */
+ public Optional> logPreallocate() {
+ return Optional.ofNullable(this.logPreallocate);
+ }
+
+ /**
+ * The maximum size of the log before deleting messages.
+ *
+ */
+ @Import(name="logRetentionBytes")
+ private @Nullable Output logRetentionBytes;
+
+ /**
+ * @return The maximum size of the log before deleting messages.
+ *
+ */
+ public Optional> logRetentionBytes() {
+ return Optional.ofNullable(this.logRetentionBytes);
+ }
+
+ /**
+ * The number of hours to keep a log file before deleting it.
+ *
+ */
+ @Import(name="logRetentionHours")
+ private @Nullable Output logRetentionHours;
+
+ /**
+ * @return The number of hours to keep a log file before deleting it.
+ *
+ */
+ public Optional> logRetentionHours() {
+ return Optional.ofNullable(this.logRetentionHours);
+ }
+
+ /**
+ * The number of milliseconds to keep a log file before deleting it (in milliseconds), If not set, the value in log.retention.minutes is used. If set to -1, no time limit is applied.
+ *
+ */
+ @Import(name="logRetentionMs")
+ private @Nullable Output logRetentionMs;
+
+ /**
+ * @return The number of milliseconds to keep a log file before deleting it (in milliseconds), If not set, the value in log.retention.minutes is used. If set to -1, no time limit is applied.
+ *
+ */
+ public Optional> logRetentionMs() {
+ return Optional.ofNullable(this.logRetentionMs);
+ }
+
+ /**
+ * The maximum jitter to subtract from logRollTimeMillis (in milliseconds). If not set, the value in log.roll.jitter.hours is used.
+ *
+ */
+ @Import(name="logRollJitterMs")
+ private @Nullable Output logRollJitterMs;
+
+ /**
+ * @return The maximum jitter to subtract from logRollTimeMillis (in milliseconds). If not set, the value in log.roll.jitter.hours is used.
+ *
+ */
+ public Optional> logRollJitterMs() {
+ return Optional.ofNullable(this.logRollJitterMs);
+ }
+
+ /**
+ * The amount of time to wait before deleting a file from the filesystem.
+ *
+ */
+ @Import(name="logSegmentDeleteDelayMs")
+ private @Nullable Output logSegmentDeleteDelayMs;
+
+ /**
+ * @return The amount of time to wait before deleting a file from the filesystem.
+ *
+ */
+ public Optional