Class ReplicatorReplicationInfoListArgs


  • public final class ReplicatorReplicationInfoListArgs
    extends com.pulumi.resources.ResourceArgs
    • Method Detail

      • sourceKafkaClusterAlias

        public java.util.Optional<com.pulumi.core.Output<java.lang.String>> sourceKafkaClusterAlias()
        Returns:
        Alias of the source Kafka cluster.
      • sourceKafkaClusterArn

        public java.util.Optional<com.pulumi.core.Output<java.lang.String>> sourceKafkaClusterArn()
        Returns:
        ARN of the source Kafka cluster. Use for an Amazon MSK source. Exactly one of `sourceKafkaClusterArn` or `sourceKafkaClusterId` must be specified.
      • sourceKafkaClusterId

        public java.util.Optional<com.pulumi.core.Output<java.lang.String>> sourceKafkaClusterId()
        Returns:
        Identifier of the source Kafka cluster. Use for a self-managed / on-premises Apache Kafka source (matches `apacheKafkaClusterId`). Exactly one of `sourceKafkaClusterArn` or `sourceKafkaClusterId` must be specified.
      • targetCompressionType

        public com.pulumi.core.Output<java.lang.String> targetCompressionType()
        Returns:
        Type of compression to use writing records to target Kafka cluster.
      • targetKafkaClusterAlias

        public java.util.Optional<com.pulumi.core.Output<java.lang.String>> targetKafkaClusterAlias()
        Returns:
        Alias of the target Kafka cluster.
      • targetKafkaClusterArn

        public java.util.Optional<com.pulumi.core.Output<java.lang.String>> targetKafkaClusterArn()
        Returns:
        ARN of the target Kafka cluster. Use for an Amazon MSK target. Exactly one of `targetKafkaClusterArn` or `targetKafkaClusterId` must be specified.
      • targetKafkaClusterId

        public java.util.Optional<com.pulumi.core.Output<java.lang.String>> targetKafkaClusterId()
        Returns:
        Identifier of the target Kafka cluster. Use for a self-managed / on-premises Apache Kafka target (matches `apacheKafkaClusterId`). Exactly one of `targetKafkaClusterArn` or `targetKafkaClusterId` must be specified.