diff --git a/sdk/dotnet/GetMirrorMakerReplicationFlow.cs b/sdk/dotnet/GetMirrorMakerReplicationFlow.cs index ee5455cf..290f274a 100644 --- a/sdk/dotnet/GetMirrorMakerReplicationFlow.cs +++ b/sdk/dotnet/GetMirrorMakerReplicationFlow.cs @@ -135,6 +135,10 @@ public GetMirrorMakerReplicationFlowInvokeArgs() [OutputType] public sealed class GetMirrorMakerReplicationFlowResult { + /// + /// List of topic configuration properties and/or regular expressions to not replicate. The properties that are not replicated by default are: `follower.replication.throttled.replicas`, `leader.replication.throttled.replicas`, `message.timestamp.difference.max.ms`, `message.timestamp.type`, `unclean.leader.election.enable`, and `min.insync.replicas`. Setting this overrides the defaults. For example, to enable replication for 'min.insync.replicas' and 'unclean.leader.election.enable' set this to: ["follower\\.replication\\.throttled\\.replicas", "leader\\.replication\\.throttled\\.replicas", "message\\.timestamp\\.difference\\.max\\.ms", "message\\.timestamp\\.type"] + /// + public readonly ImmutableArray ConfigPropertiesExcludes; /// /// Whether to emit heartbeats to the direction opposite to the flow, i.e. to the source cluster. The default value is `false`. /// @@ -198,6 +202,8 @@ public sealed class GetMirrorMakerReplicationFlowResult [OutputConstructor] private GetMirrorMakerReplicationFlowResult( + ImmutableArray configPropertiesExcludes, + bool emitBackwardHeartbeatsEnabled, bool emitHeartbeatsEnabled, @@ -228,6 +234,7 @@ private GetMirrorMakerReplicationFlowResult( ImmutableArray topicsBlacklists) { + ConfigPropertiesExcludes = configPropertiesExcludes; EmitBackwardHeartbeatsEnabled = emitBackwardHeartbeatsEnabled; EmitHeartbeatsEnabled = emitHeartbeatsEnabled; Enable = enable; diff --git a/sdk/dotnet/MirrorMakerReplicationFlow.cs b/sdk/dotnet/MirrorMakerReplicationFlow.cs index 7870706a..760435c6 100644 --- a/sdk/dotnet/MirrorMakerReplicationFlow.cs +++ b/sdk/dotnet/MirrorMakerReplicationFlow.cs @@ -39,6 +39,15 @@ namespace Pulumi.Aiven /// ".*\\.replica", /// "__.*", /// }, + /// ConfigPropertiesExcludes = new[] + /// { + /// "follower\\.replication\\.throttled\\.replicas", + /// "leader\\.replication\\.throttled\\.replicas", + /// "message\\.timestamp\\.difference\\.max\\.ms", + /// "message\\.timestamp\\.type", + /// "unclean\\.leader\\.election\\.enable", + /// "min\\.insync\\.replicas", + /// }, /// }); /// /// }); @@ -53,6 +62,12 @@ namespace Pulumi.Aiven [AivenResourceType("aiven:index/mirrorMakerReplicationFlow:MirrorMakerReplicationFlow")] public partial class MirrorMakerReplicationFlow : global::Pulumi.CustomResource { + /// + /// List of topic configuration properties and/or regular expressions to not replicate. The properties that are not replicated by default are: `follower.replication.throttled.replicas`, `leader.replication.throttled.replicas`, `message.timestamp.difference.max.ms`, `message.timestamp.type`, `unclean.leader.election.enable`, and `min.insync.replicas`. Setting this overrides the defaults. For example, to enable replication for 'min.insync.replicas' and 'unclean.leader.election.enable' set this to: ["follower\\.replication\\.throttled\\.replicas", "leader\\.replication\\.throttled\\.replicas", "message\\.timestamp\\.difference\\.max\\.ms", "message\\.timestamp\\.type"] + /// + [Output("configPropertiesExcludes")] + public Output> ConfigPropertiesExcludes { get; private set; } = null!; + /// /// Whether to emit heartbeats to the direction opposite to the flow, i.e. to the source cluster. The default value is `false`. /// @@ -183,6 +198,18 @@ public static MirrorMakerReplicationFlow Get(string name, Input id, Mirr public sealed class MirrorMakerReplicationFlowArgs : global::Pulumi.ResourceArgs { + [Input("configPropertiesExcludes")] + private InputList? _configPropertiesExcludes; + + /// + /// List of topic configuration properties and/or regular expressions to not replicate. The properties that are not replicated by default are: `follower.replication.throttled.replicas`, `leader.replication.throttled.replicas`, `message.timestamp.difference.max.ms`, `message.timestamp.type`, `unclean.leader.election.enable`, and `min.insync.replicas`. Setting this overrides the defaults. For example, to enable replication for 'min.insync.replicas' and 'unclean.leader.election.enable' set this to: ["follower\\.replication\\.throttled\\.replicas", "leader\\.replication\\.throttled\\.replicas", "message\\.timestamp\\.difference\\.max\\.ms", "message\\.timestamp\\.type"] + /// + public InputList ConfigPropertiesExcludes + { + get => _configPropertiesExcludes ?? (_configPropertiesExcludes = new InputList()); + set => _configPropertiesExcludes = value; + } + /// /// Whether to emit heartbeats to the direction opposite to the flow, i.e. to the source cluster. The default value is `false`. /// @@ -287,6 +314,18 @@ public MirrorMakerReplicationFlowArgs() public sealed class MirrorMakerReplicationFlowState : global::Pulumi.ResourceArgs { + [Input("configPropertiesExcludes")] + private InputList? _configPropertiesExcludes; + + /// + /// List of topic configuration properties and/or regular expressions to not replicate. The properties that are not replicated by default are: `follower.replication.throttled.replicas`, `leader.replication.throttled.replicas`, `message.timestamp.difference.max.ms`, `message.timestamp.type`, `unclean.leader.election.enable`, and `min.insync.replicas`. Setting this overrides the defaults. For example, to enable replication for 'min.insync.replicas' and 'unclean.leader.election.enable' set this to: ["follower\\.replication\\.throttled\\.replicas", "leader\\.replication\\.throttled\\.replicas", "message\\.timestamp\\.difference\\.max\\.ms", "message\\.timestamp\\.type"] + /// + public InputList ConfigPropertiesExcludes + { + get => _configPropertiesExcludes ?? (_configPropertiesExcludes = new InputList()); + set => _configPropertiesExcludes = value; + } + /// /// Whether to emit heartbeats to the direction opposite to the flow, i.e. to the source cluster. The default value is `false`. /// diff --git a/sdk/go/aiven/getMirrorMakerReplicationFlow.go b/sdk/go/aiven/getMirrorMakerReplicationFlow.go index 16ce953f..2b831511 100644 --- a/sdk/go/aiven/getMirrorMakerReplicationFlow.go +++ b/sdk/go/aiven/getMirrorMakerReplicationFlow.go @@ -65,6 +65,8 @@ type LookupMirrorMakerReplicationFlowArgs struct { // A collection of values returned by getMirrorMakerReplicationFlow. type LookupMirrorMakerReplicationFlowResult struct { + // List of topic configuration properties and/or regular expressions to not replicate. The properties that are not replicated by default are: `follower.replication.throttled.replicas`, `leader.replication.throttled.replicas`, `message.timestamp.difference.max.ms`, `message.timestamp.type`, `unclean.leader.election.enable`, and `min.insync.replicas`. Setting this overrides the defaults. For example, to enable replication for 'min.insync.replicas' and 'unclean.leader.election.enable' set this to: ["follower\\.replication\\.throttled\\.replicas", "leader\\.replication\\.throttled\\.replicas", "message\\.timestamp\\.difference\\.max\\.ms", "message\\.timestamp\\.type"] + ConfigPropertiesExcludes []string `pulumi:"configPropertiesExcludes"` // Whether to emit heartbeats to the direction opposite to the flow, i.e. to the source cluster. The default value is `false`. EmitBackwardHeartbeatsEnabled bool `pulumi:"emitBackwardHeartbeatsEnabled"` // Whether to emit heartbeats to the target cluster. The default value is `false`. @@ -141,6 +143,11 @@ func (o LookupMirrorMakerReplicationFlowResultOutput) ToLookupMirrorMakerReplica return o } +// List of topic configuration properties and/or regular expressions to not replicate. The properties that are not replicated by default are: `follower.replication.throttled.replicas`, `leader.replication.throttled.replicas`, `message.timestamp.difference.max.ms`, `message.timestamp.type`, `unclean.leader.election.enable`, and `min.insync.replicas`. Setting this overrides the defaults. For example, to enable replication for 'min.insync.replicas' and 'unclean.leader.election.enable' set this to: ["follower\\.replication\\.throttled\\.replicas", "leader\\.replication\\.throttled\\.replicas", "message\\.timestamp\\.difference\\.max\\.ms", "message\\.timestamp\\.type"] +func (o LookupMirrorMakerReplicationFlowResultOutput) ConfigPropertiesExcludes() pulumi.StringArrayOutput { + return o.ApplyT(func(v LookupMirrorMakerReplicationFlowResult) []string { return v.ConfigPropertiesExcludes }).(pulumi.StringArrayOutput) +} + // Whether to emit heartbeats to the direction opposite to the flow, i.e. to the source cluster. The default value is `false`. func (o LookupMirrorMakerReplicationFlowResultOutput) EmitBackwardHeartbeatsEnabled() pulumi.BoolOutput { return o.ApplyT(func(v LookupMirrorMakerReplicationFlowResult) bool { return v.EmitBackwardHeartbeatsEnabled }).(pulumi.BoolOutput) diff --git a/sdk/go/aiven/mirrorMakerReplicationFlow.go b/sdk/go/aiven/mirrorMakerReplicationFlow.go index 05c1bc87..d261a787 100644 --- a/sdk/go/aiven/mirrorMakerReplicationFlow.go +++ b/sdk/go/aiven/mirrorMakerReplicationFlow.go @@ -42,6 +42,14 @@ import ( // pulumi.String(".*\\.replica"), // pulumi.String("__.*"), // }, +// ConfigPropertiesExcludes: pulumi.StringArray{ +// pulumi.String("follower\\.replication\\.throttled\\.replicas"), +// pulumi.String("leader\\.replication\\.throttled\\.replicas"), +// pulumi.String("message\\.timestamp\\.difference\\.max\\.ms"), +// pulumi.String("message\\.timestamp\\.type"), +// pulumi.String("unclean\\.leader\\.election\\.enable"), +// pulumi.String("min\\.insync\\.replicas"), +// }, // }) // if err != nil { // return err @@ -60,6 +68,8 @@ import ( type MirrorMakerReplicationFlow struct { pulumi.CustomResourceState + // List of topic configuration properties and/or regular expressions to not replicate. The properties that are not replicated by default are: `follower.replication.throttled.replicas`, `leader.replication.throttled.replicas`, `message.timestamp.difference.max.ms`, `message.timestamp.type`, `unclean.leader.election.enable`, and `min.insync.replicas`. Setting this overrides the defaults. For example, to enable replication for 'min.insync.replicas' and 'unclean.leader.election.enable' set this to: ["follower\\.replication\\.throttled\\.replicas", "leader\\.replication\\.throttled\\.replicas", "message\\.timestamp\\.difference\\.max\\.ms", "message\\.timestamp\\.type"] + ConfigPropertiesExcludes pulumi.StringArrayOutput `pulumi:"configPropertiesExcludes"` // Whether to emit heartbeats to the direction opposite to the flow, i.e. to the source cluster. The default value is `false`. EmitBackwardHeartbeatsEnabled pulumi.BoolPtrOutput `pulumi:"emitBackwardHeartbeatsEnabled"` // Whether to emit heartbeats to the target cluster. The default value is `false`. @@ -141,6 +151,8 @@ func GetMirrorMakerReplicationFlow(ctx *pulumi.Context, // Input properties used for looking up and filtering MirrorMakerReplicationFlow resources. type mirrorMakerReplicationFlowState struct { + // List of topic configuration properties and/or regular expressions to not replicate. The properties that are not replicated by default are: `follower.replication.throttled.replicas`, `leader.replication.throttled.replicas`, `message.timestamp.difference.max.ms`, `message.timestamp.type`, `unclean.leader.election.enable`, and `min.insync.replicas`. Setting this overrides the defaults. For example, to enable replication for 'min.insync.replicas' and 'unclean.leader.election.enable' set this to: ["follower\\.replication\\.throttled\\.replicas", "leader\\.replication\\.throttled\\.replicas", "message\\.timestamp\\.difference\\.max\\.ms", "message\\.timestamp\\.type"] + ConfigPropertiesExcludes []string `pulumi:"configPropertiesExcludes"` // Whether to emit heartbeats to the direction opposite to the flow, i.e. to the source cluster. The default value is `false`. EmitBackwardHeartbeatsEnabled *bool `pulumi:"emitBackwardHeartbeatsEnabled"` // Whether to emit heartbeats to the target cluster. The default value is `false`. @@ -172,6 +184,8 @@ type mirrorMakerReplicationFlowState struct { } type MirrorMakerReplicationFlowState struct { + // List of topic configuration properties and/or regular expressions to not replicate. The properties that are not replicated by default are: `follower.replication.throttled.replicas`, `leader.replication.throttled.replicas`, `message.timestamp.difference.max.ms`, `message.timestamp.type`, `unclean.leader.election.enable`, and `min.insync.replicas`. Setting this overrides the defaults. For example, to enable replication for 'min.insync.replicas' and 'unclean.leader.election.enable' set this to: ["follower\\.replication\\.throttled\\.replicas", "leader\\.replication\\.throttled\\.replicas", "message\\.timestamp\\.difference\\.max\\.ms", "message\\.timestamp\\.type"] + ConfigPropertiesExcludes pulumi.StringArrayInput // Whether to emit heartbeats to the direction opposite to the flow, i.e. to the source cluster. The default value is `false`. EmitBackwardHeartbeatsEnabled pulumi.BoolPtrInput // Whether to emit heartbeats to the target cluster. The default value is `false`. @@ -207,6 +221,8 @@ func (MirrorMakerReplicationFlowState) ElementType() reflect.Type { } type mirrorMakerReplicationFlowArgs struct { + // List of topic configuration properties and/or regular expressions to not replicate. The properties that are not replicated by default are: `follower.replication.throttled.replicas`, `leader.replication.throttled.replicas`, `message.timestamp.difference.max.ms`, `message.timestamp.type`, `unclean.leader.election.enable`, and `min.insync.replicas`. Setting this overrides the defaults. For example, to enable replication for 'min.insync.replicas' and 'unclean.leader.election.enable' set this to: ["follower\\.replication\\.throttled\\.replicas", "leader\\.replication\\.throttled\\.replicas", "message\\.timestamp\\.difference\\.max\\.ms", "message\\.timestamp\\.type"] + ConfigPropertiesExcludes []string `pulumi:"configPropertiesExcludes"` // Whether to emit heartbeats to the direction opposite to the flow, i.e. to the source cluster. The default value is `false`. EmitBackwardHeartbeatsEnabled *bool `pulumi:"emitBackwardHeartbeatsEnabled"` // Whether to emit heartbeats to the target cluster. The default value is `false`. @@ -239,6 +255,8 @@ type mirrorMakerReplicationFlowArgs struct { // The set of arguments for constructing a MirrorMakerReplicationFlow resource. type MirrorMakerReplicationFlowArgs struct { + // List of topic configuration properties and/or regular expressions to not replicate. The properties that are not replicated by default are: `follower.replication.throttled.replicas`, `leader.replication.throttled.replicas`, `message.timestamp.difference.max.ms`, `message.timestamp.type`, `unclean.leader.election.enable`, and `min.insync.replicas`. Setting this overrides the defaults. For example, to enable replication for 'min.insync.replicas' and 'unclean.leader.election.enable' set this to: ["follower\\.replication\\.throttled\\.replicas", "leader\\.replication\\.throttled\\.replicas", "message\\.timestamp\\.difference\\.max\\.ms", "message\\.timestamp\\.type"] + ConfigPropertiesExcludes pulumi.StringArrayInput // Whether to emit heartbeats to the direction opposite to the flow, i.e. to the source cluster. The default value is `false`. EmitBackwardHeartbeatsEnabled pulumi.BoolPtrInput // Whether to emit heartbeats to the target cluster. The default value is `false`. @@ -356,6 +374,11 @@ func (o MirrorMakerReplicationFlowOutput) ToMirrorMakerReplicationFlowOutputWith return o } +// List of topic configuration properties and/or regular expressions to not replicate. The properties that are not replicated by default are: `follower.replication.throttled.replicas`, `leader.replication.throttled.replicas`, `message.timestamp.difference.max.ms`, `message.timestamp.type`, `unclean.leader.election.enable`, and `min.insync.replicas`. Setting this overrides the defaults. For example, to enable replication for 'min.insync.replicas' and 'unclean.leader.election.enable' set this to: ["follower\\.replication\\.throttled\\.replicas", "leader\\.replication\\.throttled\\.replicas", "message\\.timestamp\\.difference\\.max\\.ms", "message\\.timestamp\\.type"] +func (o MirrorMakerReplicationFlowOutput) ConfigPropertiesExcludes() pulumi.StringArrayOutput { + return o.ApplyT(func(v *MirrorMakerReplicationFlow) pulumi.StringArrayOutput { return v.ConfigPropertiesExcludes }).(pulumi.StringArrayOutput) +} + // Whether to emit heartbeats to the direction opposite to the flow, i.e. to the source cluster. The default value is `false`. func (o MirrorMakerReplicationFlowOutput) EmitBackwardHeartbeatsEnabled() pulumi.BoolPtrOutput { return o.ApplyT(func(v *MirrorMakerReplicationFlow) pulumi.BoolPtrOutput { return v.EmitBackwardHeartbeatsEnabled }).(pulumi.BoolPtrOutput) diff --git a/sdk/java/src/main/java/com/pulumi/aiven/MirrorMakerReplicationFlow.java b/sdk/java/src/main/java/com/pulumi/aiven/MirrorMakerReplicationFlow.java index 5cf14ecf..42db2ac1 100644 --- a/sdk/java/src/main/java/com/pulumi/aiven/MirrorMakerReplicationFlow.java +++ b/sdk/java/src/main/java/com/pulumi/aiven/MirrorMakerReplicationFlow.java @@ -56,6 +56,13 @@ * ".*[\\-\\.]internal", * ".*\\.replica", * "__.*") + * .configPropertiesExcludes( + * "follower\\.replication\\.throttled\\.replicas", + * "leader\\.replication\\.throttled\\.replicas", + * "message\\.timestamp\\.difference\\.max\\.ms", + * "message\\.timestamp\\.type", + * "unclean\\.leader\\.election\\.enable", + * "min\\.insync\\.replicas") * .build()); * * } @@ -73,6 +80,20 @@ */ @ResourceType(type="aiven:index/mirrorMakerReplicationFlow:MirrorMakerReplicationFlow") public class MirrorMakerReplicationFlow extends com.pulumi.resources.CustomResource { + /** + * List of topic configuration properties and/or regular expressions to not replicate. The properties that are not replicated by default are: `follower.replication.throttled.replicas`, `leader.replication.throttled.replicas`, `message.timestamp.difference.max.ms`, `message.timestamp.type`, `unclean.leader.election.enable`, and `min.insync.replicas`. Setting this overrides the defaults. For example, to enable replication for 'min.insync.replicas' and 'unclean.leader.election.enable' set this to: ["follower\\.replication\\.throttled\\.replicas", "leader\\.replication\\.throttled\\.replicas", "message\\.timestamp\\.difference\\.max\\.ms", "message\\.timestamp\\.type"] + * + */ + @Export(name="configPropertiesExcludes", refs={List.class,String.class}, tree="[0,1]") + private Output> configPropertiesExcludes; + + /** + * @return List of topic configuration properties and/or regular expressions to not replicate. The properties that are not replicated by default are: `follower.replication.throttled.replicas`, `leader.replication.throttled.replicas`, `message.timestamp.difference.max.ms`, `message.timestamp.type`, `unclean.leader.election.enable`, and `min.insync.replicas`. Setting this overrides the defaults. For example, to enable replication for 'min.insync.replicas' and 'unclean.leader.election.enable' set this to: ["follower\\.replication\\.throttled\\.replicas", "leader\\.replication\\.throttled\\.replicas", "message\\.timestamp\\.difference\\.max\\.ms", "message\\.timestamp\\.type"] + * + */ + public Output>> configPropertiesExcludes() { + return Codegen.optional(this.configPropertiesExcludes); + } /** * Whether to emit heartbeats to the direction opposite to the flow, i.e. to the source cluster. The default value is `false`. * diff --git a/sdk/java/src/main/java/com/pulumi/aiven/MirrorMakerReplicationFlowArgs.java b/sdk/java/src/main/java/com/pulumi/aiven/MirrorMakerReplicationFlowArgs.java index 980472bf..a9dd31e0 100644 --- a/sdk/java/src/main/java/com/pulumi/aiven/MirrorMakerReplicationFlowArgs.java +++ b/sdk/java/src/main/java/com/pulumi/aiven/MirrorMakerReplicationFlowArgs.java @@ -19,6 +19,21 @@ public final class MirrorMakerReplicationFlowArgs extends com.pulumi.resources.R public static final MirrorMakerReplicationFlowArgs Empty = new MirrorMakerReplicationFlowArgs(); + /** + * List of topic configuration properties and/or regular expressions to not replicate. The properties that are not replicated by default are: `follower.replication.throttled.replicas`, `leader.replication.throttled.replicas`, `message.timestamp.difference.max.ms`, `message.timestamp.type`, `unclean.leader.election.enable`, and `min.insync.replicas`. Setting this overrides the defaults. For example, to enable replication for 'min.insync.replicas' and 'unclean.leader.election.enable' set this to: ["follower\\.replication\\.throttled\\.replicas", "leader\\.replication\\.throttled\\.replicas", "message\\.timestamp\\.difference\\.max\\.ms", "message\\.timestamp\\.type"] + * + */ + @Import(name="configPropertiesExcludes") + private @Nullable Output> configPropertiesExcludes; + + /** + * @return List of topic configuration properties and/or regular expressions to not replicate. The properties that are not replicated by default are: `follower.replication.throttled.replicas`, `leader.replication.throttled.replicas`, `message.timestamp.difference.max.ms`, `message.timestamp.type`, `unclean.leader.election.enable`, and `min.insync.replicas`. Setting this overrides the defaults. For example, to enable replication for 'min.insync.replicas' and 'unclean.leader.election.enable' set this to: ["follower\\.replication\\.throttled\\.replicas", "leader\\.replication\\.throttled\\.replicas", "message\\.timestamp\\.difference\\.max\\.ms", "message\\.timestamp\\.type"] + * + */ + public Optional>> configPropertiesExcludes() { + return Optional.ofNullable(this.configPropertiesExcludes); + } + /** * Whether to emit heartbeats to the direction opposite to the flow, i.e. to the source cluster. The default value is `false`. * @@ -232,6 +247,7 @@ public Optional>> topicsBlacklists() { private MirrorMakerReplicationFlowArgs() {} private MirrorMakerReplicationFlowArgs(MirrorMakerReplicationFlowArgs $) { + this.configPropertiesExcludes = $.configPropertiesExcludes; this.emitBackwardHeartbeatsEnabled = $.emitBackwardHeartbeatsEnabled; this.emitHeartbeatsEnabled = $.emitHeartbeatsEnabled; this.enable = $.enable; @@ -266,6 +282,37 @@ public Builder(MirrorMakerReplicationFlowArgs defaults) { $ = new MirrorMakerReplicationFlowArgs(Objects.requireNonNull(defaults)); } + /** + * @param configPropertiesExcludes List of topic configuration properties and/or regular expressions to not replicate. The properties that are not replicated by default are: `follower.replication.throttled.replicas`, `leader.replication.throttled.replicas`, `message.timestamp.difference.max.ms`, `message.timestamp.type`, `unclean.leader.election.enable`, and `min.insync.replicas`. Setting this overrides the defaults. For example, to enable replication for 'min.insync.replicas' and 'unclean.leader.election.enable' set this to: ["follower\\.replication\\.throttled\\.replicas", "leader\\.replication\\.throttled\\.replicas", "message\\.timestamp\\.difference\\.max\\.ms", "message\\.timestamp\\.type"] + * + * @return builder + * + */ + public Builder configPropertiesExcludes(@Nullable Output> configPropertiesExcludes) { + $.configPropertiesExcludes = configPropertiesExcludes; + return this; + } + + /** + * @param configPropertiesExcludes List of topic configuration properties and/or regular expressions to not replicate. The properties that are not replicated by default are: `follower.replication.throttled.replicas`, `leader.replication.throttled.replicas`, `message.timestamp.difference.max.ms`, `message.timestamp.type`, `unclean.leader.election.enable`, and `min.insync.replicas`. Setting this overrides the defaults. For example, to enable replication for 'min.insync.replicas' and 'unclean.leader.election.enable' set this to: ["follower\\.replication\\.throttled\\.replicas", "leader\\.replication\\.throttled\\.replicas", "message\\.timestamp\\.difference\\.max\\.ms", "message\\.timestamp\\.type"] + * + * @return builder + * + */ + public Builder configPropertiesExcludes(List configPropertiesExcludes) { + return configPropertiesExcludes(Output.of(configPropertiesExcludes)); + } + + /** + * @param configPropertiesExcludes List of topic configuration properties and/or regular expressions to not replicate. The properties that are not replicated by default are: `follower.replication.throttled.replicas`, `leader.replication.throttled.replicas`, `message.timestamp.difference.max.ms`, `message.timestamp.type`, `unclean.leader.election.enable`, and `min.insync.replicas`. Setting this overrides the defaults. For example, to enable replication for 'min.insync.replicas' and 'unclean.leader.election.enable' set this to: ["follower\\.replication\\.throttled\\.replicas", "leader\\.replication\\.throttled\\.replicas", "message\\.timestamp\\.difference\\.max\\.ms", "message\\.timestamp\\.type"] + * + * @return builder + * + */ + public Builder configPropertiesExcludes(String... configPropertiesExcludes) { + return configPropertiesExcludes(List.of(configPropertiesExcludes)); + } + /** * @param emitBackwardHeartbeatsEnabled Whether to emit heartbeats to the direction opposite to the flow, i.e. to the source cluster. The default value is `false`. * diff --git a/sdk/java/src/main/java/com/pulumi/aiven/inputs/MirrorMakerReplicationFlowState.java b/sdk/java/src/main/java/com/pulumi/aiven/inputs/MirrorMakerReplicationFlowState.java index 1397ff79..65a71f06 100644 --- a/sdk/java/src/main/java/com/pulumi/aiven/inputs/MirrorMakerReplicationFlowState.java +++ b/sdk/java/src/main/java/com/pulumi/aiven/inputs/MirrorMakerReplicationFlowState.java @@ -18,6 +18,21 @@ public final class MirrorMakerReplicationFlowState extends com.pulumi.resources. public static final MirrorMakerReplicationFlowState Empty = new MirrorMakerReplicationFlowState(); + /** + * List of topic configuration properties and/or regular expressions to not replicate. The properties that are not replicated by default are: `follower.replication.throttled.replicas`, `leader.replication.throttled.replicas`, `message.timestamp.difference.max.ms`, `message.timestamp.type`, `unclean.leader.election.enable`, and `min.insync.replicas`. Setting this overrides the defaults. For example, to enable replication for 'min.insync.replicas' and 'unclean.leader.election.enable' set this to: ["follower\\.replication\\.throttled\\.replicas", "leader\\.replication\\.throttled\\.replicas", "message\\.timestamp\\.difference\\.max\\.ms", "message\\.timestamp\\.type"] + * + */ + @Import(name="configPropertiesExcludes") + private @Nullable Output> configPropertiesExcludes; + + /** + * @return List of topic configuration properties and/or regular expressions to not replicate. The properties that are not replicated by default are: `follower.replication.throttled.replicas`, `leader.replication.throttled.replicas`, `message.timestamp.difference.max.ms`, `message.timestamp.type`, `unclean.leader.election.enable`, and `min.insync.replicas`. Setting this overrides the defaults. For example, to enable replication for 'min.insync.replicas' and 'unclean.leader.election.enable' set this to: ["follower\\.replication\\.throttled\\.replicas", "leader\\.replication\\.throttled\\.replicas", "message\\.timestamp\\.difference\\.max\\.ms", "message\\.timestamp\\.type"] + * + */ + public Optional>> configPropertiesExcludes() { + return Optional.ofNullable(this.configPropertiesExcludes); + } + /** * Whether to emit heartbeats to the direction opposite to the flow, i.e. to the source cluster. The default value is `false`. * @@ -231,6 +246,7 @@ public Optional>> topicsBlacklists() { private MirrorMakerReplicationFlowState() {} private MirrorMakerReplicationFlowState(MirrorMakerReplicationFlowState $) { + this.configPropertiesExcludes = $.configPropertiesExcludes; this.emitBackwardHeartbeatsEnabled = $.emitBackwardHeartbeatsEnabled; this.emitHeartbeatsEnabled = $.emitHeartbeatsEnabled; this.enable = $.enable; @@ -265,6 +281,37 @@ public Builder(MirrorMakerReplicationFlowState defaults) { $ = new MirrorMakerReplicationFlowState(Objects.requireNonNull(defaults)); } + /** + * @param configPropertiesExcludes List of topic configuration properties and/or regular expressions to not replicate. The properties that are not replicated by default are: `follower.replication.throttled.replicas`, `leader.replication.throttled.replicas`, `message.timestamp.difference.max.ms`, `message.timestamp.type`, `unclean.leader.election.enable`, and `min.insync.replicas`. Setting this overrides the defaults. For example, to enable replication for 'min.insync.replicas' and 'unclean.leader.election.enable' set this to: ["follower\\.replication\\.throttled\\.replicas", "leader\\.replication\\.throttled\\.replicas", "message\\.timestamp\\.difference\\.max\\.ms", "message\\.timestamp\\.type"] + * + * @return builder + * + */ + public Builder configPropertiesExcludes(@Nullable Output> configPropertiesExcludes) { + $.configPropertiesExcludes = configPropertiesExcludes; + return this; + } + + /** + * @param configPropertiesExcludes List of topic configuration properties and/or regular expressions to not replicate. The properties that are not replicated by default are: `follower.replication.throttled.replicas`, `leader.replication.throttled.replicas`, `message.timestamp.difference.max.ms`, `message.timestamp.type`, `unclean.leader.election.enable`, and `min.insync.replicas`. Setting this overrides the defaults. For example, to enable replication for 'min.insync.replicas' and 'unclean.leader.election.enable' set this to: ["follower\\.replication\\.throttled\\.replicas", "leader\\.replication\\.throttled\\.replicas", "message\\.timestamp\\.difference\\.max\\.ms", "message\\.timestamp\\.type"] + * + * @return builder + * + */ + public Builder configPropertiesExcludes(List configPropertiesExcludes) { + return configPropertiesExcludes(Output.of(configPropertiesExcludes)); + } + + /** + * @param configPropertiesExcludes List of topic configuration properties and/or regular expressions to not replicate. The properties that are not replicated by default are: `follower.replication.throttled.replicas`, `leader.replication.throttled.replicas`, `message.timestamp.difference.max.ms`, `message.timestamp.type`, `unclean.leader.election.enable`, and `min.insync.replicas`. Setting this overrides the defaults. For example, to enable replication for 'min.insync.replicas' and 'unclean.leader.election.enable' set this to: ["follower\\.replication\\.throttled\\.replicas", "leader\\.replication\\.throttled\\.replicas", "message\\.timestamp\\.difference\\.max\\.ms", "message\\.timestamp\\.type"] + * + * @return builder + * + */ + public Builder configPropertiesExcludes(String... configPropertiesExcludes) { + return configPropertiesExcludes(List.of(configPropertiesExcludes)); + } + /** * @param emitBackwardHeartbeatsEnabled Whether to emit heartbeats to the direction opposite to the flow, i.e. to the source cluster. The default value is `false`. * diff --git a/sdk/java/src/main/java/com/pulumi/aiven/outputs/GetMirrorMakerReplicationFlowResult.java b/sdk/java/src/main/java/com/pulumi/aiven/outputs/GetMirrorMakerReplicationFlowResult.java index 883568b8..c49e0085 100644 --- a/sdk/java/src/main/java/com/pulumi/aiven/outputs/GetMirrorMakerReplicationFlowResult.java +++ b/sdk/java/src/main/java/com/pulumi/aiven/outputs/GetMirrorMakerReplicationFlowResult.java @@ -13,6 +13,11 @@ @CustomType public final class GetMirrorMakerReplicationFlowResult { + /** + * @return List of topic configuration properties and/or regular expressions to not replicate. The properties that are not replicated by default are: `follower.replication.throttled.replicas`, `leader.replication.throttled.replicas`, `message.timestamp.difference.max.ms`, `message.timestamp.type`, `unclean.leader.election.enable`, and `min.insync.replicas`. Setting this overrides the defaults. For example, to enable replication for 'min.insync.replicas' and 'unclean.leader.election.enable' set this to: ["follower\\.replication\\.throttled\\.replicas", "leader\\.replication\\.throttled\\.replicas", "message\\.timestamp\\.difference\\.max\\.ms", "message\\.timestamp\\.type"] + * + */ + private List configPropertiesExcludes; /** * @return Whether to emit heartbeats to the direction opposite to the flow, i.e. to the source cluster. The default value is `false`. * @@ -90,6 +95,13 @@ public final class GetMirrorMakerReplicationFlowResult { private List topicsBlacklists; private GetMirrorMakerReplicationFlowResult() {} + /** + * @return List of topic configuration properties and/or regular expressions to not replicate. The properties that are not replicated by default are: `follower.replication.throttled.replicas`, `leader.replication.throttled.replicas`, `message.timestamp.difference.max.ms`, `message.timestamp.type`, `unclean.leader.election.enable`, and `min.insync.replicas`. Setting this overrides the defaults. For example, to enable replication for 'min.insync.replicas' and 'unclean.leader.election.enable' set this to: ["follower\\.replication\\.throttled\\.replicas", "leader\\.replication\\.throttled\\.replicas", "message\\.timestamp\\.difference\\.max\\.ms", "message\\.timestamp\\.type"] + * + */ + public List configPropertiesExcludes() { + return this.configPropertiesExcludes; + } /** * @return Whether to emit heartbeats to the direction opposite to the flow, i.e. to the source cluster. The default value is `false`. * @@ -205,6 +217,7 @@ public static Builder builder(GetMirrorMakerReplicationFlowResult defaults) { } @CustomType.Builder public static final class Builder { + private List configPropertiesExcludes; private Boolean emitBackwardHeartbeatsEnabled; private Boolean emitHeartbeatsEnabled; private Boolean enable; @@ -223,6 +236,7 @@ public static final class Builder { public Builder() {} public Builder(GetMirrorMakerReplicationFlowResult defaults) { Objects.requireNonNull(defaults); + this.configPropertiesExcludes = defaults.configPropertiesExcludes; this.emitBackwardHeartbeatsEnabled = defaults.emitBackwardHeartbeatsEnabled; this.emitHeartbeatsEnabled = defaults.emitHeartbeatsEnabled; this.enable = defaults.enable; @@ -240,6 +254,17 @@ public Builder(GetMirrorMakerReplicationFlowResult defaults) { this.topicsBlacklists = defaults.topicsBlacklists; } + @CustomType.Setter + public Builder configPropertiesExcludes(List configPropertiesExcludes) { + if (configPropertiesExcludes == null) { + throw new MissingRequiredPropertyException("GetMirrorMakerReplicationFlowResult", "configPropertiesExcludes"); + } + this.configPropertiesExcludes = configPropertiesExcludes; + return this; + } + public Builder configPropertiesExcludes(String... configPropertiesExcludes) { + return configPropertiesExcludes(List.of(configPropertiesExcludes)); + } @CustomType.Setter public Builder emitBackwardHeartbeatsEnabled(Boolean emitBackwardHeartbeatsEnabled) { if (emitBackwardHeartbeatsEnabled == null) { @@ -368,6 +393,7 @@ public Builder topicsBlacklists(String... topicsBlacklists) { } public GetMirrorMakerReplicationFlowResult build() { final var _resultValue = new GetMirrorMakerReplicationFlowResult(); + _resultValue.configPropertiesExcludes = configPropertiesExcludes; _resultValue.emitBackwardHeartbeatsEnabled = emitBackwardHeartbeatsEnabled; _resultValue.emitHeartbeatsEnabled = emitHeartbeatsEnabled; _resultValue.enable = enable; diff --git a/sdk/nodejs/getMirrorMakerReplicationFlow.ts b/sdk/nodejs/getMirrorMakerReplicationFlow.ts index 0666f433..4b2b68fc 100644 --- a/sdk/nodejs/getMirrorMakerReplicationFlow.ts +++ b/sdk/nodejs/getMirrorMakerReplicationFlow.ts @@ -58,6 +58,10 @@ export interface GetMirrorMakerReplicationFlowArgs { * A collection of values returned by getMirrorMakerReplicationFlow. */ export interface GetMirrorMakerReplicationFlowResult { + /** + * List of topic configuration properties and/or regular expressions to not replicate. The properties that are not replicated by default are: `follower.replication.throttled.replicas`, `leader.replication.throttled.replicas`, `message.timestamp.difference.max.ms`, `message.timestamp.type`, `unclean.leader.election.enable`, and `min.insync.replicas`. Setting this overrides the defaults. For example, to enable replication for 'min.insync.replicas' and 'unclean.leader.election.enable' set this to: ["follower\\.replication\\.throttled\\.replicas", "leader\\.replication\\.throttled\\.replicas", "message\\.timestamp\\.difference\\.max\\.ms", "message\\.timestamp\\.type"] + */ + readonly configPropertiesExcludes: string[]; /** * Whether to emit heartbeats to the direction opposite to the flow, i.e. to the source cluster. The default value is `false`. */ diff --git a/sdk/nodejs/mirrorMakerReplicationFlow.ts b/sdk/nodejs/mirrorMakerReplicationFlow.ts index a0b49361..834c68ac 100644 --- a/sdk/nodejs/mirrorMakerReplicationFlow.ts +++ b/sdk/nodejs/mirrorMakerReplicationFlow.ts @@ -25,6 +25,14 @@ import * as utilities from "./utilities"; * ".*\\.replica", * "__.*", * ], + * configPropertiesExcludes: [ + * "follower\\.replication\\.throttled\\.replicas", + * "leader\\.replication\\.throttled\\.replicas", + * "message\\.timestamp\\.difference\\.max\\.ms", + * "message\\.timestamp\\.type", + * "unclean\\.leader\\.election\\.enable", + * "min\\.insync\\.replicas", + * ], * }); * ``` * @@ -62,6 +70,10 @@ export class MirrorMakerReplicationFlow extends pulumi.CustomResource { return obj['__pulumiType'] === MirrorMakerReplicationFlow.__pulumiType; } + /** + * List of topic configuration properties and/or regular expressions to not replicate. The properties that are not replicated by default are: `follower.replication.throttled.replicas`, `leader.replication.throttled.replicas`, `message.timestamp.difference.max.ms`, `message.timestamp.type`, `unclean.leader.election.enable`, and `min.insync.replicas`. Setting this overrides the defaults. For example, to enable replication for 'min.insync.replicas' and 'unclean.leader.election.enable' set this to: ["follower\\.replication\\.throttled\\.replicas", "leader\\.replication\\.throttled\\.replicas", "message\\.timestamp\\.difference\\.max\\.ms", "message\\.timestamp\\.type"] + */ + public readonly configPropertiesExcludes!: pulumi.Output; /** * Whether to emit heartbeats to the direction opposite to the flow, i.e. to the source cluster. The default value is `false`. */ @@ -132,6 +144,7 @@ export class MirrorMakerReplicationFlow extends pulumi.CustomResource { opts = opts || {}; if (opts.id) { const state = argsOrState as MirrorMakerReplicationFlowState | undefined; + resourceInputs["configPropertiesExcludes"] = state ? state.configPropertiesExcludes : undefined; resourceInputs["emitBackwardHeartbeatsEnabled"] = state ? state.emitBackwardHeartbeatsEnabled : undefined; resourceInputs["emitHeartbeatsEnabled"] = state ? state.emitHeartbeatsEnabled : undefined; resourceInputs["enable"] = state ? state.enable : undefined; @@ -169,6 +182,7 @@ export class MirrorMakerReplicationFlow extends pulumi.CustomResource { if ((!args || args.targetCluster === undefined) && !opts.urn) { throw new Error("Missing required property 'targetCluster'"); } + resourceInputs["configPropertiesExcludes"] = args ? args.configPropertiesExcludes : undefined; resourceInputs["emitBackwardHeartbeatsEnabled"] = args ? args.emitBackwardHeartbeatsEnabled : undefined; resourceInputs["emitHeartbeatsEnabled"] = args ? args.emitHeartbeatsEnabled : undefined; resourceInputs["enable"] = args ? args.enable : undefined; @@ -193,6 +207,10 @@ export class MirrorMakerReplicationFlow extends pulumi.CustomResource { * Input properties used for looking up and filtering MirrorMakerReplicationFlow resources. */ export interface MirrorMakerReplicationFlowState { + /** + * List of topic configuration properties and/or regular expressions to not replicate. The properties that are not replicated by default are: `follower.replication.throttled.replicas`, `leader.replication.throttled.replicas`, `message.timestamp.difference.max.ms`, `message.timestamp.type`, `unclean.leader.election.enable`, and `min.insync.replicas`. Setting this overrides the defaults. For example, to enable replication for 'min.insync.replicas' and 'unclean.leader.election.enable' set this to: ["follower\\.replication\\.throttled\\.replicas", "leader\\.replication\\.throttled\\.replicas", "message\\.timestamp\\.difference\\.max\\.ms", "message\\.timestamp\\.type"] + */ + configPropertiesExcludes?: pulumi.Input[]>; /** * Whether to emit heartbeats to the direction opposite to the flow, i.e. to the source cluster. The default value is `false`. */ @@ -255,6 +273,10 @@ export interface MirrorMakerReplicationFlowState { * The set of arguments for constructing a MirrorMakerReplicationFlow resource. */ export interface MirrorMakerReplicationFlowArgs { + /** + * List of topic configuration properties and/or regular expressions to not replicate. The properties that are not replicated by default are: `follower.replication.throttled.replicas`, `leader.replication.throttled.replicas`, `message.timestamp.difference.max.ms`, `message.timestamp.type`, `unclean.leader.election.enable`, and `min.insync.replicas`. Setting this overrides the defaults. For example, to enable replication for 'min.insync.replicas' and 'unclean.leader.election.enable' set this to: ["follower\\.replication\\.throttled\\.replicas", "leader\\.replication\\.throttled\\.replicas", "message\\.timestamp\\.difference\\.max\\.ms", "message\\.timestamp\\.type"] + */ + configPropertiesExcludes?: pulumi.Input[]>; /** * Whether to emit heartbeats to the direction opposite to the flow, i.e. to the source cluster. The default value is `false`. */ diff --git a/sdk/python/pulumi_aiven/get_mirror_maker_replication_flow.py b/sdk/python/pulumi_aiven/get_mirror_maker_replication_flow.py index 5b902928..3772b222 100644 --- a/sdk/python/pulumi_aiven/get_mirror_maker_replication_flow.py +++ b/sdk/python/pulumi_aiven/get_mirror_maker_replication_flow.py @@ -21,7 +21,10 @@ class GetMirrorMakerReplicationFlowResult: """ A collection of values returned by getMirrorMakerReplicationFlow. """ - def __init__(__self__, emit_backward_heartbeats_enabled=None, emit_heartbeats_enabled=None, enable=None, id=None, offset_syncs_topic_location=None, project=None, replication_factor=None, replication_policy_class=None, service_name=None, source_cluster=None, sync_group_offsets_enabled=None, sync_group_offsets_interval_seconds=None, target_cluster=None, topics=None, topics_blacklists=None): + def __init__(__self__, config_properties_excludes=None, emit_backward_heartbeats_enabled=None, emit_heartbeats_enabled=None, enable=None, id=None, offset_syncs_topic_location=None, project=None, replication_factor=None, replication_policy_class=None, service_name=None, source_cluster=None, sync_group_offsets_enabled=None, sync_group_offsets_interval_seconds=None, target_cluster=None, topics=None, topics_blacklists=None): + if config_properties_excludes and not isinstance(config_properties_excludes, list): + raise TypeError("Expected argument 'config_properties_excludes' to be a list") + pulumi.set(__self__, "config_properties_excludes", config_properties_excludes) if emit_backward_heartbeats_enabled and not isinstance(emit_backward_heartbeats_enabled, bool): raise TypeError("Expected argument 'emit_backward_heartbeats_enabled' to be a bool") pulumi.set(__self__, "emit_backward_heartbeats_enabled", emit_backward_heartbeats_enabled) @@ -68,6 +71,14 @@ def __init__(__self__, emit_backward_heartbeats_enabled=None, emit_heartbeats_en raise TypeError("Expected argument 'topics_blacklists' to be a list") pulumi.set(__self__, "topics_blacklists", topics_blacklists) + @property + @pulumi.getter(name="configPropertiesExcludes") + def config_properties_excludes(self) -> Sequence[str]: + """ + List of topic configuration properties and/or regular expressions to not replicate. The properties that are not replicated by default are: `follower.replication.throttled.replicas`, `leader.replication.throttled.replicas`, `message.timestamp.difference.max.ms`, `message.timestamp.type`, `unclean.leader.election.enable`, and `min.insync.replicas`. Setting this overrides the defaults. For example, to enable replication for 'min.insync.replicas' and 'unclean.leader.election.enable' set this to: ["follower\\\\.replication\\\\.throttled\\\\.replicas", "leader\\\\.replication\\\\.throttled\\\\.replicas", "message\\\\.timestamp\\\\.difference\\\\.max\\\\.ms", "message\\\\.timestamp\\\\.type"] + """ + return pulumi.get(self, "config_properties_excludes") + @property @pulumi.getter(name="emitBackwardHeartbeatsEnabled") def emit_backward_heartbeats_enabled(self) -> bool: @@ -195,6 +206,7 @@ def __await__(self): if False: yield self return GetMirrorMakerReplicationFlowResult( + config_properties_excludes=self.config_properties_excludes, emit_backward_heartbeats_enabled=self.emit_backward_heartbeats_enabled, emit_heartbeats_enabled=self.emit_heartbeats_enabled, enable=self.enable, @@ -247,6 +259,7 @@ def get_mirror_maker_replication_flow(project: Optional[str] = None, __ret__ = pulumi.runtime.invoke('aiven:index/getMirrorMakerReplicationFlow:getMirrorMakerReplicationFlow', __args__, opts=opts, typ=GetMirrorMakerReplicationFlowResult).value return AwaitableGetMirrorMakerReplicationFlowResult( + config_properties_excludes=pulumi.get(__ret__, 'config_properties_excludes'), emit_backward_heartbeats_enabled=pulumi.get(__ret__, 'emit_backward_heartbeats_enabled'), emit_heartbeats_enabled=pulumi.get(__ret__, 'emit_heartbeats_enabled'), enable=pulumi.get(__ret__, 'enable'), diff --git a/sdk/python/pulumi_aiven/mirror_maker_replication_flow.py b/sdk/python/pulumi_aiven/mirror_maker_replication_flow.py index 49f2369e..1a1054e0 100644 --- a/sdk/python/pulumi_aiven/mirror_maker_replication_flow.py +++ b/sdk/python/pulumi_aiven/mirror_maker_replication_flow.py @@ -21,6 +21,7 @@ def __init__(__self__, *, service_name: pulumi.Input[str], source_cluster: pulumi.Input[str], target_cluster: pulumi.Input[str], + config_properties_excludes: Optional[pulumi.Input[Sequence[pulumi.Input[str]]]] = None, emit_backward_heartbeats_enabled: Optional[pulumi.Input[bool]] = None, emit_heartbeats_enabled: Optional[pulumi.Input[bool]] = None, replication_factor: Optional[pulumi.Input[int]] = None, @@ -37,6 +38,7 @@ def __init__(__self__, *, :param pulumi.Input[str] service_name: The name of the project this resource belongs to. To set up proper dependencies please refer to this variable as a reference. Changing this property forces recreation of the resource. :param pulumi.Input[str] source_cluster: Source cluster alias. Maximum length: `128`. :param pulumi.Input[str] target_cluster: Target cluster alias. Maximum length: `128`. + :param pulumi.Input[Sequence[pulumi.Input[str]]] config_properties_excludes: List of topic configuration properties and/or regular expressions to not replicate. The properties that are not replicated by default are: `follower.replication.throttled.replicas`, `leader.replication.throttled.replicas`, `message.timestamp.difference.max.ms`, `message.timestamp.type`, `unclean.leader.election.enable`, and `min.insync.replicas`. Setting this overrides the defaults. For example, to enable replication for 'min.insync.replicas' and 'unclean.leader.election.enable' set this to: ["follower\\\\.replication\\\\.throttled\\\\.replicas", "leader\\\\.replication\\\\.throttled\\\\.replicas", "message\\\\.timestamp\\\\.difference\\\\.max\\\\.ms", "message\\\\.timestamp\\\\.type"] :param pulumi.Input[bool] emit_backward_heartbeats_enabled: Whether to emit heartbeats to the direction opposite to the flow, i.e. to the source cluster. The default value is `false`. :param pulumi.Input[bool] emit_heartbeats_enabled: Whether to emit heartbeats to the target cluster. The default value is `false`. :param pulumi.Input[int] replication_factor: Replication factor, `>= 1`. @@ -52,6 +54,8 @@ def __init__(__self__, *, pulumi.set(__self__, "service_name", service_name) pulumi.set(__self__, "source_cluster", source_cluster) pulumi.set(__self__, "target_cluster", target_cluster) + if config_properties_excludes is not None: + pulumi.set(__self__, "config_properties_excludes", config_properties_excludes) if emit_backward_heartbeats_enabled is not None: pulumi.set(__self__, "emit_backward_heartbeats_enabled", emit_backward_heartbeats_enabled) if emit_heartbeats_enabled is not None: @@ -151,6 +155,18 @@ def target_cluster(self) -> pulumi.Input[str]: def target_cluster(self, value: pulumi.Input[str]): pulumi.set(self, "target_cluster", value) + @property + @pulumi.getter(name="configPropertiesExcludes") + def config_properties_excludes(self) -> Optional[pulumi.Input[Sequence[pulumi.Input[str]]]]: + """ + List of topic configuration properties and/or regular expressions to not replicate. The properties that are not replicated by default are: `follower.replication.throttled.replicas`, `leader.replication.throttled.replicas`, `message.timestamp.difference.max.ms`, `message.timestamp.type`, `unclean.leader.election.enable`, and `min.insync.replicas`. Setting this overrides the defaults. For example, to enable replication for 'min.insync.replicas' and 'unclean.leader.election.enable' set this to: ["follower\\\\.replication\\\\.throttled\\\\.replicas", "leader\\\\.replication\\\\.throttled\\\\.replicas", "message\\\\.timestamp\\\\.difference\\\\.max\\\\.ms", "message\\\\.timestamp\\\\.type"] + """ + return pulumi.get(self, "config_properties_excludes") + + @config_properties_excludes.setter + def config_properties_excludes(self, value: Optional[pulumi.Input[Sequence[pulumi.Input[str]]]]): + pulumi.set(self, "config_properties_excludes", value) + @property @pulumi.getter(name="emitBackwardHeartbeatsEnabled") def emit_backward_heartbeats_enabled(self) -> Optional[pulumi.Input[bool]]: @@ -239,6 +255,7 @@ def topics_blacklists(self, value: Optional[pulumi.Input[Sequence[pulumi.Input[s @pulumi.input_type class _MirrorMakerReplicationFlowState: def __init__(__self__, *, + config_properties_excludes: Optional[pulumi.Input[Sequence[pulumi.Input[str]]]] = None, emit_backward_heartbeats_enabled: Optional[pulumi.Input[bool]] = None, emit_heartbeats_enabled: Optional[pulumi.Input[bool]] = None, enable: Optional[pulumi.Input[bool]] = None, @@ -255,6 +272,7 @@ def __init__(__self__, *, topics_blacklists: Optional[pulumi.Input[Sequence[pulumi.Input[str]]]] = None): """ Input properties used for looking up and filtering MirrorMakerReplicationFlow resources. + :param pulumi.Input[Sequence[pulumi.Input[str]]] config_properties_excludes: List of topic configuration properties and/or regular expressions to not replicate. The properties that are not replicated by default are: `follower.replication.throttled.replicas`, `leader.replication.throttled.replicas`, `message.timestamp.difference.max.ms`, `message.timestamp.type`, `unclean.leader.election.enable`, and `min.insync.replicas`. Setting this overrides the defaults. For example, to enable replication for 'min.insync.replicas' and 'unclean.leader.election.enable' set this to: ["follower\\\\.replication\\\\.throttled\\\\.replicas", "leader\\\\.replication\\\\.throttled\\\\.replicas", "message\\\\.timestamp\\\\.difference\\\\.max\\\\.ms", "message\\\\.timestamp\\\\.type"] :param pulumi.Input[bool] emit_backward_heartbeats_enabled: Whether to emit heartbeats to the direction opposite to the flow, i.e. to the source cluster. The default value is `false`. :param pulumi.Input[bool] emit_heartbeats_enabled: Whether to emit heartbeats to the target cluster. The default value is `false`. :param pulumi.Input[bool] enable: Enable of disable replication flows for a service. @@ -270,6 +288,8 @@ def __init__(__self__, *, :param pulumi.Input[Sequence[pulumi.Input[str]]] topics: List of topics and/or regular expressions to replicate :param pulumi.Input[Sequence[pulumi.Input[str]]] topics_blacklists: List of topics and/or regular expressions to not replicate. """ + if config_properties_excludes is not None: + pulumi.set(__self__, "config_properties_excludes", config_properties_excludes) if emit_backward_heartbeats_enabled is not None: pulumi.set(__self__, "emit_backward_heartbeats_enabled", emit_backward_heartbeats_enabled) if emit_heartbeats_enabled is not None: @@ -299,6 +319,18 @@ def __init__(__self__, *, if topics_blacklists is not None: pulumi.set(__self__, "topics_blacklists", topics_blacklists) + @property + @pulumi.getter(name="configPropertiesExcludes") + def config_properties_excludes(self) -> Optional[pulumi.Input[Sequence[pulumi.Input[str]]]]: + """ + List of topic configuration properties and/or regular expressions to not replicate. The properties that are not replicated by default are: `follower.replication.throttled.replicas`, `leader.replication.throttled.replicas`, `message.timestamp.difference.max.ms`, `message.timestamp.type`, `unclean.leader.election.enable`, and `min.insync.replicas`. Setting this overrides the defaults. For example, to enable replication for 'min.insync.replicas' and 'unclean.leader.election.enable' set this to: ["follower\\\\.replication\\\\.throttled\\\\.replicas", "leader\\\\.replication\\\\.throttled\\\\.replicas", "message\\\\.timestamp\\\\.difference\\\\.max\\\\.ms", "message\\\\.timestamp\\\\.type"] + """ + return pulumi.get(self, "config_properties_excludes") + + @config_properties_excludes.setter + def config_properties_excludes(self, value: Optional[pulumi.Input[Sequence[pulumi.Input[str]]]]): + pulumi.set(self, "config_properties_excludes", value) + @property @pulumi.getter(name="emitBackwardHeartbeatsEnabled") def emit_backward_heartbeats_enabled(self) -> Optional[pulumi.Input[bool]]: @@ -473,6 +505,7 @@ class MirrorMakerReplicationFlow(pulumi.CustomResource): def __init__(__self__, resource_name: str, opts: Optional[pulumi.ResourceOptions] = None, + config_properties_excludes: Optional[pulumi.Input[Sequence[pulumi.Input[str]]]] = None, emit_backward_heartbeats_enabled: Optional[pulumi.Input[bool]] = None, emit_heartbeats_enabled: Optional[pulumi.Input[bool]] = None, enable: Optional[pulumi.Input[bool]] = None, @@ -508,6 +541,14 @@ def __init__(__self__, ".*[\\\\-\\\\.]internal", ".*\\\\.replica", "__.*", + ], + config_properties_excludes=[ + "follower\\\\.replication\\\\.throttled\\\\.replicas", + "leader\\\\.replication\\\\.throttled\\\\.replicas", + "message\\\\.timestamp\\\\.difference\\\\.max\\\\.ms", + "message\\\\.timestamp\\\\.type", + "unclean\\\\.leader\\\\.election\\\\.enable", + "min\\\\.insync\\\\.replicas", ]) ``` @@ -519,6 +560,7 @@ def __init__(__self__, :param str resource_name: The name of the resource. :param pulumi.ResourceOptions opts: Options for the resource. + :param pulumi.Input[Sequence[pulumi.Input[str]]] config_properties_excludes: List of topic configuration properties and/or regular expressions to not replicate. The properties that are not replicated by default are: `follower.replication.throttled.replicas`, `leader.replication.throttled.replicas`, `message.timestamp.difference.max.ms`, `message.timestamp.type`, `unclean.leader.election.enable`, and `min.insync.replicas`. Setting this overrides the defaults. For example, to enable replication for 'min.insync.replicas' and 'unclean.leader.election.enable' set this to: ["follower\\\\.replication\\\\.throttled\\\\.replicas", "leader\\\\.replication\\\\.throttled\\\\.replicas", "message\\\\.timestamp\\\\.difference\\\\.max\\\\.ms", "message\\\\.timestamp\\\\.type"] :param pulumi.Input[bool] emit_backward_heartbeats_enabled: Whether to emit heartbeats to the direction opposite to the flow, i.e. to the source cluster. The default value is `false`. :param pulumi.Input[bool] emit_heartbeats_enabled: Whether to emit heartbeats to the target cluster. The default value is `false`. :param pulumi.Input[bool] enable: Enable of disable replication flows for a service. @@ -560,6 +602,14 @@ def __init__(__self__, ".*[\\\\-\\\\.]internal", ".*\\\\.replica", "__.*", + ], + config_properties_excludes=[ + "follower\\\\.replication\\\\.throttled\\\\.replicas", + "leader\\\\.replication\\\\.throttled\\\\.replicas", + "message\\\\.timestamp\\\\.difference\\\\.max\\\\.ms", + "message\\\\.timestamp\\\\.type", + "unclean\\\\.leader\\\\.election\\\\.enable", + "min\\\\.insync\\\\.replicas", ]) ``` @@ -584,6 +634,7 @@ def __init__(__self__, resource_name: str, *args, **kwargs): def _internal_init(__self__, resource_name: str, opts: Optional[pulumi.ResourceOptions] = None, + config_properties_excludes: Optional[pulumi.Input[Sequence[pulumi.Input[str]]]] = None, emit_backward_heartbeats_enabled: Optional[pulumi.Input[bool]] = None, emit_heartbeats_enabled: Optional[pulumi.Input[bool]] = None, enable: Optional[pulumi.Input[bool]] = None, @@ -607,6 +658,7 @@ def _internal_init(__self__, raise TypeError('__props__ is only valid when passed in combination with a valid opts.id to get an existing resource') __props__ = MirrorMakerReplicationFlowArgs.__new__(MirrorMakerReplicationFlowArgs) + __props__.__dict__["config_properties_excludes"] = config_properties_excludes __props__.__dict__["emit_backward_heartbeats_enabled"] = emit_backward_heartbeats_enabled __props__.__dict__["emit_heartbeats_enabled"] = emit_heartbeats_enabled if enable is None and not opts.urn: @@ -645,6 +697,7 @@ def _internal_init(__self__, def get(resource_name: str, id: pulumi.Input[str], opts: Optional[pulumi.ResourceOptions] = None, + config_properties_excludes: Optional[pulumi.Input[Sequence[pulumi.Input[str]]]] = None, emit_backward_heartbeats_enabled: Optional[pulumi.Input[bool]] = None, emit_heartbeats_enabled: Optional[pulumi.Input[bool]] = None, enable: Optional[pulumi.Input[bool]] = None, @@ -666,6 +719,7 @@ def get(resource_name: str, :param str resource_name: The unique name of the resulting resource. :param pulumi.Input[str] id: The unique provider ID of the resource to lookup. :param pulumi.ResourceOptions opts: Options for the resource. + :param pulumi.Input[Sequence[pulumi.Input[str]]] config_properties_excludes: List of topic configuration properties and/or regular expressions to not replicate. The properties that are not replicated by default are: `follower.replication.throttled.replicas`, `leader.replication.throttled.replicas`, `message.timestamp.difference.max.ms`, `message.timestamp.type`, `unclean.leader.election.enable`, and `min.insync.replicas`. Setting this overrides the defaults. For example, to enable replication for 'min.insync.replicas' and 'unclean.leader.election.enable' set this to: ["follower\\\\.replication\\\\.throttled\\\\.replicas", "leader\\\\.replication\\\\.throttled\\\\.replicas", "message\\\\.timestamp\\\\.difference\\\\.max\\\\.ms", "message\\\\.timestamp\\\\.type"] :param pulumi.Input[bool] emit_backward_heartbeats_enabled: Whether to emit heartbeats to the direction opposite to the flow, i.e. to the source cluster. The default value is `false`. :param pulumi.Input[bool] emit_heartbeats_enabled: Whether to emit heartbeats to the target cluster. The default value is `false`. :param pulumi.Input[bool] enable: Enable of disable replication flows for a service. @@ -685,6 +739,7 @@ def get(resource_name: str, __props__ = _MirrorMakerReplicationFlowState.__new__(_MirrorMakerReplicationFlowState) + __props__.__dict__["config_properties_excludes"] = config_properties_excludes __props__.__dict__["emit_backward_heartbeats_enabled"] = emit_backward_heartbeats_enabled __props__.__dict__["emit_heartbeats_enabled"] = emit_heartbeats_enabled __props__.__dict__["enable"] = enable @@ -701,6 +756,14 @@ def get(resource_name: str, __props__.__dict__["topics_blacklists"] = topics_blacklists return MirrorMakerReplicationFlow(resource_name, opts=opts, __props__=__props__) + @property + @pulumi.getter(name="configPropertiesExcludes") + def config_properties_excludes(self) -> pulumi.Output[Optional[Sequence[str]]]: + """ + List of topic configuration properties and/or regular expressions to not replicate. The properties that are not replicated by default are: `follower.replication.throttled.replicas`, `leader.replication.throttled.replicas`, `message.timestamp.difference.max.ms`, `message.timestamp.type`, `unclean.leader.election.enable`, and `min.insync.replicas`. Setting this overrides the defaults. For example, to enable replication for 'min.insync.replicas' and 'unclean.leader.election.enable' set this to: ["follower\\\\.replication\\\\.throttled\\\\.replicas", "leader\\\\.replication\\\\.throttled\\\\.replicas", "message\\\\.timestamp\\\\.difference\\\\.max\\\\.ms", "message\\\\.timestamp\\\\.type"] + """ + return pulumi.get(self, "config_properties_excludes") + @property @pulumi.getter(name="emitBackwardHeartbeatsEnabled") def emit_backward_heartbeats_enabled(self) -> pulumi.Output[Optional[bool]]: