Aiven v6.13.0 published on Monday, Mar 25, 2024 by Pulumi
aiven.getMirrorMakerReplicationFlow
Explore with Pulumi AI
The MirrorMaker 2 Replication Flow data source provides information about the existing MirrorMaker 2 Replication Flow on Aiven Cloud.
Example Usage
import * as pulumi from "@pulumi/pulumi";
import * as aiven from "@pulumi/aiven";
const f1 = aiven.getMirrorMakerReplicationFlow({
project: aiven_project["kafka-mm-project1"].project,
serviceName: aiven_kafka.mm.service_name,
sourceCluster: aiven_kafka.source.service_name,
targetCluster: aiven_kafka.target.service_name,
});
import pulumi
import pulumi_aiven as aiven
f1 = aiven.get_mirror_maker_replication_flow(project=aiven_project["kafka-mm-project1"]["project"],
service_name=aiven_kafka["mm"]["service_name"],
source_cluster=aiven_kafka["source"]["service_name"],
target_cluster=aiven_kafka["target"]["service_name"])
package main
import (
"github.com/pulumi/pulumi-aiven/sdk/v6/go/aiven"
"github.com/pulumi/pulumi/sdk/v3/go/pulumi"
)
func main() {
pulumi.Run(func(ctx *pulumi.Context) error {
_, err := aiven.LookupMirrorMakerReplicationFlow(ctx, &aiven.LookupMirrorMakerReplicationFlowArgs{
Project: aiven_project.KafkaMmProject1.Project,
ServiceName: aiven_kafka.Mm.Service_name,
SourceCluster: aiven_kafka.Source.Service_name,
TargetCluster: aiven_kafka.Target.Service_name,
}, nil)
if err != nil {
return err
}
return nil
})
}
using System.Collections.Generic;
using System.Linq;
using Pulumi;
using Aiven = Pulumi.Aiven;
return await Deployment.RunAsync(() =>
{
var f1 = Aiven.GetMirrorMakerReplicationFlow.Invoke(new()
{
Project = aiven_project.Kafka_mm_project1.Project,
ServiceName = aiven_kafka.Mm.Service_name,
SourceCluster = aiven_kafka.Source.Service_name,
TargetCluster = aiven_kafka.Target.Service_name,
});
});
package generated_program;
import com.pulumi.Context;
import com.pulumi.Pulumi;
import com.pulumi.core.Output;
import com.pulumi.aiven.AivenFunctions;
import com.pulumi.aiven.inputs.GetMirrorMakerReplicationFlowArgs;
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) {
final var f1 = AivenFunctions.getMirrorMakerReplicationFlow(GetMirrorMakerReplicationFlowArgs.builder()
.project(aiven_project.kafka-mm-project1().project())
.serviceName(aiven_kafka.mm().service_name())
.sourceCluster(aiven_kafka.source().service_name())
.targetCluster(aiven_kafka.target().service_name())
.build());
}
}
variables:
f1:
fn::invoke:
Function: aiven:getMirrorMakerReplicationFlow
Arguments:
project: ${aiven_project"kafka-mm-project1"[%!s(MISSING)].project}
serviceName: ${aiven_kafka.mm.service_name}
sourceCluster: ${aiven_kafka.source.service_name}
targetCluster: ${aiven_kafka.target.service_name}
Using getMirrorMakerReplicationFlow
Two invocation forms are available. The direct form accepts plain arguments and either blocks until the result value is available, or returns a Promise-wrapped result. The output form accepts Input-wrapped arguments and returns an Output-wrapped result.
function getMirrorMakerReplicationFlow(args: GetMirrorMakerReplicationFlowArgs, opts?: InvokeOptions): Promise<GetMirrorMakerReplicationFlowResult>
function getMirrorMakerReplicationFlowOutput(args: GetMirrorMakerReplicationFlowOutputArgs, opts?: InvokeOptions): Output<GetMirrorMakerReplicationFlowResult>
def get_mirror_maker_replication_flow(project: Optional[str] = None,
service_name: Optional[str] = None,
source_cluster: Optional[str] = None,
target_cluster: Optional[str] = None,
opts: Optional[InvokeOptions] = None) -> GetMirrorMakerReplicationFlowResult
def get_mirror_maker_replication_flow_output(project: Optional[pulumi.Input[str]] = None,
service_name: Optional[pulumi.Input[str]] = None,
source_cluster: Optional[pulumi.Input[str]] = None,
target_cluster: Optional[pulumi.Input[str]] = None,
opts: Optional[InvokeOptions] = None) -> Output[GetMirrorMakerReplicationFlowResult]
func LookupMirrorMakerReplicationFlow(ctx *Context, args *LookupMirrorMakerReplicationFlowArgs, opts ...InvokeOption) (*LookupMirrorMakerReplicationFlowResult, error)
func LookupMirrorMakerReplicationFlowOutput(ctx *Context, args *LookupMirrorMakerReplicationFlowOutputArgs, opts ...InvokeOption) LookupMirrorMakerReplicationFlowResultOutput
> Note: This function is named LookupMirrorMakerReplicationFlow
in the Go SDK.
public static class GetMirrorMakerReplicationFlow
{
public static Task<GetMirrorMakerReplicationFlowResult> InvokeAsync(GetMirrorMakerReplicationFlowArgs args, InvokeOptions? opts = null)
public static Output<GetMirrorMakerReplicationFlowResult> Invoke(GetMirrorMakerReplicationFlowInvokeArgs args, InvokeOptions? opts = null)
}
public static CompletableFuture<GetMirrorMakerReplicationFlowResult> getMirrorMakerReplicationFlow(GetMirrorMakerReplicationFlowArgs args, InvokeOptions options)
// Output-based functions aren't available in Java yet
fn::invoke:
function: aiven:index/getMirrorMakerReplicationFlow:getMirrorMakerReplicationFlow
arguments:
# arguments dictionary
The following arguments are supported:
- Project string
- Identifies 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.
- Service
Name string - Identifies 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.
- Source
Cluster string - Source cluster alias. Maximum length:
128
. - Target
Cluster string - Target cluster alias. Maximum length:
128
.
- Project string
- Identifies 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.
- Service
Name string - Identifies 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.
- Source
Cluster string - Source cluster alias. Maximum length:
128
. - Target
Cluster string - Target cluster alias. Maximum length:
128
.
- project String
- Identifies 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.
- service
Name String - Identifies 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.
- source
Cluster String - Source cluster alias. Maximum length:
128
. - target
Cluster String - Target cluster alias. Maximum length:
128
.
- project string
- Identifies 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.
- service
Name string - Identifies 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.
- source
Cluster string - Source cluster alias. Maximum length:
128
. - target
Cluster string - Target cluster alias. Maximum length:
128
.
- project str
- Identifies 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.
- service_
name str - Identifies 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.
- source_
cluster str - Source cluster alias. Maximum length:
128
. - target_
cluster str - Target cluster alias. Maximum length:
128
.
- project String
- Identifies 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.
- service
Name String - Identifies 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.
- source
Cluster String - Source cluster alias. Maximum length:
128
. - target
Cluster String - Target cluster alias. Maximum length:
128
.
getMirrorMakerReplicationFlow Result
The following output properties are available:
- Emit
Backward boolHeartbeats Enabled - Whether to emit heartbeats to the direction opposite to the flow, i.e. to the source cluster. The default value is
false
. - Emit
Heartbeats boolEnabled - Whether to emit heartbeats to the target cluster. The default value is
false
. - Enable bool
- Enable of disable replication flows for a service.
- Id string
- The provider-assigned unique ID for this managed resource.
- Offset
Syncs stringTopic Location - Offset syncs topic location.
- Project string
- Identifies 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.
- Replication
Policy stringClass - Replication policy class. The possible values are
org.apache.kafka.connect.mirror.DefaultReplicationPolicy
andorg.apache.kafka.connect.mirror.IdentityReplicationPolicy
. The default value isorg.apache.kafka.connect.mirror.DefaultReplicationPolicy
. - Service
Name string - Identifies 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.
- Source
Cluster string - Source cluster alias. Maximum length:
128
. - Sync
Group boolOffsets Enabled - Sync consumer group offsets. The default value is
false
. - Sync
Group intOffsets Interval Seconds - Frequency of consumer group offset sync. The default value is
1
. - Target
Cluster string - Target cluster alias. Maximum length:
128
. - Topics List<string>
- List of topics and/or regular expressions to replicate
- Topics
Blacklists List<string> - List of topics and/or regular expressions to not replicate.
- Emit
Backward boolHeartbeats Enabled - Whether to emit heartbeats to the direction opposite to the flow, i.e. to the source cluster. The default value is
false
. - Emit
Heartbeats boolEnabled - Whether to emit heartbeats to the target cluster. The default value is
false
. - Enable bool
- Enable of disable replication flows for a service.
- Id string
- The provider-assigned unique ID for this managed resource.
- Offset
Syncs stringTopic Location - Offset syncs topic location.
- Project string
- Identifies 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.
- Replication
Policy stringClass - Replication policy class. The possible values are
org.apache.kafka.connect.mirror.DefaultReplicationPolicy
andorg.apache.kafka.connect.mirror.IdentityReplicationPolicy
. The default value isorg.apache.kafka.connect.mirror.DefaultReplicationPolicy
. - Service
Name string - Identifies 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.
- Source
Cluster string - Source cluster alias. Maximum length:
128
. - Sync
Group boolOffsets Enabled - Sync consumer group offsets. The default value is
false
. - Sync
Group intOffsets Interval Seconds - Frequency of consumer group offset sync. The default value is
1
. - Target
Cluster string - Target cluster alias. Maximum length:
128
. - Topics []string
- List of topics and/or regular expressions to replicate
- Topics
Blacklists []string - List of topics and/or regular expressions to not replicate.
- emit
Backward BooleanHeartbeats Enabled - Whether to emit heartbeats to the direction opposite to the flow, i.e. to the source cluster. The default value is
false
. - emit
Heartbeats BooleanEnabled - Whether to emit heartbeats to the target cluster. The default value is
false
. - enable Boolean
- Enable of disable replication flows for a service.
- id String
- The provider-assigned unique ID for this managed resource.
- offset
Syncs StringTopic Location - Offset syncs topic location.
- project String
- Identifies 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.
- replication
Policy StringClass - Replication policy class. The possible values are
org.apache.kafka.connect.mirror.DefaultReplicationPolicy
andorg.apache.kafka.connect.mirror.IdentityReplicationPolicy
. The default value isorg.apache.kafka.connect.mirror.DefaultReplicationPolicy
. - service
Name String - Identifies 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.
- source
Cluster String - Source cluster alias. Maximum length:
128
. - sync
Group BooleanOffsets Enabled - Sync consumer group offsets. The default value is
false
. - sync
Group IntegerOffsets Interval Seconds - Frequency of consumer group offset sync. The default value is
1
. - target
Cluster String - Target cluster alias. Maximum length:
128
. - topics List<String>
- List of topics and/or regular expressions to replicate
- topics
Blacklists List<String> - List of topics and/or regular expressions to not replicate.
- emit
Backward booleanHeartbeats Enabled - Whether to emit heartbeats to the direction opposite to the flow, i.e. to the source cluster. The default value is
false
. - emit
Heartbeats booleanEnabled - Whether to emit heartbeats to the target cluster. The default value is
false
. - enable boolean
- Enable of disable replication flows for a service.
- id string
- The provider-assigned unique ID for this managed resource.
- offset
Syncs stringTopic Location - Offset syncs topic location.
- project string
- Identifies 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.
- replication
Policy stringClass - Replication policy class. The possible values are
org.apache.kafka.connect.mirror.DefaultReplicationPolicy
andorg.apache.kafka.connect.mirror.IdentityReplicationPolicy
. The default value isorg.apache.kafka.connect.mirror.DefaultReplicationPolicy
. - service
Name string - Identifies 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.
- source
Cluster string - Source cluster alias. Maximum length:
128
. - sync
Group booleanOffsets Enabled - Sync consumer group offsets. The default value is
false
. - sync
Group numberOffsets Interval Seconds - Frequency of consumer group offset sync. The default value is
1
. - target
Cluster string - Target cluster alias. Maximum length:
128
. - topics string[]
- List of topics and/or regular expressions to replicate
- topics
Blacklists string[] - List of topics and/or regular expressions to not replicate.
- emit_
backward_ boolheartbeats_ enabled - Whether to emit heartbeats to the direction opposite to the flow, i.e. to the source cluster. The default value is
false
. - emit_
heartbeats_ boolenabled - Whether to emit heartbeats to the target cluster. The default value is
false
. - enable bool
- Enable of disable replication flows for a service.
- id str
- The provider-assigned unique ID for this managed resource.
- offset_
syncs_ strtopic_ location - Offset syncs topic location.
- project str
- Identifies 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.
- replication_
policy_ strclass - Replication policy class. The possible values are
org.apache.kafka.connect.mirror.DefaultReplicationPolicy
andorg.apache.kafka.connect.mirror.IdentityReplicationPolicy
. The default value isorg.apache.kafka.connect.mirror.DefaultReplicationPolicy
. - service_
name str - Identifies 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.
- source_
cluster str - Source cluster alias. Maximum length:
128
. - sync_
group_ booloffsets_ enabled - Sync consumer group offsets. The default value is
false
. - sync_
group_ intoffsets_ interval_ seconds - Frequency of consumer group offset sync. The default value is
1
. - target_
cluster str - Target cluster alias. Maximum length:
128
. - topics Sequence[str]
- List of topics and/or regular expressions to replicate
- topics_
blacklists Sequence[str] - List of topics and/or regular expressions to not replicate.
- emit
Backward BooleanHeartbeats Enabled - Whether to emit heartbeats to the direction opposite to the flow, i.e. to the source cluster. The default value is
false
. - emit
Heartbeats BooleanEnabled - Whether to emit heartbeats to the target cluster. The default value is
false
. - enable Boolean
- Enable of disable replication flows for a service.
- id String
- The provider-assigned unique ID for this managed resource.
- offset
Syncs StringTopic Location - Offset syncs topic location.
- project String
- Identifies 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.
- replication
Policy StringClass - Replication policy class. The possible values are
org.apache.kafka.connect.mirror.DefaultReplicationPolicy
andorg.apache.kafka.connect.mirror.IdentityReplicationPolicy
. The default value isorg.apache.kafka.connect.mirror.DefaultReplicationPolicy
. - service
Name String - Identifies 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.
- source
Cluster String - Source cluster alias. Maximum length:
128
. - sync
Group BooleanOffsets Enabled - Sync consumer group offsets. The default value is
false
. - sync
Group NumberOffsets Interval Seconds - Frequency of consumer group offset sync. The default value is
1
. - target
Cluster String - Target cluster alias. Maximum length:
128
. - topics List<String>
- List of topics and/or regular expressions to replicate
- topics
Blacklists List<String> - List of topics and/or regular expressions to not replicate.
Package Details
- Repository
- Aiven pulumi/pulumi-aiven
- License
- Apache-2.0
- Notes
- This Pulumi package is based on the
aiven
Terraform Provider.