Package com.pulumi.aws.mskconnect

Class Connector

  • public class Connector
extends com.pulumi.resources.CustomResource
    Provides an Amazon MSK Connect Connector resource. ## Example Usage ### Basic configuration 
     
 package generated_program;
 
 import com.pulumi.Context;
 import com.pulumi.Pulumi;
 import com.pulumi.core.Output;
 import com.pulumi.aws.mskconnect.Connector;
 import com.pulumi.aws.mskconnect.ConnectorArgs;
 import com.pulumi.aws.mskconnect.inputs.ConnectorCapacityArgs;
 import com.pulumi.aws.mskconnect.inputs.ConnectorCapacityAutoscalingArgs;
 import com.pulumi.aws.mskconnect.inputs.ConnectorCapacityAutoscalingScaleInPolicyArgs;
 import com.pulumi.aws.mskconnect.inputs.ConnectorCapacityAutoscalingScaleOutPolicyArgs;
 import com.pulumi.aws.mskconnect.inputs.ConnectorKafkaClusterArgs;
 import com.pulumi.aws.mskconnect.inputs.ConnectorKafkaClusterApacheKafkaClusterArgs;
 import com.pulumi.aws.mskconnect.inputs.ConnectorKafkaClusterApacheKafkaClusterVpcArgs;
 import com.pulumi.aws.mskconnect.inputs.ConnectorKafkaClusterClientAuthenticationArgs;
 import com.pulumi.aws.mskconnect.inputs.ConnectorKafkaClusterEncryptionInTransitArgs;
 import com.pulumi.aws.mskconnect.inputs.ConnectorPluginArgs;
 import com.pulumi.aws.mskconnect.inputs.ConnectorPluginCustomPluginArgs;
 import java.util.ArrayList;
 import java.util.Arrays;
 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 example = new Connector("example", ConnectorArgs.builder()
             .capacity(ConnectorCapacityArgs.builder()
                 .autoscaling(ConnectorCapacityAutoscalingArgs.builder()
                     .scaleInPolicy(ConnectorCapacityAutoscalingScaleInPolicyArgs.builder()
                         .cpuUtilizationPercentage(20)
                         .build())
                     .scaleOutPolicy(ConnectorCapacityAutoscalingScaleOutPolicyArgs.builder()
                         .cpuUtilizationPercentage(80)
                         .build())
                     .mcuCount(1)
                     .minWorkerCount(1)
                     .maxWorkerCount(2)
                     .build())
                 .build())
             .kafkaCluster(ConnectorKafkaClusterArgs.builder()
                 .apacheKafkaCluster(ConnectorKafkaClusterApacheKafkaClusterArgs.builder()
                     .vpc(ConnectorKafkaClusterApacheKafkaClusterVpcArgs.builder()
                         .securityGroups(exampleAwsSecurityGroup.id())
                         .subnets(                        
                             example1.id(),
                             example2.id(),
                             example3.id())
                         .build())
                     .bootstrapServers(exampleAwsMskCluster.bootstrapBrokersTls())
                     .build())
                 .build())
             .kafkaClusterClientAuthentication(ConnectorKafkaClusterClientAuthenticationArgs.builder()
                 .authenticationType("NONE")
                 .build())
             .kafkaClusterEncryptionInTransit(ConnectorKafkaClusterEncryptionInTransitArgs.builder()
                 .encryptionType("TLS")
                 .build())
             .plugins(ConnectorPluginArgs.builder()
                 .customPlugin(ConnectorPluginCustomPluginArgs.builder()
                     .arn(exampleAwsMskconnectCustomPlugin.arn())
                     .revision(exampleAwsMskconnectCustomPlugin.latestRevision())
                     .build())
                 .build())
             .name("example")
             .kafkaconnectVersion("2.7.1")
             .connectorConfiguration(Map.ofEntries(
                 Map.entry("connector.class", "com.github.jcustenborder.kafka.connect.simulator.SimulatorSinkConnector"),
                 Map.entry("tasks.max", "1"),
                 Map.entry("topics", "example")
             ))
             .serviceExecutionRoleArn(exampleAwsIamRole.arn())
             .build());
 
     }
 }
    ## Import Using `pulumi import`, import MSK Connect Connector using the connector's `arn`. For example: ```sh $ pulumi import aws:mskconnect/connector:Connector example 'arn:aws:kafkaconnect:eu-central-1:123456789012:connector/example/264edee4-17a3-412e-bd76-6681cfc93805-3' ```

    • Nested Class Summary

      • Nested classes/interfaces inherited from class com.pulumi.resources.CustomResource

        com.pulumi.resources.CustomResource.CustomResourceInternal

      • Nested classes/interfaces inherited from class com.pulumi.resources.Resource

        com.pulumi.resources.Resource.LazyField<T extends java.lang.Object>, com.pulumi.resources.Resource.LazyFields, com.pulumi.resources.Resource.ResourceInternal

    • Field Summary

      • Fields inherited from class com.pulumi.resources.Resource

        childResources, remote

    • Constructor Summary

      Constructors 
      Constructor Description
      Connector​(java.lang.String name)  
      Connector​(java.lang.String name, ConnectorArgs args)  
      Connector​(java.lang.String name, ConnectorArgs args, com.pulumi.resources.CustomResourceOptions options)  

    • Constructor Detail

      • Connector

        public Connector​(java.lang.String name)
        Parameters:
        name - The _unique_ name of the resulting resource.

      • Connector

        public Connector​(java.lang.String name,
                 ConnectorArgs args)
        Parameters:
        name - The _unique_ name of the resulting resource.
        args - The arguments to use to populate this resource's properties.

      • Connector

        public Connector​(java.lang.String name,
                 ConnectorArgs args,
                 @Nullable
                 com.pulumi.resources.CustomResourceOptions options)
        Parameters:
        name - The _unique_ name of the resulting resource.
        args - The arguments to use to populate this resource's properties.
        options - A bag of options that control this resource's behavior.

    • Method Detail

      • arn

        public com.pulumi.core.Output<java.lang.String> arn()
        Returns:
        ARN of the connector.

      • capacity

        public com.pulumi.core.Output<ConnectorCapacity> capacity()
        Returns:
        Information about the capacity allocated to the connector. See `capacity` Block for details.

      • connectorConfiguration

        public com.pulumi.core.Output<java.util.Map<java.lang.String,​java.lang.String>> connectorConfiguration()
        Returns:
        Map of keys to values that represent the configuration for the connector.

      • description

        public com.pulumi.core.Output<java.util.Optional<java.lang.String>> description()
        Returns:
        Summary description of the connector.

      • kafkaCluster

        public com.pulumi.core.Output<ConnectorKafkaCluster> kafkaCluster()
        Returns:
        Apache Kafka cluster to connect to. See `kafkaCluster` Block for details.

      • kafkaClusterClientAuthentication

        public com.pulumi.core.Output<ConnectorKafkaClusterClientAuthentication> kafkaClusterClientAuthentication()
        Returns:
        Details of the client authentication used by the Apache Kafka cluster. See `kafkaClusterClientAuthentication` Block for details.

      • kafkaClusterEncryptionInTransit

        public com.pulumi.core.Output<ConnectorKafkaClusterEncryptionInTransit> kafkaClusterEncryptionInTransit()
        Returns:
        Details of encryption in transit to the Apache Kafka cluster. See `kafkaClusterEncryptionInTransit` Block for details.

      • kafkaconnectVersion

        public com.pulumi.core.Output<java.lang.String> kafkaconnectVersion()
        Returns:
        Version of Kafka Connect. It has to be compatible with both the Apache Kafka cluster's version and the plugins.

      • logDelivery

        public com.pulumi.core.Output<java.util.Optional<ConnectorLogDelivery>> logDelivery()
        Returns:
        Details about log delivery. See `logDelivery` Block for details.

      • name

        public com.pulumi.core.Output<java.lang.String> name()
        Returns:
        Name of the connector.

      • plugins

        public com.pulumi.core.Output<java.util.List<ConnectorPlugin>> plugins()
        Returns:
        Plugins to use for the connector. See `plugin` Block for details.

      • region

        public com.pulumi.core.Output<java.lang.String> region()
        Returns:
        Region where this resource will be [managed](https://docs.aws.amazon.com/general/latest/gr/rande.html#regional-endpoints). Defaults to the Region set in the provider configuration.

      • serviceExecutionRoleArn

        public com.pulumi.core.Output<java.lang.String> serviceExecutionRoleArn()
        Returns:
        ARN of the IAM role used by the connector to access the Amazon Web Services resources that it needs. The types of resources depends on the logic of the connector. For example, a connector that has Amazon S3 as a destination must have permissions that allow it to write to the S3 destination bucket. The following arguments are optional:

      • tags

        public com.pulumi.core.Output<java.util.Optional<java.util.Map<java.lang.String,​java.lang.String>>> tags()
        Returns:
        Map of tags to assign to the resource. If configured with a provider `defaultTags` configuration block present, tags with matching keys will overwrite those defined at the provider-level.

      • tagsAll

        public com.pulumi.core.Output<java.util.Map<java.lang.String,​java.lang.String>> tagsAll()
        Returns:
        Map of tags assigned to the resource, including those inherited from the provider `defaultTags` configuration block.

      • version

        public com.pulumi.core.Output<java.lang.String> version()
        Returns:
        Current version of the connector.

      • workerConfiguration

        public com.pulumi.core.Output<java.util.Optional<ConnectorWorkerConfiguration>> workerConfiguration()
        Returns:
        Worker configuration to use with the connector. See `workerConfiguration` Block for details.

      • get

        public static Connector get​(java.lang.String name,
                            com.pulumi.core.Output<java.lang.String> id,
                            @Nullable
                            ConnectorState state,
                            @Nullable
                            com.pulumi.resources.CustomResourceOptions options)
        Get an existing Host resource's state with the given name, ID, and optional extra properties used to qualify the lookup.
        Parameters:
        name - The _unique_ name of the resulting resource.
        id - The _unique_ provider ID of the resource to lookup.
        state -
        options - Optional settings to control the behavior of the CustomResource.