1. Packages
  2. Konnect Provider
  3. API Docs
  4. GatewayPluginConfluentConsume
konnect 3.4.1 published on Wednesday, Oct 29, 2025 by kong

konnect.GatewayPluginConfluentConsume

Get Started
konnect logo
konnect 3.4.1 published on Wednesday, Oct 29, 2025 by kong

    GatewayPluginConfluentConsume Resource

    Example Usage

    Example coming soon!
    
    Example coming soon!
    
    Example coming soon!
    
    Example coming soon!
    
    package generated_program;
    
    import com.pulumi.Context;
    import com.pulumi.Pulumi;
    import com.pulumi.core.Output;
    import com.pulumi.konnect.GatewayPluginConfluentConsume;
    import com.pulumi.konnect.GatewayPluginConfluentConsumeArgs;
    import com.pulumi.konnect.inputs.GatewayPluginConfluentConsumeConfigArgs;
    import com.pulumi.konnect.inputs.GatewayPluginConfluentConsumeConsumerArgs;
    import com.pulumi.konnect.inputs.GatewayPluginConfluentConsumeOrderingArgs;
    import com.pulumi.konnect.inputs.GatewayPluginConfluentConsumeOrderingAfterArgs;
    import com.pulumi.konnect.inputs.GatewayPluginConfluentConsumeOrderingBeforeArgs;
    import com.pulumi.konnect.inputs.GatewayPluginConfluentConsumePartialArgs;
    import com.pulumi.konnect.inputs.GatewayPluginConfluentConsumeRouteArgs;
    import com.pulumi.konnect.inputs.GatewayPluginConfluentConsumeServiceArgs;
    import static com.pulumi.codegen.internal.Serialization.*;
    import java.util.List;
    import java.util.ArrayList;
    import java.util.Map;
    import java.io.File;
    import java.nio.file.Files;
    import java.nio.file.Paths;
    
    public class App {
        public static void main(String[] args) {
            Pulumi.run(App::stack);
        }
    
        public static void stack(Context ctx) {
            var myGatewaypluginconfluentconsume = new GatewayPluginConfluentConsume("myGatewaypluginconfluentconsume", GatewayPluginConfluentConsumeArgs.builder()
                .config(GatewayPluginConfluentConsumeConfigArgs.builder()
                    .auto_offset_reset("earliest")
                    .bootstrap_servers(%!v(PANIC=Format method: runtime error: invalid memory address or nil pointer dereference))
                    .cluster_api_key("...my_cluster_api_key...")
                    .cluster_api_secret("...my_cluster_api_secret...")
                    .cluster_name("...my_cluster_name...")
                    .commit_strategy("auto")
                    .confluent_cloud_api_key("...my_confluent_cloud_api_key...")
                    .confluent_cloud_api_secret("...my_confluent_cloud_api_secret...")
                    .dlq_topic("...my_dlq_topic...")
                    .enable_dlq(true)
                    .keepalive(2)
                    .keepalive_enabled(true)
                    .message_by_lua_functions("...")
                    .message_deserializer("noop")
                    .mode("http-get")
                    .schema_registry(%!v(PANIC=Format method: runtime error: invalid memory address or nil pointer dereference))
                    .timeout(7)
                    .topics(GatewayPluginConfluentConsumeConfigTopicArgs.builder()
                        .name("...my_name...")
                        .schemaRegistry(GatewayPluginConfluentConsumeConfigTopicSchemaRegistryArgs.builder()
                            .confluent(GatewayPluginConfluentConsumeConfigTopicSchemaRegistryConfluentArgs.builder()
                                .authentication(GatewayPluginConfluentConsumeConfigTopicSchemaRegistryConfluentAuthenticationArgs.builder()
                                    .basic(GatewayPluginConfluentConsumeConfigTopicSchemaRegistryConfluentAuthenticationBasicArgs.builder()
                                        .password("...my_password...")
                                        .username("...my_username...")
                                        .build())
                                    .mode("basic")
                                    .oauth2(GatewayPluginConfluentConsumeConfigTopicSchemaRegistryConfluentAuthenticationOauth2Args.builder()
                                        .audience("...")
                                        .clientId("...my_client_id...")
                                        .clientSecret("...my_client_secret...")
                                        .grantType("client_credentials")
                                        .password("...my_password...")
                                        .scopes("...")
                                        .tokenEndpoint("...my_token_endpoint...")
                                        .tokenHeaders(Map.of("key", serializeJson(
                                            "value")))
                                        .tokenPostArgs(Map.of("key", serializeJson(
                                            "value")))
                                        .username("...my_username...")
                                        .build())
                                    .oauth2Client(GatewayPluginConfluentConsumeConfigTopicSchemaRegistryConfluentAuthenticationOauth2ClientArgs.builder()
                                        .authMethod("client_secret_basic")
                                        .clientSecretJwtAlg("HS512")
                                        .httpProxy("...my_http_proxy...")
                                        .httpProxyAuthorization("...my_http_proxy_authorization...")
                                        .httpVersion(5.07)
                                        .httpsProxy("...my_https_proxy...")
                                        .httpsProxyAuthorization("...my_https_proxy_authorization...")
                                        .keepAlive(false)
                                        .noProxy("...my_no_proxy...")
                                        .sslVerify(true)
                                        .timeout(1747283445)
                                        .build())
                                    .build())
                                .sslVerify(true)
                                .ttl(179.01)
                                .url("...my_url...")
                                .build())
                            .build())
                        .build())
                    .build())
                .consumer(GatewayPluginConfluentConsumeConsumerArgs.builder()
                    .id("...my_id...")
                    .build())
                .controlPlaneId("9524ec7d-36d9-465d-a8c5-83a3c9390458")
                .createdAt(6)
                .enabled(true)
                .gatewayPluginConfluentConsumeId("...my_id...")
                .instanceName("...my_instance_name...")
                .ordering(GatewayPluginConfluentConsumeOrderingArgs.builder()
                    .after(GatewayPluginConfluentConsumeOrderingAfterArgs.builder()
                        .access("...")
                        .build())
                    .before(GatewayPluginConfluentConsumeOrderingBeforeArgs.builder()
                        .access("...")
                        .build())
                    .build())
                .partials(GatewayPluginConfluentConsumePartialArgs.builder()
                    .id("...my_id...")
                    .name("...my_name...")
                    .path("...my_path...")
                    .build())
                .protocols("wss")
                .route(GatewayPluginConfluentConsumeRouteArgs.builder()
                    .id("...my_id...")
                    .build())
                .service(GatewayPluginConfluentConsumeServiceArgs.builder()
                    .id("...my_id...")
                    .build())
                .tags("...")
                .updatedAt(0)
                .build());
    
        }
    }
    
    resources:
      myGatewaypluginconfluentconsume:
        type: konnect:GatewayPluginConfluentConsume
        properties:
          config:
            auto_offset_reset: earliest
            bootstrap_servers:
              - host: '...my_host...'
                port: 58521
            cluster_api_key: '...my_cluster_api_key...'
            cluster_api_secret: '...my_cluster_api_secret...'
            cluster_name: '...my_cluster_name...'
            commit_strategy: auto
            confluent_cloud_api_key: '...my_confluent_cloud_api_key...'
            confluent_cloud_api_secret: '...my_confluent_cloud_api_secret...'
            dlq_topic: '...my_dlq_topic...'
            enable_dlq: true
            keepalive: 2
            keepalive_enabled: true
            message_by_lua_functions:
              - '...'
            message_deserializer: noop
            mode: http-get
            schema_registry:
              confluent:
                authentication:
                  basic:
                    password: '...my_password...'
                    username: '...my_username...'
                  mode: basic
                  oauth2:
                    audience:
                      - '...'
                    clientId: '...my_client_id...'
                    clientSecret: '...my_client_secret...'
                    grantType: password
                    password: '...my_password...'
                    scopes:
                      - '...'
                    tokenEndpoint: '...my_token_endpoint...'
                    tokenHeaders:
                      key:
                        fn::toJSON: value
                    tokenPostArgs:
                      key:
                        fn::toJSON: value
                    username: '...my_username...'
                  oauth2Client:
                    authMethod: client_secret_basic
                    clientSecretJwtAlg: HS512
                    httpProxy: '...my_http_proxy...'
                    httpProxyAuthorization: '...my_http_proxy_authorization...'
                    httpVersion: 8.6
                    httpsProxy: '...my_https_proxy...'
                    httpsProxyAuthorization: '...my_https_proxy_authorization...'
                    keepAlive: false
                    noProxy: '...my_no_proxy...'
                    sslVerify: true
                    timeout: 5.95962925e+08
                sslVerify: false
                ttl: 2309.04
                url: '...my_url...'
            timeout: 7
            topics:
              - name: '...my_name...'
                schemaRegistry:
                  confluent:
                    authentication:
                      basic:
                        password: '...my_password...'
                        username: '...my_username...'
                      mode: basic
                      oauth2:
                        audience:
                          - '...'
                        clientId: '...my_client_id...'
                        clientSecret: '...my_client_secret...'
                        grantType: client_credentials
                        password: '...my_password...'
                        scopes:
                          - '...'
                        tokenEndpoint: '...my_token_endpoint...'
                        tokenHeaders:
                          key:
                            fn::toJSON: value
                        tokenPostArgs:
                          key:
                            fn::toJSON: value
                        username: '...my_username...'
                      oauth2Client:
                        authMethod: client_secret_basic
                        clientSecretJwtAlg: HS512
                        httpProxy: '...my_http_proxy...'
                        httpProxyAuthorization: '...my_http_proxy_authorization...'
                        httpVersion: 5.07
                        httpsProxy: '...my_https_proxy...'
                        httpsProxyAuthorization: '...my_https_proxy_authorization...'
                        keepAlive: false
                        noProxy: '...my_no_proxy...'
                        sslVerify: true
                        timeout: 1.747283445e+09
                    sslVerify: true
                    ttl: 179.01
                    url: '...my_url...'
          consumer:
            id: '...my_id...'
          controlPlaneId: 9524ec7d-36d9-465d-a8c5-83a3c9390458
          createdAt: 6
          enabled: true
          gatewayPluginConfluentConsumeId: '...my_id...'
          instanceName: '...my_instance_name...'
          ordering:
            after:
              access:
                - '...'
            before:
              access:
                - '...'
          partials:
            - id: '...my_id...'
              name: '...my_name...'
              path: '...my_path...'
          protocols:
            - wss
          route:
            id: '...my_id...'
          service:
            id: '...my_id...'
          tags:
            - '...'
          updatedAt: 0
    

    Create GatewayPluginConfluentConsume Resource

    Resources are created with functions called constructors. To learn more about declaring and configuring resources, see Resources.

    Constructor syntax

    new GatewayPluginConfluentConsume(name: string, args: GatewayPluginConfluentConsumeArgs, opts?: CustomResourceOptions);
    @overload
    def GatewayPluginConfluentConsume(resource_name: str,
                                      args: GatewayPluginConfluentConsumeArgs,
                                      opts: Optional[ResourceOptions] = None)
    
    @overload
    def GatewayPluginConfluentConsume(resource_name: str,
                                      opts: Optional[ResourceOptions] = None,
                                      control_plane_id: Optional[str] = None,
                                      config: Optional[GatewayPluginConfluentConsumeConfigArgs] = None,
                                      instance_name: Optional[str] = None,
                                      created_at: Optional[float] = None,
                                      enabled: Optional[bool] = None,
                                      gateway_plugin_confluent_consume_id: Optional[str] = None,
                                      consumer: Optional[GatewayPluginConfluentConsumeConsumerArgs] = None,
                                      ordering: Optional[GatewayPluginConfluentConsumeOrderingArgs] = None,
                                      partials: Optional[Sequence[GatewayPluginConfluentConsumePartialArgs]] = None,
                                      protocols: Optional[Sequence[str]] = None,
                                      route: Optional[GatewayPluginConfluentConsumeRouteArgs] = None,
                                      service: Optional[GatewayPluginConfluentConsumeServiceArgs] = None,
                                      tags: Optional[Sequence[str]] = None,
                                      updated_at: Optional[float] = None)
    func NewGatewayPluginConfluentConsume(ctx *Context, name string, args GatewayPluginConfluentConsumeArgs, opts ...ResourceOption) (*GatewayPluginConfluentConsume, error)
    public GatewayPluginConfluentConsume(string name, GatewayPluginConfluentConsumeArgs args, CustomResourceOptions? opts = null)
    public GatewayPluginConfluentConsume(String name, GatewayPluginConfluentConsumeArgs args)
    public GatewayPluginConfluentConsume(String name, GatewayPluginConfluentConsumeArgs args, CustomResourceOptions options)
    
    type: konnect:GatewayPluginConfluentConsume
    properties: # The arguments to resource properties.
    options: # Bag of options to control resource's behavior.
    
    

    Parameters

    name string
    The unique name of the resource.
    args GatewayPluginConfluentConsumeArgs
    The arguments to resource properties.
    opts CustomResourceOptions
    Bag of options to control resource's behavior.
    resource_name str
    The unique name of the resource.
    args GatewayPluginConfluentConsumeArgs
    The arguments to resource properties.
    opts ResourceOptions
    Bag of options to control resource's behavior.
    ctx Context
    Context object for the current deployment.
    name string
    The unique name of the resource.
    args GatewayPluginConfluentConsumeArgs
    The arguments to resource properties.
    opts ResourceOption
    Bag of options to control resource's behavior.
    name string
    The unique name of the resource.
    args GatewayPluginConfluentConsumeArgs
    The arguments to resource properties.
    opts CustomResourceOptions
    Bag of options to control resource's behavior.
    name String
    The unique name of the resource.
    args GatewayPluginConfluentConsumeArgs
    The arguments to resource properties.
    options CustomResourceOptions
    Bag of options to control resource's behavior.

    Constructor example

    The following reference example uses placeholder values for all input properties.

    var gatewayPluginConfluentConsumeResource = new Konnect.GatewayPluginConfluentConsume("gatewayPluginConfluentConsumeResource", new()
    {
        ControlPlaneId = "string",
        Config = new Konnect.Inputs.GatewayPluginConfluentConsumeConfigArgs
        {
            ClusterApiSecret = "string",
            Topics = new[]
            {
                new Konnect.Inputs.GatewayPluginConfluentConsumeConfigTopicArgs
                {
                    Name = "string",
                    SchemaRegistry = new Konnect.Inputs.GatewayPluginConfluentConsumeConfigTopicSchemaRegistryArgs
                    {
                        Confluent = new Konnect.Inputs.GatewayPluginConfluentConsumeConfigTopicSchemaRegistryConfluentArgs
                        {
                            Authentication = new Konnect.Inputs.GatewayPluginConfluentConsumeConfigTopicSchemaRegistryConfluentAuthenticationArgs
                            {
                                Basic = new Konnect.Inputs.GatewayPluginConfluentConsumeConfigTopicSchemaRegistryConfluentAuthenticationBasicArgs
                                {
                                    Password = "string",
                                    Username = "string",
                                },
                                Mode = "string",
                                Oauth2 = new Konnect.Inputs.GatewayPluginConfluentConsumeConfigTopicSchemaRegistryConfluentAuthenticationOauth2Args
                                {
                                    Audiences = new[]
                                    {
                                        "string",
                                    },
                                    ClientId = "string",
                                    ClientSecret = "string",
                                    GrantType = "string",
                                    Password = "string",
                                    Scopes = new[]
                                    {
                                        "string",
                                    },
                                    TokenEndpoint = "string",
                                    TokenHeaders = 
                                    {
                                        { "string", "string" },
                                    },
                                    TokenPostArgs = 
                                    {
                                        { "string", "string" },
                                    },
                                    Username = "string",
                                },
                                Oauth2Client = new Konnect.Inputs.GatewayPluginConfluentConsumeConfigTopicSchemaRegistryConfluentAuthenticationOauth2ClientArgs
                                {
                                    AuthMethod = "string",
                                    ClientSecretJwtAlg = "string",
                                    HttpProxy = "string",
                                    HttpProxyAuthorization = "string",
                                    HttpVersion = 0,
                                    HttpsProxy = "string",
                                    HttpsProxyAuthorization = "string",
                                    KeepAlive = false,
                                    NoProxy = "string",
                                    SslVerify = false,
                                    Timeout = 0,
                                },
                            },
                            SslVerify = false,
                            Ttl = 0,
                            Url = "string",
                        },
                    },
                },
            },
            ClusterApiKey = "string",
            DlqTopic = "string",
            Keepalive = 0,
            CommitStrategy = "string",
            ConfluentCloudApiKey = "string",
            ConfluentCloudApiSecret = "string",
            AutoOffsetReset = "string",
            EnableDlq = false,
            ClusterName = "string",
            KeepaliveEnabled = false,
            MessageByLuaFunctions = new[]
            {
                "string",
            },
            MessageDeserializer = "string",
            Mode = "string",
            SchemaRegistry = new Konnect.Inputs.GatewayPluginConfluentConsumeConfigSchemaRegistryArgs
            {
                Confluent = new Konnect.Inputs.GatewayPluginConfluentConsumeConfigSchemaRegistryConfluentArgs
                {
                    Authentication = new Konnect.Inputs.GatewayPluginConfluentConsumeConfigSchemaRegistryConfluentAuthenticationArgs
                    {
                        Basic = new Konnect.Inputs.GatewayPluginConfluentConsumeConfigSchemaRegistryConfluentAuthenticationBasicArgs
                        {
                            Password = "string",
                            Username = "string",
                        },
                        Mode = "string",
                        Oauth2 = new Konnect.Inputs.GatewayPluginConfluentConsumeConfigSchemaRegistryConfluentAuthenticationOauth2Args
                        {
                            TokenEndpoint = "string",
                            Audiences = new[]
                            {
                                "string",
                            },
                            ClientId = "string",
                            ClientSecret = "string",
                            GrantType = "string",
                            Password = "string",
                            Scopes = new[]
                            {
                                "string",
                            },
                            TokenHeaders = 
                            {
                                { "string", "string" },
                            },
                            TokenPostArgs = 
                            {
                                { "string", "string" },
                            },
                            Username = "string",
                        },
                        Oauth2Client = new Konnect.Inputs.GatewayPluginConfluentConsumeConfigSchemaRegistryConfluentAuthenticationOauth2ClientArgs
                        {
                            AuthMethod = "string",
                            ClientSecretJwtAlg = "string",
                            HttpProxy = "string",
                            HttpProxyAuthorization = "string",
                            HttpVersion = 0,
                            HttpsProxy = "string",
                            HttpsProxyAuthorization = "string",
                            KeepAlive = false,
                            NoProxy = "string",
                            SslVerify = false,
                            Timeout = 0,
                        },
                    },
                    SslVerify = false,
                    Ttl = 0,
                    Url = "string",
                },
            },
            Timeout = 0,
            BootstrapServers = new[]
            {
                new Konnect.Inputs.GatewayPluginConfluentConsumeConfigBootstrapServerArgs
                {
                    Host = "string",
                    Port = 0,
                },
            },
        },
        InstanceName = "string",
        CreatedAt = 0,
        Enabled = false,
        GatewayPluginConfluentConsumeId = "string",
        Consumer = new Konnect.Inputs.GatewayPluginConfluentConsumeConsumerArgs
        {
            Id = "string",
        },
        Ordering = new Konnect.Inputs.GatewayPluginConfluentConsumeOrderingArgs
        {
            After = new Konnect.Inputs.GatewayPluginConfluentConsumeOrderingAfterArgs
            {
                Accesses = new[]
                {
                    "string",
                },
            },
            Before = new Konnect.Inputs.GatewayPluginConfluentConsumeOrderingBeforeArgs
            {
                Accesses = new[]
                {
                    "string",
                },
            },
        },
        Partials = new[]
        {
            new Konnect.Inputs.GatewayPluginConfluentConsumePartialArgs
            {
                Id = "string",
                Name = "string",
                Path = "string",
            },
        },
        Protocols = new[]
        {
            "string",
        },
        Route = new Konnect.Inputs.GatewayPluginConfluentConsumeRouteArgs
        {
            Id = "string",
        },
        Service = new Konnect.Inputs.GatewayPluginConfluentConsumeServiceArgs
        {
            Id = "string",
        },
        Tags = new[]
        {
            "string",
        },
        UpdatedAt = 0,
    });
    
    example, err := konnect.NewGatewayPluginConfluentConsume(ctx, "gatewayPluginConfluentConsumeResource", &konnect.GatewayPluginConfluentConsumeArgs{
    	ControlPlaneId: pulumi.String("string"),
    	Config: &konnect.GatewayPluginConfluentConsumeConfigArgs{
    		ClusterApiSecret: pulumi.String("string"),
    		Topics: konnect.GatewayPluginConfluentConsumeConfigTopicArray{
    			&konnect.GatewayPluginConfluentConsumeConfigTopicArgs{
    				Name: pulumi.String("string"),
    				SchemaRegistry: &konnect.GatewayPluginConfluentConsumeConfigTopicSchemaRegistryArgs{
    					Confluent: &konnect.GatewayPluginConfluentConsumeConfigTopicSchemaRegistryConfluentArgs{
    						Authentication: &konnect.GatewayPluginConfluentConsumeConfigTopicSchemaRegistryConfluentAuthenticationArgs{
    							Basic: &konnect.GatewayPluginConfluentConsumeConfigTopicSchemaRegistryConfluentAuthenticationBasicArgs{
    								Password: pulumi.String("string"),
    								Username: pulumi.String("string"),
    							},
    							Mode: pulumi.String("string"),
    							Oauth2: &konnect.GatewayPluginConfluentConsumeConfigTopicSchemaRegistryConfluentAuthenticationOauth2Args{
    								Audiences: pulumi.StringArray{
    									pulumi.String("string"),
    								},
    								ClientId:     pulumi.String("string"),
    								ClientSecret: pulumi.String("string"),
    								GrantType:    pulumi.String("string"),
    								Password:     pulumi.String("string"),
    								Scopes: pulumi.StringArray{
    									pulumi.String("string"),
    								},
    								TokenEndpoint: pulumi.String("string"),
    								TokenHeaders: pulumi.StringMap{
    									"string": pulumi.String("string"),
    								},
    								TokenPostArgs: pulumi.StringMap{
    									"string": pulumi.String("string"),
    								},
    								Username: pulumi.String("string"),
    							},
    							Oauth2Client: &konnect.GatewayPluginConfluentConsumeConfigTopicSchemaRegistryConfluentAuthenticationOauth2ClientArgs{
    								AuthMethod:              pulumi.String("string"),
    								ClientSecretJwtAlg:      pulumi.String("string"),
    								HttpProxy:               pulumi.String("string"),
    								HttpProxyAuthorization:  pulumi.String("string"),
    								HttpVersion:             pulumi.Float64(0),
    								HttpsProxy:              pulumi.String("string"),
    								HttpsProxyAuthorization: pulumi.String("string"),
    								KeepAlive:               pulumi.Bool(false),
    								NoProxy:                 pulumi.String("string"),
    								SslVerify:               pulumi.Bool(false),
    								Timeout:                 pulumi.Float64(0),
    							},
    						},
    						SslVerify: pulumi.Bool(false),
    						Ttl:       pulumi.Float64(0),
    						Url:       pulumi.String("string"),
    					},
    				},
    			},
    		},
    		ClusterApiKey:           pulumi.String("string"),
    		DlqTopic:                pulumi.String("string"),
    		Keepalive:               pulumi.Float64(0),
    		CommitStrategy:          pulumi.String("string"),
    		ConfluentCloudApiKey:    pulumi.String("string"),
    		ConfluentCloudApiSecret: pulumi.String("string"),
    		AutoOffsetReset:         pulumi.String("string"),
    		EnableDlq:               pulumi.Bool(false),
    		ClusterName:             pulumi.String("string"),
    		KeepaliveEnabled:        pulumi.Bool(false),
    		MessageByLuaFunctions: pulumi.StringArray{
    			pulumi.String("string"),
    		},
    		MessageDeserializer: pulumi.String("string"),
    		Mode:                pulumi.String("string"),
    		SchemaRegistry: &konnect.GatewayPluginConfluentConsumeConfigSchemaRegistryArgs{
    			Confluent: &konnect.GatewayPluginConfluentConsumeConfigSchemaRegistryConfluentArgs{
    				Authentication: &konnect.GatewayPluginConfluentConsumeConfigSchemaRegistryConfluentAuthenticationArgs{
    					Basic: &konnect.GatewayPluginConfluentConsumeConfigSchemaRegistryConfluentAuthenticationBasicArgs{
    						Password: pulumi.String("string"),
    						Username: pulumi.String("string"),
    					},
    					Mode: pulumi.String("string"),
    					Oauth2: &konnect.GatewayPluginConfluentConsumeConfigSchemaRegistryConfluentAuthenticationOauth2Args{
    						TokenEndpoint: pulumi.String("string"),
    						Audiences: pulumi.StringArray{
    							pulumi.String("string"),
    						},
    						ClientId:     pulumi.String("string"),
    						ClientSecret: pulumi.String("string"),
    						GrantType:    pulumi.String("string"),
    						Password:     pulumi.String("string"),
    						Scopes: pulumi.StringArray{
    							pulumi.String("string"),
    						},
    						TokenHeaders: pulumi.StringMap{
    							"string": pulumi.String("string"),
    						},
    						TokenPostArgs: pulumi.StringMap{
    							"string": pulumi.String("string"),
    						},
    						Username: pulumi.String("string"),
    					},
    					Oauth2Client: &konnect.GatewayPluginConfluentConsumeConfigSchemaRegistryConfluentAuthenticationOauth2ClientArgs{
    						AuthMethod:              pulumi.String("string"),
    						ClientSecretJwtAlg:      pulumi.String("string"),
    						HttpProxy:               pulumi.String("string"),
    						HttpProxyAuthorization:  pulumi.String("string"),
    						HttpVersion:             pulumi.Float64(0),
    						HttpsProxy:              pulumi.String("string"),
    						HttpsProxyAuthorization: pulumi.String("string"),
    						KeepAlive:               pulumi.Bool(false),
    						NoProxy:                 pulumi.String("string"),
    						SslVerify:               pulumi.Bool(false),
    						Timeout:                 pulumi.Float64(0),
    					},
    				},
    				SslVerify: pulumi.Bool(false),
    				Ttl:       pulumi.Float64(0),
    				Url:       pulumi.String("string"),
    			},
    		},
    		Timeout: pulumi.Float64(0),
    		BootstrapServers: konnect.GatewayPluginConfluentConsumeConfigBootstrapServerArray{
    			&konnect.GatewayPluginConfluentConsumeConfigBootstrapServerArgs{
    				Host: pulumi.String("string"),
    				Port: pulumi.Float64(0),
    			},
    		},
    	},
    	InstanceName:                    pulumi.String("string"),
    	CreatedAt:                       pulumi.Float64(0),
    	Enabled:                         pulumi.Bool(false),
    	GatewayPluginConfluentConsumeId: pulumi.String("string"),
    	Consumer: &konnect.GatewayPluginConfluentConsumeConsumerArgs{
    		Id: pulumi.String("string"),
    	},
    	Ordering: &konnect.GatewayPluginConfluentConsumeOrderingArgs{
    		After: &konnect.GatewayPluginConfluentConsumeOrderingAfterArgs{
    			Accesses: pulumi.StringArray{
    				pulumi.String("string"),
    			},
    		},
    		Before: &konnect.GatewayPluginConfluentConsumeOrderingBeforeArgs{
    			Accesses: pulumi.StringArray{
    				pulumi.String("string"),
    			},
    		},
    	},
    	Partials: konnect.GatewayPluginConfluentConsumePartialArray{
    		&konnect.GatewayPluginConfluentConsumePartialArgs{
    			Id:   pulumi.String("string"),
    			Name: pulumi.String("string"),
    			Path: pulumi.String("string"),
    		},
    	},
    	Protocols: pulumi.StringArray{
    		pulumi.String("string"),
    	},
    	Route: &konnect.GatewayPluginConfluentConsumeRouteArgs{
    		Id: pulumi.String("string"),
    	},
    	Service: &konnect.GatewayPluginConfluentConsumeServiceArgs{
    		Id: pulumi.String("string"),
    	},
    	Tags: pulumi.StringArray{
    		pulumi.String("string"),
    	},
    	UpdatedAt: pulumi.Float64(0),
    })
    
    var gatewayPluginConfluentConsumeResource = new GatewayPluginConfluentConsume("gatewayPluginConfluentConsumeResource", GatewayPluginConfluentConsumeArgs.builder()
        .controlPlaneId("string")
        .config(GatewayPluginConfluentConsumeConfigArgs.builder()
            .clusterApiSecret("string")
            .topics(GatewayPluginConfluentConsumeConfigTopicArgs.builder()
                .name("string")
                .schemaRegistry(GatewayPluginConfluentConsumeConfigTopicSchemaRegistryArgs.builder()
                    .confluent(GatewayPluginConfluentConsumeConfigTopicSchemaRegistryConfluentArgs.builder()
                        .authentication(GatewayPluginConfluentConsumeConfigTopicSchemaRegistryConfluentAuthenticationArgs.builder()
                            .basic(GatewayPluginConfluentConsumeConfigTopicSchemaRegistryConfluentAuthenticationBasicArgs.builder()
                                .password("string")
                                .username("string")
                                .build())
                            .mode("string")
                            .oauth2(GatewayPluginConfluentConsumeConfigTopicSchemaRegistryConfluentAuthenticationOauth2Args.builder()
                                .audiences("string")
                                .clientId("string")
                                .clientSecret("string")
                                .grantType("string")
                                .password("string")
                                .scopes("string")
                                .tokenEndpoint("string")
                                .tokenHeaders(Map.of("string", "string"))
                                .tokenPostArgs(Map.of("string", "string"))
                                .username("string")
                                .build())
                            .oauth2Client(GatewayPluginConfluentConsumeConfigTopicSchemaRegistryConfluentAuthenticationOauth2ClientArgs.builder()
                                .authMethod("string")
                                .clientSecretJwtAlg("string")
                                .httpProxy("string")
                                .httpProxyAuthorization("string")
                                .httpVersion(0.0)
                                .httpsProxy("string")
                                .httpsProxyAuthorization("string")
                                .keepAlive(false)
                                .noProxy("string")
                                .sslVerify(false)
                                .timeout(0.0)
                                .build())
                            .build())
                        .sslVerify(false)
                        .ttl(0.0)
                        .url("string")
                        .build())
                    .build())
                .build())
            .clusterApiKey("string")
            .dlqTopic("string")
            .keepalive(0.0)
            .commitStrategy("string")
            .confluentCloudApiKey("string")
            .confluentCloudApiSecret("string")
            .autoOffsetReset("string")
            .enableDlq(false)
            .clusterName("string")
            .keepaliveEnabled(false)
            .messageByLuaFunctions("string")
            .messageDeserializer("string")
            .mode("string")
            .schemaRegistry(GatewayPluginConfluentConsumeConfigSchemaRegistryArgs.builder()
                .confluent(GatewayPluginConfluentConsumeConfigSchemaRegistryConfluentArgs.builder()
                    .authentication(GatewayPluginConfluentConsumeConfigSchemaRegistryConfluentAuthenticationArgs.builder()
                        .basic(GatewayPluginConfluentConsumeConfigSchemaRegistryConfluentAuthenticationBasicArgs.builder()
                            .password("string")
                            .username("string")
                            .build())
                        .mode("string")
                        .oauth2(GatewayPluginConfluentConsumeConfigSchemaRegistryConfluentAuthenticationOauth2Args.builder()
                            .tokenEndpoint("string")
                            .audiences("string")
                            .clientId("string")
                            .clientSecret("string")
                            .grantType("string")
                            .password("string")
                            .scopes("string")
                            .tokenHeaders(Map.of("string", "string"))
                            .tokenPostArgs(Map.of("string", "string"))
                            .username("string")
                            .build())
                        .oauth2Client(GatewayPluginConfluentConsumeConfigSchemaRegistryConfluentAuthenticationOauth2ClientArgs.builder()
                            .authMethod("string")
                            .clientSecretJwtAlg("string")
                            .httpProxy("string")
                            .httpProxyAuthorization("string")
                            .httpVersion(0.0)
                            .httpsProxy("string")
                            .httpsProxyAuthorization("string")
                            .keepAlive(false)
                            .noProxy("string")
                            .sslVerify(false)
                            .timeout(0.0)
                            .build())
                        .build())
                    .sslVerify(false)
                    .ttl(0.0)
                    .url("string")
                    .build())
                .build())
            .timeout(0.0)
            .bootstrapServers(GatewayPluginConfluentConsumeConfigBootstrapServerArgs.builder()
                .host("string")
                .port(0.0)
                .build())
            .build())
        .instanceName("string")
        .createdAt(0.0)
        .enabled(false)
        .gatewayPluginConfluentConsumeId("string")
        .consumer(GatewayPluginConfluentConsumeConsumerArgs.builder()
            .id("string")
            .build())
        .ordering(GatewayPluginConfluentConsumeOrderingArgs.builder()
            .after(GatewayPluginConfluentConsumeOrderingAfterArgs.builder()
                .accesses("string")
                .build())
            .before(GatewayPluginConfluentConsumeOrderingBeforeArgs.builder()
                .accesses("string")
                .build())
            .build())
        .partials(GatewayPluginConfluentConsumePartialArgs.builder()
            .id("string")
            .name("string")
            .path("string")
            .build())
        .protocols("string")
        .route(GatewayPluginConfluentConsumeRouteArgs.builder()
            .id("string")
            .build())
        .service(GatewayPluginConfluentConsumeServiceArgs.builder()
            .id("string")
            .build())
        .tags("string")
        .updatedAt(0.0)
        .build());
    
    gateway_plugin_confluent_consume_resource = konnect.GatewayPluginConfluentConsume("gatewayPluginConfluentConsumeResource",
        control_plane_id="string",
        config={
            "cluster_api_secret": "string",
            "topics": [{
                "name": "string",
                "schema_registry": {
                    "confluent": {
                        "authentication": {
                            "basic": {
                                "password": "string",
                                "username": "string",
                            },
                            "mode": "string",
                            "oauth2": {
                                "audiences": ["string"],
                                "client_id": "string",
                                "client_secret": "string",
                                "grant_type": "string",
                                "password": "string",
                                "scopes": ["string"],
                                "token_endpoint": "string",
                                "token_headers": {
                                    "string": "string",
                                },
                                "token_post_args": {
                                    "string": "string",
                                },
                                "username": "string",
                            },
                            "oauth2_client": {
                                "auth_method": "string",
                                "client_secret_jwt_alg": "string",
                                "http_proxy": "string",
                                "http_proxy_authorization": "string",
                                "http_version": 0,
                                "https_proxy": "string",
                                "https_proxy_authorization": "string",
                                "keep_alive": False,
                                "no_proxy": "string",
                                "ssl_verify": False,
                                "timeout": 0,
                            },
                        },
                        "ssl_verify": False,
                        "ttl": 0,
                        "url": "string",
                    },
                },
            }],
            "cluster_api_key": "string",
            "dlq_topic": "string",
            "keepalive": 0,
            "commit_strategy": "string",
            "confluent_cloud_api_key": "string",
            "confluent_cloud_api_secret": "string",
            "auto_offset_reset": "string",
            "enable_dlq": False,
            "cluster_name": "string",
            "keepalive_enabled": False,
            "message_by_lua_functions": ["string"],
            "message_deserializer": "string",
            "mode": "string",
            "schema_registry": {
                "confluent": {
                    "authentication": {
                        "basic": {
                            "password": "string",
                            "username": "string",
                        },
                        "mode": "string",
                        "oauth2": {
                            "token_endpoint": "string",
                            "audiences": ["string"],
                            "client_id": "string",
                            "client_secret": "string",
                            "grant_type": "string",
                            "password": "string",
                            "scopes": ["string"],
                            "token_headers": {
                                "string": "string",
                            },
                            "token_post_args": {
                                "string": "string",
                            },
                            "username": "string",
                        },
                        "oauth2_client": {
                            "auth_method": "string",
                            "client_secret_jwt_alg": "string",
                            "http_proxy": "string",
                            "http_proxy_authorization": "string",
                            "http_version": 0,
                            "https_proxy": "string",
                            "https_proxy_authorization": "string",
                            "keep_alive": False,
                            "no_proxy": "string",
                            "ssl_verify": False,
                            "timeout": 0,
                        },
                    },
                    "ssl_verify": False,
                    "ttl": 0,
                    "url": "string",
                },
            },
            "timeout": 0,
            "bootstrap_servers": [{
                "host": "string",
                "port": 0,
            }],
        },
        instance_name="string",
        created_at=0,
        enabled=False,
        gateway_plugin_confluent_consume_id="string",
        consumer={
            "id": "string",
        },
        ordering={
            "after": {
                "accesses": ["string"],
            },
            "before": {
                "accesses": ["string"],
            },
        },
        partials=[{
            "id": "string",
            "name": "string",
            "path": "string",
        }],
        protocols=["string"],
        route={
            "id": "string",
        },
        service={
            "id": "string",
        },
        tags=["string"],
        updated_at=0)
    
    const gatewayPluginConfluentConsumeResource = new konnect.GatewayPluginConfluentConsume("gatewayPluginConfluentConsumeResource", {
        controlPlaneId: "string",
        config: {
            clusterApiSecret: "string",
            topics: [{
                name: "string",
                schemaRegistry: {
                    confluent: {
                        authentication: {
                            basic: {
                                password: "string",
                                username: "string",
                            },
                            mode: "string",
                            oauth2: {
                                audiences: ["string"],
                                clientId: "string",
                                clientSecret: "string",
                                grantType: "string",
                                password: "string",
                                scopes: ["string"],
                                tokenEndpoint: "string",
                                tokenHeaders: {
                                    string: "string",
                                },
                                tokenPostArgs: {
                                    string: "string",
                                },
                                username: "string",
                            },
                            oauth2Client: {
                                authMethod: "string",
                                clientSecretJwtAlg: "string",
                                httpProxy: "string",
                                httpProxyAuthorization: "string",
                                httpVersion: 0,
                                httpsProxy: "string",
                                httpsProxyAuthorization: "string",
                                keepAlive: false,
                                noProxy: "string",
                                sslVerify: false,
                                timeout: 0,
                            },
                        },
                        sslVerify: false,
                        ttl: 0,
                        url: "string",
                    },
                },
            }],
            clusterApiKey: "string",
            dlqTopic: "string",
            keepalive: 0,
            commitStrategy: "string",
            confluentCloudApiKey: "string",
            confluentCloudApiSecret: "string",
            autoOffsetReset: "string",
            enableDlq: false,
            clusterName: "string",
            keepaliveEnabled: false,
            messageByLuaFunctions: ["string"],
            messageDeserializer: "string",
            mode: "string",
            schemaRegistry: {
                confluent: {
                    authentication: {
                        basic: {
                            password: "string",
                            username: "string",
                        },
                        mode: "string",
                        oauth2: {
                            tokenEndpoint: "string",
                            audiences: ["string"],
                            clientId: "string",
                            clientSecret: "string",
                            grantType: "string",
                            password: "string",
                            scopes: ["string"],
                            tokenHeaders: {
                                string: "string",
                            },
                            tokenPostArgs: {
                                string: "string",
                            },
                            username: "string",
                        },
                        oauth2Client: {
                            authMethod: "string",
                            clientSecretJwtAlg: "string",
                            httpProxy: "string",
                            httpProxyAuthorization: "string",
                            httpVersion: 0,
                            httpsProxy: "string",
                            httpsProxyAuthorization: "string",
                            keepAlive: false,
                            noProxy: "string",
                            sslVerify: false,
                            timeout: 0,
                        },
                    },
                    sslVerify: false,
                    ttl: 0,
                    url: "string",
                },
            },
            timeout: 0,
            bootstrapServers: [{
                host: "string",
                port: 0,
            }],
        },
        instanceName: "string",
        createdAt: 0,
        enabled: false,
        gatewayPluginConfluentConsumeId: "string",
        consumer: {
            id: "string",
        },
        ordering: {
            after: {
                accesses: ["string"],
            },
            before: {
                accesses: ["string"],
            },
        },
        partials: [{
            id: "string",
            name: "string",
            path: "string",
        }],
        protocols: ["string"],
        route: {
            id: "string",
        },
        service: {
            id: "string",
        },
        tags: ["string"],
        updatedAt: 0,
    });
    
    type: konnect:GatewayPluginConfluentConsume
    properties:
        config:
            autoOffsetReset: string
            bootstrapServers:
                - host: string
                  port: 0
            clusterApiKey: string
            clusterApiSecret: string
            clusterName: string
            commitStrategy: string
            confluentCloudApiKey: string
            confluentCloudApiSecret: string
            dlqTopic: string
            enableDlq: false
            keepalive: 0
            keepaliveEnabled: false
            messageByLuaFunctions:
                - string
            messageDeserializer: string
            mode: string
            schemaRegistry:
                confluent:
                    authentication:
                        basic:
                            password: string
                            username: string
                        mode: string
                        oauth2:
                            audiences:
                                - string
                            clientId: string
                            clientSecret: string
                            grantType: string
                            password: string
                            scopes:
                                - string
                            tokenEndpoint: string
                            tokenHeaders:
                                string: string
                            tokenPostArgs:
                                string: string
                            username: string
                        oauth2Client:
                            authMethod: string
                            clientSecretJwtAlg: string
                            httpProxy: string
                            httpProxyAuthorization: string
                            httpVersion: 0
                            httpsProxy: string
                            httpsProxyAuthorization: string
                            keepAlive: false
                            noProxy: string
                            sslVerify: false
                            timeout: 0
                    sslVerify: false
                    ttl: 0
                    url: string
            timeout: 0
            topics:
                - name: string
                  schemaRegistry:
                    confluent:
                        authentication:
                            basic:
                                password: string
                                username: string
                            mode: string
                            oauth2:
                                audiences:
                                    - string
                                clientId: string
                                clientSecret: string
                                grantType: string
                                password: string
                                scopes:
                                    - string
                                tokenEndpoint: string
                                tokenHeaders:
                                    string: string
                                tokenPostArgs:
                                    string: string
                                username: string
                            oauth2Client:
                                authMethod: string
                                clientSecretJwtAlg: string
                                httpProxy: string
                                httpProxyAuthorization: string
                                httpVersion: 0
                                httpsProxy: string
                                httpsProxyAuthorization: string
                                keepAlive: false
                                noProxy: string
                                sslVerify: false
                                timeout: 0
                        sslVerify: false
                        ttl: 0
                        url: string
        consumer:
            id: string
        controlPlaneId: string
        createdAt: 0
        enabled: false
        gatewayPluginConfluentConsumeId: string
        instanceName: string
        ordering:
            after:
                accesses:
                    - string
            before:
                accesses:
                    - string
        partials:
            - id: string
              name: string
              path: string
        protocols:
            - string
        route:
            id: string
        service:
            id: string
        tags:
            - string
        updatedAt: 0
    

    GatewayPluginConfluentConsume Resource Properties

    To learn more about resource properties and how to use them, see Inputs and Outputs in the Architecture and Concepts docs.

    Inputs

    In Python, inputs that are objects can be passed either as argument classes or as dictionary literals.

    The GatewayPluginConfluentConsume resource accepts the following input properties:

    Config GatewayPluginConfluentConsumeConfig
    ControlPlaneId string
    The UUID of your control plane. This variable is available in the Konnect manager. Requires replacement if changed.
    Consumer GatewayPluginConfluentConsumeConsumer
    If set, the plugin will activate only for requests where the specified has been authenticated. (Note that some plugins can not be restricted to consumers this way.). Leave unset for the plugin to activate regardless of the authenticated Consumer.
    CreatedAt double
    Unix epoch when the resource was created.
    Enabled bool
    Whether the plugin is applied. Default: true
    GatewayPluginConfluentConsumeId string
    A string representing a UUID (universally unique identifier).
    InstanceName string
    A unique string representing a UTF-8 encoded name.
    Ordering GatewayPluginConfluentConsumeOrdering
    Partials List<GatewayPluginConfluentConsumePartial>
    A list of partials to be used by the plugin.
    Protocols List<string>
    A list of the request protocols that will trigger this plugin. The default value, as well as the possible values allowed on this field, may change depending on the plugin type. For example, plugins that only work in stream mode will only support tcp and tls. Default: ["grpc","grpcs","http","https","ws","wss"]
    Route GatewayPluginConfluentConsumeRoute
    If set, the plugin will only activate when receiving requests via the specified route. Leave unset for the plugin to activate regardless of the route being used.
    Service GatewayPluginConfluentConsumeService
    If set, the plugin will only activate when receiving requests via one of the routes belonging to the specified Service. Leave unset for the plugin to activate regardless of the Service being matched.
    Tags List<string>
    An optional set of strings associated with the Plugin for grouping and filtering.
    UpdatedAt double
    Unix epoch when the resource was last updated.
    Config GatewayPluginConfluentConsumeConfigArgs
    ControlPlaneId string
    The UUID of your control plane. This variable is available in the Konnect manager. Requires replacement if changed.
    Consumer GatewayPluginConfluentConsumeConsumerArgs
    If set, the plugin will activate only for requests where the specified has been authenticated. (Note that some plugins can not be restricted to consumers this way.). Leave unset for the plugin to activate regardless of the authenticated Consumer.
    CreatedAt float64
    Unix epoch when the resource was created.
    Enabled bool
    Whether the plugin is applied. Default: true
    GatewayPluginConfluentConsumeId string
    A string representing a UUID (universally unique identifier).
    InstanceName string
    A unique string representing a UTF-8 encoded name.
    Ordering GatewayPluginConfluentConsumeOrderingArgs
    Partials []GatewayPluginConfluentConsumePartialArgs
    A list of partials to be used by the plugin.
    Protocols []string
    A list of the request protocols that will trigger this plugin. The default value, as well as the possible values allowed on this field, may change depending on the plugin type. For example, plugins that only work in stream mode will only support tcp and tls. Default: ["grpc","grpcs","http","https","ws","wss"]
    Route GatewayPluginConfluentConsumeRouteArgs
    If set, the plugin will only activate when receiving requests via the specified route. Leave unset for the plugin to activate regardless of the route being used.
    Service GatewayPluginConfluentConsumeServiceArgs
    If set, the plugin will only activate when receiving requests via one of the routes belonging to the specified Service. Leave unset for the plugin to activate regardless of the Service being matched.
    Tags []string
    An optional set of strings associated with the Plugin for grouping and filtering.
    UpdatedAt float64
    Unix epoch when the resource was last updated.
    config GatewayPluginConfluentConsumeConfig
    controlPlaneId String
    The UUID of your control plane. This variable is available in the Konnect manager. Requires replacement if changed.
    consumer GatewayPluginConfluentConsumeConsumer
    If set, the plugin will activate only for requests where the specified has been authenticated. (Note that some plugins can not be restricted to consumers this way.). Leave unset for the plugin to activate regardless of the authenticated Consumer.
    createdAt Double
    Unix epoch when the resource was created.
    enabled Boolean
    Whether the plugin is applied. Default: true
    gatewayPluginConfluentConsumeId String
    A string representing a UUID (universally unique identifier).
    instanceName String
    A unique string representing a UTF-8 encoded name.
    ordering GatewayPluginConfluentConsumeOrdering
    partials List<GatewayPluginConfluentConsumePartial>
    A list of partials to be used by the plugin.
    protocols List<String>
    A list of the request protocols that will trigger this plugin. The default value, as well as the possible values allowed on this field, may change depending on the plugin type. For example, plugins that only work in stream mode will only support tcp and tls. Default: ["grpc","grpcs","http","https","ws","wss"]
    route GatewayPluginConfluentConsumeRoute
    If set, the plugin will only activate when receiving requests via the specified route. Leave unset for the plugin to activate regardless of the route being used.
    service GatewayPluginConfluentConsumeService
    If set, the plugin will only activate when receiving requests via one of the routes belonging to the specified Service. Leave unset for the plugin to activate regardless of the Service being matched.
    tags List<String>
    An optional set of strings associated with the Plugin for grouping and filtering.
    updatedAt Double
    Unix epoch when the resource was last updated.
    config GatewayPluginConfluentConsumeConfig
    controlPlaneId string
    The UUID of your control plane. This variable is available in the Konnect manager. Requires replacement if changed.
    consumer GatewayPluginConfluentConsumeConsumer
    If set, the plugin will activate only for requests where the specified has been authenticated. (Note that some plugins can not be restricted to consumers this way.). Leave unset for the plugin to activate regardless of the authenticated Consumer.
    createdAt number
    Unix epoch when the resource was created.
    enabled boolean
    Whether the plugin is applied. Default: true
    gatewayPluginConfluentConsumeId string
    A string representing a UUID (universally unique identifier).
    instanceName string
    A unique string representing a UTF-8 encoded name.
    ordering GatewayPluginConfluentConsumeOrdering
    partials GatewayPluginConfluentConsumePartial[]
    A list of partials to be used by the plugin.
    protocols string[]
    A list of the request protocols that will trigger this plugin. The default value, as well as the possible values allowed on this field, may change depending on the plugin type. For example, plugins that only work in stream mode will only support tcp and tls. Default: ["grpc","grpcs","http","https","ws","wss"]
    route GatewayPluginConfluentConsumeRoute
    If set, the plugin will only activate when receiving requests via the specified route. Leave unset for the plugin to activate regardless of the route being used.
    service GatewayPluginConfluentConsumeService
    If set, the plugin will only activate when receiving requests via one of the routes belonging to the specified Service. Leave unset for the plugin to activate regardless of the Service being matched.
    tags string[]
    An optional set of strings associated with the Plugin for grouping and filtering.
    updatedAt number
    Unix epoch when the resource was last updated.
    config GatewayPluginConfluentConsumeConfigArgs
    control_plane_id str
    The UUID of your control plane. This variable is available in the Konnect manager. Requires replacement if changed.
    consumer GatewayPluginConfluentConsumeConsumerArgs
    If set, the plugin will activate only for requests where the specified has been authenticated. (Note that some plugins can not be restricted to consumers this way.). Leave unset for the plugin to activate regardless of the authenticated Consumer.
    created_at float
    Unix epoch when the resource was created.
    enabled bool
    Whether the plugin is applied. Default: true
    gateway_plugin_confluent_consume_id str
    A string representing a UUID (universally unique identifier).
    instance_name str
    A unique string representing a UTF-8 encoded name.
    ordering GatewayPluginConfluentConsumeOrderingArgs
    partials Sequence[GatewayPluginConfluentConsumePartialArgs]
    A list of partials to be used by the plugin.
    protocols Sequence[str]
    A list of the request protocols that will trigger this plugin. The default value, as well as the possible values allowed on this field, may change depending on the plugin type. For example, plugins that only work in stream mode will only support tcp and tls. Default: ["grpc","grpcs","http","https","ws","wss"]
    route GatewayPluginConfluentConsumeRouteArgs
    If set, the plugin will only activate when receiving requests via the specified route. Leave unset for the plugin to activate regardless of the route being used.
    service GatewayPluginConfluentConsumeServiceArgs
    If set, the plugin will only activate when receiving requests via one of the routes belonging to the specified Service. Leave unset for the plugin to activate regardless of the Service being matched.
    tags Sequence[str]
    An optional set of strings associated with the Plugin for grouping and filtering.
    updated_at float
    Unix epoch when the resource was last updated.
    config Property Map
    controlPlaneId String
    The UUID of your control plane. This variable is available in the Konnect manager. Requires replacement if changed.
    consumer Property Map
    If set, the plugin will activate only for requests where the specified has been authenticated. (Note that some plugins can not be restricted to consumers this way.). Leave unset for the plugin to activate regardless of the authenticated Consumer.
    createdAt Number
    Unix epoch when the resource was created.
    enabled Boolean
    Whether the plugin is applied. Default: true
    gatewayPluginConfluentConsumeId String
    A string representing a UUID (universally unique identifier).
    instanceName String
    A unique string representing a UTF-8 encoded name.
    ordering Property Map
    partials List<Property Map>
    A list of partials to be used by the plugin.
    protocols List<String>
    A list of the request protocols that will trigger this plugin. The default value, as well as the possible values allowed on this field, may change depending on the plugin type. For example, plugins that only work in stream mode will only support tcp and tls. Default: ["grpc","grpcs","http","https","ws","wss"]
    route Property Map
    If set, the plugin will only activate when receiving requests via the specified route. Leave unset for the plugin to activate regardless of the route being used.
    service Property Map
    If set, the plugin will only activate when receiving requests via one of the routes belonging to the specified Service. Leave unset for the plugin to activate regardless of the Service being matched.
    tags List<String>
    An optional set of strings associated with the Plugin for grouping and filtering.
    updatedAt Number
    Unix epoch when the resource was last updated.

    Outputs

    All input properties are implicitly available as output properties. Additionally, the GatewayPluginConfluentConsume resource produces the following output properties:

    Id string
    The provider-assigned unique ID for this managed resource.
    Id string
    The provider-assigned unique ID for this managed resource.
    id String
    The provider-assigned unique ID for this managed resource.
    id string
    The provider-assigned unique ID for this managed resource.
    id str
    The provider-assigned unique ID for this managed resource.
    id String
    The provider-assigned unique ID for this managed resource.

    Look up Existing GatewayPluginConfluentConsume Resource

    Get an existing GatewayPluginConfluentConsume resource’s state with the given name, ID, and optional extra properties used to qualify the lookup.

    public static get(name: string, id: Input<ID>, state?: GatewayPluginConfluentConsumeState, opts?: CustomResourceOptions): GatewayPluginConfluentConsume
    @staticmethod
    def get(resource_name: str,
            id: str,
            opts: Optional[ResourceOptions] = None,
            config: Optional[GatewayPluginConfluentConsumeConfigArgs] = None,
            consumer: Optional[GatewayPluginConfluentConsumeConsumerArgs] = None,
            control_plane_id: Optional[str] = None,
            created_at: Optional[float] = None,
            enabled: Optional[bool] = None,
            gateway_plugin_confluent_consume_id: Optional[str] = None,
            instance_name: Optional[str] = None,
            ordering: Optional[GatewayPluginConfluentConsumeOrderingArgs] = None,
            partials: Optional[Sequence[GatewayPluginConfluentConsumePartialArgs]] = None,
            protocols: Optional[Sequence[str]] = None,
            route: Optional[GatewayPluginConfluentConsumeRouteArgs] = None,
            service: Optional[GatewayPluginConfluentConsumeServiceArgs] = None,
            tags: Optional[Sequence[str]] = None,
            updated_at: Optional[float] = None) -> GatewayPluginConfluentConsume
    func GetGatewayPluginConfluentConsume(ctx *Context, name string, id IDInput, state *GatewayPluginConfluentConsumeState, opts ...ResourceOption) (*GatewayPluginConfluentConsume, error)
    public static GatewayPluginConfluentConsume Get(string name, Input<string> id, GatewayPluginConfluentConsumeState? state, CustomResourceOptions? opts = null)
    public static GatewayPluginConfluentConsume get(String name, Output<String> id, GatewayPluginConfluentConsumeState state, CustomResourceOptions options)
    resources:  _:    type: konnect:GatewayPluginConfluentConsume    get:      id: ${id}
    name
    The unique name of the resulting resource.
    id
    The unique provider ID of the resource to lookup.
    state
    Any extra arguments used during the lookup.
    opts
    A bag of options that control this resource's behavior.
    resource_name
    The unique name of the resulting resource.
    id
    The unique provider ID of the resource to lookup.
    name
    The unique name of the resulting resource.
    id
    The unique provider ID of the resource to lookup.
    state
    Any extra arguments used during the lookup.
    opts
    A bag of options that control this resource's behavior.
    name
    The unique name of the resulting resource.
    id
    The unique provider ID of the resource to lookup.
    state
    Any extra arguments used during the lookup.
    opts
    A bag of options that control this resource's behavior.
    name
    The unique name of the resulting resource.
    id
    The unique provider ID of the resource to lookup.
    state
    Any extra arguments used during the lookup.
    opts
    A bag of options that control this resource's behavior.
    The following state arguments are supported:
    Config GatewayPluginConfluentConsumeConfig
    Consumer GatewayPluginConfluentConsumeConsumer
    If set, the plugin will activate only for requests where the specified has been authenticated. (Note that some plugins can not be restricted to consumers this way.). Leave unset for the plugin to activate regardless of the authenticated Consumer.
    ControlPlaneId string
    The UUID of your control plane. This variable is available in the Konnect manager. Requires replacement if changed.
    CreatedAt double
    Unix epoch when the resource was created.
    Enabled bool
    Whether the plugin is applied. Default: true
    GatewayPluginConfluentConsumeId string
    A string representing a UUID (universally unique identifier).
    InstanceName string
    A unique string representing a UTF-8 encoded name.
    Ordering GatewayPluginConfluentConsumeOrdering
    Partials List<GatewayPluginConfluentConsumePartial>
    A list of partials to be used by the plugin.
    Protocols List<string>
    A list of the request protocols that will trigger this plugin. The default value, as well as the possible values allowed on this field, may change depending on the plugin type. For example, plugins that only work in stream mode will only support tcp and tls. Default: ["grpc","grpcs","http","https","ws","wss"]
    Route GatewayPluginConfluentConsumeRoute
    If set, the plugin will only activate when receiving requests via the specified route. Leave unset for the plugin to activate regardless of the route being used.
    Service GatewayPluginConfluentConsumeService
    If set, the plugin will only activate when receiving requests via one of the routes belonging to the specified Service. Leave unset for the plugin to activate regardless of the Service being matched.
    Tags List<string>
    An optional set of strings associated with the Plugin for grouping and filtering.
    UpdatedAt double
    Unix epoch when the resource was last updated.
    Config GatewayPluginConfluentConsumeConfigArgs
    Consumer GatewayPluginConfluentConsumeConsumerArgs
    If set, the plugin will activate only for requests where the specified has been authenticated. (Note that some plugins can not be restricted to consumers this way.). Leave unset for the plugin to activate regardless of the authenticated Consumer.
    ControlPlaneId string
    The UUID of your control plane. This variable is available in the Konnect manager. Requires replacement if changed.
    CreatedAt float64
    Unix epoch when the resource was created.
    Enabled bool
    Whether the plugin is applied. Default: true
    GatewayPluginConfluentConsumeId string
    A string representing a UUID (universally unique identifier).
    InstanceName string
    A unique string representing a UTF-8 encoded name.
    Ordering GatewayPluginConfluentConsumeOrderingArgs
    Partials []GatewayPluginConfluentConsumePartialArgs
    A list of partials to be used by the plugin.
    Protocols []string
    A list of the request protocols that will trigger this plugin. The default value, as well as the possible values allowed on this field, may change depending on the plugin type. For example, plugins that only work in stream mode will only support tcp and tls. Default: ["grpc","grpcs","http","https","ws","wss"]
    Route GatewayPluginConfluentConsumeRouteArgs
    If set, the plugin will only activate when receiving requests via the specified route. Leave unset for the plugin to activate regardless of the route being used.
    Service GatewayPluginConfluentConsumeServiceArgs
    If set, the plugin will only activate when receiving requests via one of the routes belonging to the specified Service. Leave unset for the plugin to activate regardless of the Service being matched.
    Tags []string
    An optional set of strings associated with the Plugin for grouping and filtering.
    UpdatedAt float64
    Unix epoch when the resource was last updated.
    config GatewayPluginConfluentConsumeConfig
    consumer GatewayPluginConfluentConsumeConsumer
    If set, the plugin will activate only for requests where the specified has been authenticated. (Note that some plugins can not be restricted to consumers this way.). Leave unset for the plugin to activate regardless of the authenticated Consumer.
    controlPlaneId String
    The UUID of your control plane. This variable is available in the Konnect manager. Requires replacement if changed.
    createdAt Double
    Unix epoch when the resource was created.
    enabled Boolean
    Whether the plugin is applied. Default: true
    gatewayPluginConfluentConsumeId String
    A string representing a UUID (universally unique identifier).
    instanceName String
    A unique string representing a UTF-8 encoded name.
    ordering GatewayPluginConfluentConsumeOrdering
    partials List<GatewayPluginConfluentConsumePartial>
    A list of partials to be used by the plugin.
    protocols List<String>
    A list of the request protocols that will trigger this plugin. The default value, as well as the possible values allowed on this field, may change depending on the plugin type. For example, plugins that only work in stream mode will only support tcp and tls. Default: ["grpc","grpcs","http","https","ws","wss"]
    route GatewayPluginConfluentConsumeRoute
    If set, the plugin will only activate when receiving requests via the specified route. Leave unset for the plugin to activate regardless of the route being used.
    service GatewayPluginConfluentConsumeService
    If set, the plugin will only activate when receiving requests via one of the routes belonging to the specified Service. Leave unset for the plugin to activate regardless of the Service being matched.
    tags List<String>
    An optional set of strings associated with the Plugin for grouping and filtering.
    updatedAt Double
    Unix epoch when the resource was last updated.
    config GatewayPluginConfluentConsumeConfig
    consumer GatewayPluginConfluentConsumeConsumer
    If set, the plugin will activate only for requests where the specified has been authenticated. (Note that some plugins can not be restricted to consumers this way.). Leave unset for the plugin to activate regardless of the authenticated Consumer.
    controlPlaneId string
    The UUID of your control plane. This variable is available in the Konnect manager. Requires replacement if changed.
    createdAt number
    Unix epoch when the resource was created.
    enabled boolean
    Whether the plugin is applied. Default: true
    gatewayPluginConfluentConsumeId string
    A string representing a UUID (universally unique identifier).
    instanceName string
    A unique string representing a UTF-8 encoded name.
    ordering GatewayPluginConfluentConsumeOrdering
    partials GatewayPluginConfluentConsumePartial[]
    A list of partials to be used by the plugin.
    protocols string[]
    A list of the request protocols that will trigger this plugin. The default value, as well as the possible values allowed on this field, may change depending on the plugin type. For example, plugins that only work in stream mode will only support tcp and tls. Default: ["grpc","grpcs","http","https","ws","wss"]
    route GatewayPluginConfluentConsumeRoute
    If set, the plugin will only activate when receiving requests via the specified route. Leave unset for the plugin to activate regardless of the route being used.
    service GatewayPluginConfluentConsumeService
    If set, the plugin will only activate when receiving requests via one of the routes belonging to the specified Service. Leave unset for the plugin to activate regardless of the Service being matched.
    tags string[]
    An optional set of strings associated with the Plugin for grouping and filtering.
    updatedAt number
    Unix epoch when the resource was last updated.
    config GatewayPluginConfluentConsumeConfigArgs
    consumer GatewayPluginConfluentConsumeConsumerArgs
    If set, the plugin will activate only for requests where the specified has been authenticated. (Note that some plugins can not be restricted to consumers this way.). Leave unset for the plugin to activate regardless of the authenticated Consumer.
    control_plane_id str
    The UUID of your control plane. This variable is available in the Konnect manager. Requires replacement if changed.
    created_at float
    Unix epoch when the resource was created.
    enabled bool
    Whether the plugin is applied. Default: true
    gateway_plugin_confluent_consume_id str
    A string representing a UUID (universally unique identifier).
    instance_name str
    A unique string representing a UTF-8 encoded name.
    ordering GatewayPluginConfluentConsumeOrderingArgs
    partials Sequence[GatewayPluginConfluentConsumePartialArgs]
    A list of partials to be used by the plugin.
    protocols Sequence[str]
    A list of the request protocols that will trigger this plugin. The default value, as well as the possible values allowed on this field, may change depending on the plugin type. For example, plugins that only work in stream mode will only support tcp and tls. Default: ["grpc","grpcs","http","https","ws","wss"]
    route GatewayPluginConfluentConsumeRouteArgs
    If set, the plugin will only activate when receiving requests via the specified route. Leave unset for the plugin to activate regardless of the route being used.
    service GatewayPluginConfluentConsumeServiceArgs
    If set, the plugin will only activate when receiving requests via one of the routes belonging to the specified Service. Leave unset for the plugin to activate regardless of the Service being matched.
    tags Sequence[str]
    An optional set of strings associated with the Plugin for grouping and filtering.
    updated_at float
    Unix epoch when the resource was last updated.
    config Property Map
    consumer Property Map
    If set, the plugin will activate only for requests where the specified has been authenticated. (Note that some plugins can not be restricted to consumers this way.). Leave unset for the plugin to activate regardless of the authenticated Consumer.
    controlPlaneId String
    The UUID of your control plane. This variable is available in the Konnect manager. Requires replacement if changed.
    createdAt Number
    Unix epoch when the resource was created.
    enabled Boolean
    Whether the plugin is applied. Default: true
    gatewayPluginConfluentConsumeId String
    A string representing a UUID (universally unique identifier).
    instanceName String
    A unique string representing a UTF-8 encoded name.
    ordering Property Map
    partials List<Property Map>
    A list of partials to be used by the plugin.
    protocols List<String>
    A list of the request protocols that will trigger this plugin. The default value, as well as the possible values allowed on this field, may change depending on the plugin type. For example, plugins that only work in stream mode will only support tcp and tls. Default: ["grpc","grpcs","http","https","ws","wss"]
    route Property Map
    If set, the plugin will only activate when receiving requests via the specified route. Leave unset for the plugin to activate regardless of the route being used.
    service Property Map
    If set, the plugin will only activate when receiving requests via one of the routes belonging to the specified Service. Leave unset for the plugin to activate regardless of the Service being matched.
    tags List<String>
    An optional set of strings associated with the Plugin for grouping and filtering.
    updatedAt Number
    Unix epoch when the resource was last updated.

    Supporting Types

    GatewayPluginConfluentConsumeConfig, GatewayPluginConfluentConsumeConfigArgs

    ClusterApiKey string
    Username/Apikey for SASL authentication.
    ClusterApiSecret string
    Password/ApiSecret for SASL authentication.
    Topics List<GatewayPluginConfluentConsumeConfigTopic>
    The Kafka topics and their configuration you want to consume from.
    AutoOffsetReset string
    The offset to start from when there is no initial offset in the consumer group. Default: "latest"; must be one of ["earliest", "latest"]
    BootstrapServers List<GatewayPluginConfluentConsumeConfigBootstrapServer>
    Set of bootstrap brokers in a {host: host, port: port} list format.
    ClusterName string
    An identifier for the Kafka cluster. By default, this field generates a random string. You can also set your own custom cluster identifier. If more than one Kafka plugin is configured without a cluster_name (that is, if the default autogenerated value is removed), these plugins will use the same producer, and by extension, the same cluster. Logs will be sent to the leader of the cluster.
    CommitStrategy string
    The strategy to use for committing offsets. Default: "auto"; must be one of ["auto", "off"]
    ConfluentCloudApiKey string
    Apikey for authentication with Confluent Cloud. This allows for management tasks such as creating topics, ACLs, etc.
    ConfluentCloudApiSecret string
    The corresponding secret for the Confluent Cloud API key.
    DlqTopic string
    The topic to use for the Dead Letter Queue.
    EnableDlq bool
    Enables Dead Letter Queue. When enabled, if the message doesn't conform to the schema (from Schema Registry) or there's an error in the message_by_lua_functions, it will be forwarded to dlq_topic that can be processed later.
    Keepalive double
    Keepalive timeout in milliseconds. Default: 60000
    KeepaliveEnabled bool
    Default: false
    MessageByLuaFunctions List<string>
    The Lua functions that manipulates the message being sent to the client.
    MessageDeserializer string
    The deserializer to use for the consumed messages. Default: "noop"; must be one of ["json", "noop"]
    Mode string
    The mode of operation for the plugin. Default: "http-get"; must be one of ["http-get", "server-sent-events", "websocket"]
    SchemaRegistry GatewayPluginConfluentConsumeConfigSchemaRegistry
    The plugin-global schema registry configuration.
    Timeout double
    Socket timeout in milliseconds. Default: 10000
    ClusterApiKey string
    Username/Apikey for SASL authentication.
    ClusterApiSecret string
    Password/ApiSecret for SASL authentication.
    Topics []GatewayPluginConfluentConsumeConfigTopic
    The Kafka topics and their configuration you want to consume from.
    AutoOffsetReset string
    The offset to start from when there is no initial offset in the consumer group. Default: "latest"; must be one of ["earliest", "latest"]
    BootstrapServers []GatewayPluginConfluentConsumeConfigBootstrapServer
    Set of bootstrap brokers in a {host: host, port: port} list format.
    ClusterName string
    An identifier for the Kafka cluster. By default, this field generates a random string. You can also set your own custom cluster identifier. If more than one Kafka plugin is configured without a cluster_name (that is, if the default autogenerated value is removed), these plugins will use the same producer, and by extension, the same cluster. Logs will be sent to the leader of the cluster.
    CommitStrategy string
    The strategy to use for committing offsets. Default: "auto"; must be one of ["auto", "off"]
    ConfluentCloudApiKey string
    Apikey for authentication with Confluent Cloud. This allows for management tasks such as creating topics, ACLs, etc.
    ConfluentCloudApiSecret string
    The corresponding secret for the Confluent Cloud API key.
    DlqTopic string
    The topic to use for the Dead Letter Queue.
    EnableDlq bool
    Enables Dead Letter Queue. When enabled, if the message doesn't conform to the schema (from Schema Registry) or there's an error in the message_by_lua_functions, it will be forwarded to dlq_topic that can be processed later.
    Keepalive float64
    Keepalive timeout in milliseconds. Default: 60000
    KeepaliveEnabled bool
    Default: false
    MessageByLuaFunctions []string
    The Lua functions that manipulates the message being sent to the client.
    MessageDeserializer string
    The deserializer to use for the consumed messages. Default: "noop"; must be one of ["json", "noop"]
    Mode string
    The mode of operation for the plugin. Default: "http-get"; must be one of ["http-get", "server-sent-events", "websocket"]
    SchemaRegistry GatewayPluginConfluentConsumeConfigSchemaRegistry
    The plugin-global schema registry configuration.
    Timeout float64
    Socket timeout in milliseconds. Default: 10000
    clusterApiKey String
    Username/Apikey for SASL authentication.
    clusterApiSecret String
    Password/ApiSecret for SASL authentication.
    topics List<GatewayPluginConfluentConsumeConfigTopic>
    The Kafka topics and their configuration you want to consume from.
    autoOffsetReset String
    The offset to start from when there is no initial offset in the consumer group. Default: "latest"; must be one of ["earliest", "latest"]
    bootstrapServers List<GatewayPluginConfluentConsumeConfigBootstrapServer>
    Set of bootstrap brokers in a {host: host, port: port} list format.
    clusterName String
    An identifier for the Kafka cluster. By default, this field generates a random string. You can also set your own custom cluster identifier. If more than one Kafka plugin is configured without a cluster_name (that is, if the default autogenerated value is removed), these plugins will use the same producer, and by extension, the same cluster. Logs will be sent to the leader of the cluster.
    commitStrategy String
    The strategy to use for committing offsets. Default: "auto"; must be one of ["auto", "off"]
    confluentCloudApiKey String
    Apikey for authentication with Confluent Cloud. This allows for management tasks such as creating topics, ACLs, etc.
    confluentCloudApiSecret String
    The corresponding secret for the Confluent Cloud API key.
    dlqTopic String
    The topic to use for the Dead Letter Queue.
    enableDlq Boolean
    Enables Dead Letter Queue. When enabled, if the message doesn't conform to the schema (from Schema Registry) or there's an error in the message_by_lua_functions, it will be forwarded to dlq_topic that can be processed later.
    keepalive Double
    Keepalive timeout in milliseconds. Default: 60000
    keepaliveEnabled Boolean
    Default: false
    messageByLuaFunctions List<String>
    The Lua functions that manipulates the message being sent to the client.
    messageDeserializer String
    The deserializer to use for the consumed messages. Default: "noop"; must be one of ["json", "noop"]
    mode String
    The mode of operation for the plugin. Default: "http-get"; must be one of ["http-get", "server-sent-events", "websocket"]
    schemaRegistry GatewayPluginConfluentConsumeConfigSchemaRegistry
    The plugin-global schema registry configuration.
    timeout Double
    Socket timeout in milliseconds. Default: 10000
    clusterApiKey string
    Username/Apikey for SASL authentication.
    clusterApiSecret string
    Password/ApiSecret for SASL authentication.
    topics GatewayPluginConfluentConsumeConfigTopic[]
    The Kafka topics and their configuration you want to consume from.
    autoOffsetReset string
    The offset to start from when there is no initial offset in the consumer group. Default: "latest"; must be one of ["earliest", "latest"]
    bootstrapServers GatewayPluginConfluentConsumeConfigBootstrapServer[]
    Set of bootstrap brokers in a {host: host, port: port} list format.
    clusterName string
    An identifier for the Kafka cluster. By default, this field generates a random string. You can also set your own custom cluster identifier. If more than one Kafka plugin is configured without a cluster_name (that is, if the default autogenerated value is removed), these plugins will use the same producer, and by extension, the same cluster. Logs will be sent to the leader of the cluster.
    commitStrategy string
    The strategy to use for committing offsets. Default: "auto"; must be one of ["auto", "off"]
    confluentCloudApiKey string
    Apikey for authentication with Confluent Cloud. This allows for management tasks such as creating topics, ACLs, etc.
    confluentCloudApiSecret string
    The corresponding secret for the Confluent Cloud API key.
    dlqTopic string
    The topic to use for the Dead Letter Queue.
    enableDlq boolean
    Enables Dead Letter Queue. When enabled, if the message doesn't conform to the schema (from Schema Registry) or there's an error in the message_by_lua_functions, it will be forwarded to dlq_topic that can be processed later.
    keepalive number
    Keepalive timeout in milliseconds. Default: 60000
    keepaliveEnabled boolean
    Default: false
    messageByLuaFunctions string[]
    The Lua functions that manipulates the message being sent to the client.
    messageDeserializer string
    The deserializer to use for the consumed messages. Default: "noop"; must be one of ["json", "noop"]
    mode string
    The mode of operation for the plugin. Default: "http-get"; must be one of ["http-get", "server-sent-events", "websocket"]
    schemaRegistry GatewayPluginConfluentConsumeConfigSchemaRegistry
    The plugin-global schema registry configuration.
    timeout number
    Socket timeout in milliseconds. Default: 10000
    cluster_api_key str
    Username/Apikey for SASL authentication.
    cluster_api_secret str
    Password/ApiSecret for SASL authentication.
    topics Sequence[GatewayPluginConfluentConsumeConfigTopic]
    The Kafka topics and their configuration you want to consume from.
    auto_offset_reset str
    The offset to start from when there is no initial offset in the consumer group. Default: "latest"; must be one of ["earliest", "latest"]
    bootstrap_servers Sequence[GatewayPluginConfluentConsumeConfigBootstrapServer]
    Set of bootstrap brokers in a {host: host, port: port} list format.
    cluster_name str
    An identifier for the Kafka cluster. By default, this field generates a random string. You can also set your own custom cluster identifier. If more than one Kafka plugin is configured without a cluster_name (that is, if the default autogenerated value is removed), these plugins will use the same producer, and by extension, the same cluster. Logs will be sent to the leader of the cluster.
    commit_strategy str
    The strategy to use for committing offsets. Default: "auto"; must be one of ["auto", "off"]
    confluent_cloud_api_key str
    Apikey for authentication with Confluent Cloud. This allows for management tasks such as creating topics, ACLs, etc.
    confluent_cloud_api_secret str
    The corresponding secret for the Confluent Cloud API key.
    dlq_topic str
    The topic to use for the Dead Letter Queue.
    enable_dlq bool
    Enables Dead Letter Queue. When enabled, if the message doesn't conform to the schema (from Schema Registry) or there's an error in the message_by_lua_functions, it will be forwarded to dlq_topic that can be processed later.
    keepalive float
    Keepalive timeout in milliseconds. Default: 60000
    keepalive_enabled bool
    Default: false
    message_by_lua_functions Sequence[str]
    The Lua functions that manipulates the message being sent to the client.
    message_deserializer str
    The deserializer to use for the consumed messages. Default: "noop"; must be one of ["json", "noop"]
    mode str
    The mode of operation for the plugin. Default: "http-get"; must be one of ["http-get", "server-sent-events", "websocket"]
    schema_registry GatewayPluginConfluentConsumeConfigSchemaRegistry
    The plugin-global schema registry configuration.
    timeout float
    Socket timeout in milliseconds. Default: 10000
    clusterApiKey String
    Username/Apikey for SASL authentication.
    clusterApiSecret String
    Password/ApiSecret for SASL authentication.
    topics List<Property Map>
    The Kafka topics and their configuration you want to consume from.
    autoOffsetReset String
    The offset to start from when there is no initial offset in the consumer group. Default: "latest"; must be one of ["earliest", "latest"]
    bootstrapServers List<Property Map>
    Set of bootstrap brokers in a {host: host, port: port} list format.
    clusterName String
    An identifier for the Kafka cluster. By default, this field generates a random string. You can also set your own custom cluster identifier. If more than one Kafka plugin is configured without a cluster_name (that is, if the default autogenerated value is removed), these plugins will use the same producer, and by extension, the same cluster. Logs will be sent to the leader of the cluster.
    commitStrategy String
    The strategy to use for committing offsets. Default: "auto"; must be one of ["auto", "off"]
    confluentCloudApiKey String
    Apikey for authentication with Confluent Cloud. This allows for management tasks such as creating topics, ACLs, etc.
    confluentCloudApiSecret String
    The corresponding secret for the Confluent Cloud API key.
    dlqTopic String
    The topic to use for the Dead Letter Queue.
    enableDlq Boolean
    Enables Dead Letter Queue. When enabled, if the message doesn't conform to the schema (from Schema Registry) or there's an error in the message_by_lua_functions, it will be forwarded to dlq_topic that can be processed later.
    keepalive Number
    Keepalive timeout in milliseconds. Default: 60000
    keepaliveEnabled Boolean
    Default: false
    messageByLuaFunctions List<String>
    The Lua functions that manipulates the message being sent to the client.
    messageDeserializer String
    The deserializer to use for the consumed messages. Default: "noop"; must be one of ["json", "noop"]
    mode String
    The mode of operation for the plugin. Default: "http-get"; must be one of ["http-get", "server-sent-events", "websocket"]
    schemaRegistry Property Map
    The plugin-global schema registry configuration.
    timeout Number
    Socket timeout in milliseconds. Default: 10000

    GatewayPluginConfluentConsumeConfigBootstrapServer, GatewayPluginConfluentConsumeConfigBootstrapServerArgs

    Host string
    A string representing a host name, such as example.com. Not Null
    Port double
    An integer representing a port number between 0 and 65535, inclusive. Not Null
    Host string
    A string representing a host name, such as example.com. Not Null
    Port float64
    An integer representing a port number between 0 and 65535, inclusive. Not Null
    host String
    A string representing a host name, such as example.com. Not Null
    port Double
    An integer representing a port number between 0 and 65535, inclusive. Not Null
    host string
    A string representing a host name, such as example.com. Not Null
    port number
    An integer representing a port number between 0 and 65535, inclusive. Not Null
    host str
    A string representing a host name, such as example.com. Not Null
    port float
    An integer representing a port number between 0 and 65535, inclusive. Not Null
    host String
    A string representing a host name, such as example.com. Not Null
    port Number
    An integer representing a port number between 0 and 65535, inclusive. Not Null

    GatewayPluginConfluentConsumeConfigSchemaRegistry, GatewayPluginConfluentConsumeConfigSchemaRegistryArgs

    GatewayPluginConfluentConsumeConfigSchemaRegistryConfluent, GatewayPluginConfluentConsumeConfigSchemaRegistryConfluentArgs

    Authentication GatewayPluginConfluentConsumeConfigSchemaRegistryConfluentAuthentication
    SslVerify bool
    Set to false to disable SSL certificate verification when connecting to the schema registry. Default: true
    Ttl double
    The TTL in seconds for the schema registry cache.
    Url string
    The URL of the schema registry.
    Authentication GatewayPluginConfluentConsumeConfigSchemaRegistryConfluentAuthentication
    SslVerify bool
    Set to false to disable SSL certificate verification when connecting to the schema registry. Default: true
    Ttl float64
    The TTL in seconds for the schema registry cache.
    Url string
    The URL of the schema registry.
    authentication GatewayPluginConfluentConsumeConfigSchemaRegistryConfluentAuthentication
    sslVerify Boolean
    Set to false to disable SSL certificate verification when connecting to the schema registry. Default: true
    ttl Double
    The TTL in seconds for the schema registry cache.
    url String
    The URL of the schema registry.
    authentication GatewayPluginConfluentConsumeConfigSchemaRegistryConfluentAuthentication
    sslVerify boolean
    Set to false to disable SSL certificate verification when connecting to the schema registry. Default: true
    ttl number
    The TTL in seconds for the schema registry cache.
    url string
    The URL of the schema registry.
    authentication GatewayPluginConfluentConsumeConfigSchemaRegistryConfluentAuthentication
    ssl_verify bool
    Set to false to disable SSL certificate verification when connecting to the schema registry. Default: true
    ttl float
    The TTL in seconds for the schema registry cache.
    url str
    The URL of the schema registry.
    authentication Property Map
    sslVerify Boolean
    Set to false to disable SSL certificate verification when connecting to the schema registry. Default: true
    ttl Number
    The TTL in seconds for the schema registry cache.
    url String
    The URL of the schema registry.

    GatewayPluginConfluentConsumeConfigSchemaRegistryConfluentAuthentication, GatewayPluginConfluentConsumeConfigSchemaRegistryConfluentAuthenticationArgs

    basic Property Map
    mode String
    Authentication mode to use with the schema registry. Default: "none"; must be one of ["basic", "none", "oauth2"]
    oauth2 Property Map
    oauth2Client Property Map

    GatewayPluginConfluentConsumeConfigSchemaRegistryConfluentAuthenticationBasic, GatewayPluginConfluentConsumeConfigSchemaRegistryConfluentAuthenticationBasicArgs

    Password string
    Username string
    Password string
    Username string
    password String
    username String
    password string
    username string
    password String
    username String

    GatewayPluginConfluentConsumeConfigSchemaRegistryConfluentAuthenticationOauth2, GatewayPluginConfluentConsumeConfigSchemaRegistryConfluentAuthenticationOauth2Args

    TokenEndpoint string
    The token endpoint URI.
    Audiences List<string>
    List of audiences passed to the IdP when obtaining a new token. Default: []
    ClientId string
    The client ID for the application registration in the IdP.
    ClientSecret string
    The client secret for the application registration in the IdP.
    GrantType string
    The OAuth grant type to be used. Default: "clientcredentials"; must be one of ["clientcredentials", "password"]
    Password string
    The password to use if config.oauth.grant_type is set to password.
    Scopes List<string>
    List of scopes to request from the IdP when obtaining a new token. Default: ["openid"]
    TokenHeaders Dictionary<string, string>
    Extra headers to be passed in the token endpoint request.
    TokenPostArgs Dictionary<string, string>
    Extra post arguments to be passed in the token endpoint request.
    Username string
    The username to use if config.oauth.grant_type is set to password.
    TokenEndpoint string
    The token endpoint URI.
    Audiences []string
    List of audiences passed to the IdP when obtaining a new token. Default: []
    ClientId string
    The client ID for the application registration in the IdP.
    ClientSecret string
    The client secret for the application registration in the IdP.
    GrantType string
    The OAuth grant type to be used. Default: "clientcredentials"; must be one of ["clientcredentials", "password"]
    Password string
    The password to use if config.oauth.grant_type is set to password.
    Scopes []string
    List of scopes to request from the IdP when obtaining a new token. Default: ["openid"]
    TokenHeaders map[string]string
    Extra headers to be passed in the token endpoint request.
    TokenPostArgs map[string]string
    Extra post arguments to be passed in the token endpoint request.
    Username string
    The username to use if config.oauth.grant_type is set to password.
    tokenEndpoint String
    The token endpoint URI.
    audiences List<String>
    List of audiences passed to the IdP when obtaining a new token. Default: []
    clientId String
    The client ID for the application registration in the IdP.
    clientSecret String
    The client secret for the application registration in the IdP.
    grantType String
    The OAuth grant type to be used. Default: "clientcredentials"; must be one of ["clientcredentials", "password"]
    password String
    The password to use if config.oauth.grant_type is set to password.
    scopes List<String>
    List of scopes to request from the IdP when obtaining a new token. Default: ["openid"]
    tokenHeaders Map<String,String>
    Extra headers to be passed in the token endpoint request.
    tokenPostArgs Map<String,String>
    Extra post arguments to be passed in the token endpoint request.
    username String
    The username to use if config.oauth.grant_type is set to password.
    tokenEndpoint string
    The token endpoint URI.
    audiences string[]
    List of audiences passed to the IdP when obtaining a new token. Default: []
    clientId string
    The client ID for the application registration in the IdP.
    clientSecret string
    The client secret for the application registration in the IdP.
    grantType string
    The OAuth grant type to be used. Default: "clientcredentials"; must be one of ["clientcredentials", "password"]
    password string
    The password to use if config.oauth.grant_type is set to password.
    scopes string[]
    List of scopes to request from the IdP when obtaining a new token. Default: ["openid"]
    tokenHeaders {[key: string]: string}
    Extra headers to be passed in the token endpoint request.
    tokenPostArgs {[key: string]: string}
    Extra post arguments to be passed in the token endpoint request.
    username string
    The username to use if config.oauth.grant_type is set to password.
    token_endpoint str
    The token endpoint URI.
    audiences Sequence[str]
    List of audiences passed to the IdP when obtaining a new token. Default: []
    client_id str
    The client ID for the application registration in the IdP.
    client_secret str
    The client secret for the application registration in the IdP.
    grant_type str
    The OAuth grant type to be used. Default: "clientcredentials"; must be one of ["clientcredentials", "password"]
    password str
    The password to use if config.oauth.grant_type is set to password.
    scopes Sequence[str]
    List of scopes to request from the IdP when obtaining a new token. Default: ["openid"]
    token_headers Mapping[str, str]
    Extra headers to be passed in the token endpoint request.
    token_post_args Mapping[str, str]
    Extra post arguments to be passed in the token endpoint request.
    username str
    The username to use if config.oauth.grant_type is set to password.
    tokenEndpoint String
    The token endpoint URI.
    audiences List<String>
    List of audiences passed to the IdP when obtaining a new token. Default: []
    clientId String
    The client ID for the application registration in the IdP.
    clientSecret String
    The client secret for the application registration in the IdP.
    grantType String
    The OAuth grant type to be used. Default: "clientcredentials"; must be one of ["clientcredentials", "password"]
    password String
    The password to use if config.oauth.grant_type is set to password.
    scopes List<String>
    List of scopes to request from the IdP when obtaining a new token. Default: ["openid"]
    tokenHeaders Map<String>
    Extra headers to be passed in the token endpoint request.
    tokenPostArgs Map<String>
    Extra post arguments to be passed in the token endpoint request.
    username String
    The username to use if config.oauth.grant_type is set to password.

    GatewayPluginConfluentConsumeConfigSchemaRegistryConfluentAuthenticationOauth2Client, GatewayPluginConfluentConsumeConfigSchemaRegistryConfluentAuthenticationOauth2ClientArgs

    AuthMethod string
    The authentication method used in client requests to the IdP. Supported values are: client_secret_basic to send client_id and client_secret in the Authorization: Basic header, client_secret_post to send client_id and client_secret as part of the request body, or client_secret_jwt to send a JWT signed with the client_secret using the client assertion as part of the body. Default: "clientsecretpost"; must be one of ["clientsecretbasic", "clientsecretjwt", "clientsecretpost", "none"]
    ClientSecretJwtAlg string
    The algorithm to use with JWT when using client_secret_jwt authentication. Default: "HS512"; must be one of ["HS256", "HS512"]
    HttpProxy string
    The proxy to use when making HTTP requests to the IdP.
    HttpProxyAuthorization string
    The Proxy-Authorization header value to be used with http_proxy.
    HttpVersion double
    The HTTP version used for requests made by this plugin. Supported values: 1.1 for HTTP 1.1 and 1.0 for HTTP 1.0.
    HttpsProxy string
    The proxy to use when making HTTPS requests to the IdP.
    HttpsProxyAuthorization string
    The Proxy-Authorization header value to be used with https_proxy.
    KeepAlive bool
    Whether to use keepalive connections to the IdP. Default: true
    NoProxy string
    A comma-separated list of hosts that should not be proxied.
    SslVerify bool
    Whether to verify the certificate presented by the IdP when using HTTPS. Default: false
    Timeout double
    Network I/O timeout for requests to the IdP in milliseconds. Default: 10000
    AuthMethod string
    The authentication method used in client requests to the IdP. Supported values are: client_secret_basic to send client_id and client_secret in the Authorization: Basic header, client_secret_post to send client_id and client_secret as part of the request body, or client_secret_jwt to send a JWT signed with the client_secret using the client assertion as part of the body. Default: "clientsecretpost"; must be one of ["clientsecretbasic", "clientsecretjwt", "clientsecretpost", "none"]
    ClientSecretJwtAlg string
    The algorithm to use with JWT when using client_secret_jwt authentication. Default: "HS512"; must be one of ["HS256", "HS512"]
    HttpProxy string
    The proxy to use when making HTTP requests to the IdP.
    HttpProxyAuthorization string
    The Proxy-Authorization header value to be used with http_proxy.
    HttpVersion float64
    The HTTP version used for requests made by this plugin. Supported values: 1.1 for HTTP 1.1 and 1.0 for HTTP 1.0.
    HttpsProxy string
    The proxy to use when making HTTPS requests to the IdP.
    HttpsProxyAuthorization string
    The Proxy-Authorization header value to be used with https_proxy.
    KeepAlive bool
    Whether to use keepalive connections to the IdP. Default: true
    NoProxy string
    A comma-separated list of hosts that should not be proxied.
    SslVerify bool
    Whether to verify the certificate presented by the IdP when using HTTPS. Default: false
    Timeout float64
    Network I/O timeout for requests to the IdP in milliseconds. Default: 10000
    authMethod String
    The authentication method used in client requests to the IdP. Supported values are: client_secret_basic to send client_id and client_secret in the Authorization: Basic header, client_secret_post to send client_id and client_secret as part of the request body, or client_secret_jwt to send a JWT signed with the client_secret using the client assertion as part of the body. Default: "clientsecretpost"; must be one of ["clientsecretbasic", "clientsecretjwt", "clientsecretpost", "none"]
    clientSecretJwtAlg String
    The algorithm to use with JWT when using client_secret_jwt authentication. Default: "HS512"; must be one of ["HS256", "HS512"]
    httpProxy String
    The proxy to use when making HTTP requests to the IdP.
    httpProxyAuthorization String
    The Proxy-Authorization header value to be used with http_proxy.
    httpVersion Double
    The HTTP version used for requests made by this plugin. Supported values: 1.1 for HTTP 1.1 and 1.0 for HTTP 1.0.
    httpsProxy String
    The proxy to use when making HTTPS requests to the IdP.
    httpsProxyAuthorization String
    The Proxy-Authorization header value to be used with https_proxy.
    keepAlive Boolean
    Whether to use keepalive connections to the IdP. Default: true
    noProxy String
    A comma-separated list of hosts that should not be proxied.
    sslVerify Boolean
    Whether to verify the certificate presented by the IdP when using HTTPS. Default: false
    timeout Double
    Network I/O timeout for requests to the IdP in milliseconds. Default: 10000
    authMethod string
    The authentication method used in client requests to the IdP. Supported values are: client_secret_basic to send client_id and client_secret in the Authorization: Basic header, client_secret_post to send client_id and client_secret as part of the request body, or client_secret_jwt to send a JWT signed with the client_secret using the client assertion as part of the body. Default: "clientsecretpost"; must be one of ["clientsecretbasic", "clientsecretjwt", "clientsecretpost", "none"]
    clientSecretJwtAlg string
    The algorithm to use with JWT when using client_secret_jwt authentication. Default: "HS512"; must be one of ["HS256", "HS512"]
    httpProxy string
    The proxy to use when making HTTP requests to the IdP.
    httpProxyAuthorization string
    The Proxy-Authorization header value to be used with http_proxy.
    httpVersion number
    The HTTP version used for requests made by this plugin. Supported values: 1.1 for HTTP 1.1 and 1.0 for HTTP 1.0.
    httpsProxy string
    The proxy to use when making HTTPS requests to the IdP.
    httpsProxyAuthorization string
    The Proxy-Authorization header value to be used with https_proxy.
    keepAlive boolean
    Whether to use keepalive connections to the IdP. Default: true
    noProxy string
    A comma-separated list of hosts that should not be proxied.
    sslVerify boolean
    Whether to verify the certificate presented by the IdP when using HTTPS. Default: false
    timeout number
    Network I/O timeout for requests to the IdP in milliseconds. Default: 10000
    auth_method str
    The authentication method used in client requests to the IdP. Supported values are: client_secret_basic to send client_id and client_secret in the Authorization: Basic header, client_secret_post to send client_id and client_secret as part of the request body, or client_secret_jwt to send a JWT signed with the client_secret using the client assertion as part of the body. Default: "clientsecretpost"; must be one of ["clientsecretbasic", "clientsecretjwt", "clientsecretpost", "none"]
    client_secret_jwt_alg str
    The algorithm to use with JWT when using client_secret_jwt authentication. Default: "HS512"; must be one of ["HS256", "HS512"]
    http_proxy str
    The proxy to use when making HTTP requests to the IdP.
    http_proxy_authorization str
    The Proxy-Authorization header value to be used with http_proxy.
    http_version float
    The HTTP version used for requests made by this plugin. Supported values: 1.1 for HTTP 1.1 and 1.0 for HTTP 1.0.
    https_proxy str
    The proxy to use when making HTTPS requests to the IdP.
    https_proxy_authorization str
    The Proxy-Authorization header value to be used with https_proxy.
    keep_alive bool
    Whether to use keepalive connections to the IdP. Default: true
    no_proxy str
    A comma-separated list of hosts that should not be proxied.
    ssl_verify bool
    Whether to verify the certificate presented by the IdP when using HTTPS. Default: false
    timeout float
    Network I/O timeout for requests to the IdP in milliseconds. Default: 10000
    authMethod String
    The authentication method used in client requests to the IdP. Supported values are: client_secret_basic to send client_id and client_secret in the Authorization: Basic header, client_secret_post to send client_id and client_secret as part of the request body, or client_secret_jwt to send a JWT signed with the client_secret using the client assertion as part of the body. Default: "clientsecretpost"; must be one of ["clientsecretbasic", "clientsecretjwt", "clientsecretpost", "none"]
    clientSecretJwtAlg String
    The algorithm to use with JWT when using client_secret_jwt authentication. Default: "HS512"; must be one of ["HS256", "HS512"]
    httpProxy String
    The proxy to use when making HTTP requests to the IdP.
    httpProxyAuthorization String
    The Proxy-Authorization header value to be used with http_proxy.
    httpVersion Number
    The HTTP version used for requests made by this plugin. Supported values: 1.1 for HTTP 1.1 and 1.0 for HTTP 1.0.
    httpsProxy String
    The proxy to use when making HTTPS requests to the IdP.
    httpsProxyAuthorization String
    The Proxy-Authorization header value to be used with https_proxy.
    keepAlive Boolean
    Whether to use keepalive connections to the IdP. Default: true
    noProxy String
    A comma-separated list of hosts that should not be proxied.
    sslVerify Boolean
    Whether to verify the certificate presented by the IdP when using HTTPS. Default: false
    timeout Number
    Network I/O timeout for requests to the IdP in milliseconds. Default: 10000

    GatewayPluginConfluentConsumeConfigTopic, GatewayPluginConfluentConsumeConfigTopicArgs

    Name string
    Not Null
    SchemaRegistry GatewayPluginConfluentConsumeConfigTopicSchemaRegistry
    The plugin-global schema registry configuration.
    Name string
    Not Null
    SchemaRegistry GatewayPluginConfluentConsumeConfigTopicSchemaRegistry
    The plugin-global schema registry configuration.
    name String
    Not Null
    schemaRegistry GatewayPluginConfluentConsumeConfigTopicSchemaRegistry
    The plugin-global schema registry configuration.
    name string
    Not Null
    schemaRegistry GatewayPluginConfluentConsumeConfigTopicSchemaRegistry
    The plugin-global schema registry configuration.
    name str
    Not Null
    schema_registry GatewayPluginConfluentConsumeConfigTopicSchemaRegistry
    The plugin-global schema registry configuration.
    name String
    Not Null
    schemaRegistry Property Map
    The plugin-global schema registry configuration.

    GatewayPluginConfluentConsumeConfigTopicSchemaRegistry, GatewayPluginConfluentConsumeConfigTopicSchemaRegistryArgs

    GatewayPluginConfluentConsumeConfigTopicSchemaRegistryConfluent, GatewayPluginConfluentConsumeConfigTopicSchemaRegistryConfluentArgs

    Authentication GatewayPluginConfluentConsumeConfigTopicSchemaRegistryConfluentAuthentication
    SslVerify bool
    Set to false to disable SSL certificate verification when connecting to the schema registry. Default: true
    Ttl double
    The TTL in seconds for the schema registry cache.
    Url string
    The URL of the schema registry.
    Authentication GatewayPluginConfluentConsumeConfigTopicSchemaRegistryConfluentAuthentication
    SslVerify bool
    Set to false to disable SSL certificate verification when connecting to the schema registry. Default: true
    Ttl float64
    The TTL in seconds for the schema registry cache.
    Url string
    The URL of the schema registry.
    authentication GatewayPluginConfluentConsumeConfigTopicSchemaRegistryConfluentAuthentication
    sslVerify Boolean
    Set to false to disable SSL certificate verification when connecting to the schema registry. Default: true
    ttl Double
    The TTL in seconds for the schema registry cache.
    url String
    The URL of the schema registry.
    authentication GatewayPluginConfluentConsumeConfigTopicSchemaRegistryConfluentAuthentication
    sslVerify boolean
    Set to false to disable SSL certificate verification when connecting to the schema registry. Default: true
    ttl number
    The TTL in seconds for the schema registry cache.
    url string
    The URL of the schema registry.
    authentication GatewayPluginConfluentConsumeConfigTopicSchemaRegistryConfluentAuthentication
    ssl_verify bool
    Set to false to disable SSL certificate verification when connecting to the schema registry. Default: true
    ttl float
    The TTL in seconds for the schema registry cache.
    url str
    The URL of the schema registry.
    authentication Property Map
    sslVerify Boolean
    Set to false to disable SSL certificate verification when connecting to the schema registry. Default: true
    ttl Number
    The TTL in seconds for the schema registry cache.
    url String
    The URL of the schema registry.

    GatewayPluginConfluentConsumeConfigTopicSchemaRegistryConfluentAuthentication, GatewayPluginConfluentConsumeConfigTopicSchemaRegistryConfluentAuthenticationArgs

    basic Property Map
    mode String
    Authentication mode to use with the schema registry. Default: "none"; must be one of ["basic", "none", "oauth2"]
    oauth2 Property Map
    oauth2Client Property Map

    GatewayPluginConfluentConsumeConfigTopicSchemaRegistryConfluentAuthenticationBasic, GatewayPluginConfluentConsumeConfigTopicSchemaRegistryConfluentAuthenticationBasicArgs

    Password string
    Not Null
    Username string
    Not Null
    Password string
    Not Null
    Username string
    Not Null
    password String
    Not Null
    username String
    Not Null
    password string
    Not Null
    username string
    Not Null
    password str
    Not Null
    username str
    Not Null
    password String
    Not Null
    username String
    Not Null

    GatewayPluginConfluentConsumeConfigTopicSchemaRegistryConfluentAuthenticationOauth2, GatewayPluginConfluentConsumeConfigTopicSchemaRegistryConfluentAuthenticationOauth2Args

    Audiences List<string>
    List of audiences passed to the IdP when obtaining a new token. Default: []
    ClientId string
    The client ID for the application registration in the IdP.
    ClientSecret string
    The client secret for the application registration in the IdP.
    GrantType string
    The OAuth grant type to be used. Default: "clientcredentials"; must be one of ["clientcredentials", "password"]
    Password string
    The password to use if config.oauth.grant_type is set to password.
    Scopes List<string>
    List of scopes to request from the IdP when obtaining a new token. Default: ["openid"]
    TokenEndpoint string
    The token endpoint URI. Not Null
    TokenHeaders Dictionary<string, string>
    Extra headers to be passed in the token endpoint request.
    TokenPostArgs Dictionary<string, string>
    Extra post arguments to be passed in the token endpoint request.
    Username string
    The username to use if config.oauth.grant_type is set to password.
    Audiences []string
    List of audiences passed to the IdP when obtaining a new token. Default: []
    ClientId string
    The client ID for the application registration in the IdP.
    ClientSecret string
    The client secret for the application registration in the IdP.
    GrantType string
    The OAuth grant type to be used. Default: "clientcredentials"; must be one of ["clientcredentials", "password"]
    Password string
    The password to use if config.oauth.grant_type is set to password.
    Scopes []string
    List of scopes to request from the IdP when obtaining a new token. Default: ["openid"]
    TokenEndpoint string
    The token endpoint URI. Not Null
    TokenHeaders map[string]string
    Extra headers to be passed in the token endpoint request.
    TokenPostArgs map[string]string
    Extra post arguments to be passed in the token endpoint request.
    Username string
    The username to use if config.oauth.grant_type is set to password.
    audiences List<String>
    List of audiences passed to the IdP when obtaining a new token. Default: []
    clientId String
    The client ID for the application registration in the IdP.
    clientSecret String
    The client secret for the application registration in the IdP.
    grantType String
    The OAuth grant type to be used. Default: "clientcredentials"; must be one of ["clientcredentials", "password"]
    password String
    The password to use if config.oauth.grant_type is set to password.
    scopes List<String>
    List of scopes to request from the IdP when obtaining a new token. Default: ["openid"]
    tokenEndpoint String
    The token endpoint URI. Not Null
    tokenHeaders Map<String,String>
    Extra headers to be passed in the token endpoint request.
    tokenPostArgs Map<String,String>
    Extra post arguments to be passed in the token endpoint request.
    username String
    The username to use if config.oauth.grant_type is set to password.
    audiences string[]
    List of audiences passed to the IdP when obtaining a new token. Default: []
    clientId string
    The client ID for the application registration in the IdP.
    clientSecret string
    The client secret for the application registration in the IdP.
    grantType string
    The OAuth grant type to be used. Default: "clientcredentials"; must be one of ["clientcredentials", "password"]
    password string
    The password to use if config.oauth.grant_type is set to password.
    scopes string[]
    List of scopes to request from the IdP when obtaining a new token. Default: ["openid"]
    tokenEndpoint string
    The token endpoint URI. Not Null
    tokenHeaders {[key: string]: string}
    Extra headers to be passed in the token endpoint request.
    tokenPostArgs {[key: string]: string}
    Extra post arguments to be passed in the token endpoint request.
    username string
    The username to use if config.oauth.grant_type is set to password.
    audiences Sequence[str]
    List of audiences passed to the IdP when obtaining a new token. Default: []
    client_id str
    The client ID for the application registration in the IdP.
    client_secret str
    The client secret for the application registration in the IdP.
    grant_type str
    The OAuth grant type to be used. Default: "clientcredentials"; must be one of ["clientcredentials", "password"]
    password str
    The password to use if config.oauth.grant_type is set to password.
    scopes Sequence[str]
    List of scopes to request from the IdP when obtaining a new token. Default: ["openid"]
    token_endpoint str
    The token endpoint URI. Not Null
    token_headers Mapping[str, str]
    Extra headers to be passed in the token endpoint request.
    token_post_args Mapping[str, str]
    Extra post arguments to be passed in the token endpoint request.
    username str
    The username to use if config.oauth.grant_type is set to password.
    audiences List<String>
    List of audiences passed to the IdP when obtaining a new token. Default: []
    clientId String
    The client ID for the application registration in the IdP.
    clientSecret String
    The client secret for the application registration in the IdP.
    grantType String
    The OAuth grant type to be used. Default: "clientcredentials"; must be one of ["clientcredentials", "password"]
    password String
    The password to use if config.oauth.grant_type is set to password.
    scopes List<String>
    List of scopes to request from the IdP when obtaining a new token. Default: ["openid"]
    tokenEndpoint String
    The token endpoint URI. Not Null
    tokenHeaders Map<String>
    Extra headers to be passed in the token endpoint request.
    tokenPostArgs Map<String>
    Extra post arguments to be passed in the token endpoint request.
    username String
    The username to use if config.oauth.grant_type is set to password.

    GatewayPluginConfluentConsumeConfigTopicSchemaRegistryConfluentAuthenticationOauth2Client, GatewayPluginConfluentConsumeConfigTopicSchemaRegistryConfluentAuthenticationOauth2ClientArgs

    AuthMethod string
    The authentication method used in client requests to the IdP. Supported values are: client_secret_basic to send client_id and client_secret in the Authorization: Basic header, client_secret_post to send client_id and client_secret as part of the request body, or client_secret_jwt to send a JWT signed with the client_secret using the client assertion as part of the body. Default: "clientsecretpost"; must be one of ["clientsecretbasic", "clientsecretjwt", "clientsecretpost", "none"]
    ClientSecretJwtAlg string
    The algorithm to use with JWT when using client_secret_jwt authentication. Default: "HS512"; must be one of ["HS256", "HS512"]
    HttpProxy string
    The proxy to use when making HTTP requests to the IdP.
    HttpProxyAuthorization string
    The Proxy-Authorization header value to be used with http_proxy.
    HttpVersion double
    The HTTP version used for requests made by this plugin. Supported values: 1.1 for HTTP 1.1 and 1.0 for HTTP 1.0.
    HttpsProxy string
    The proxy to use when making HTTPS requests to the IdP.
    HttpsProxyAuthorization string
    The Proxy-Authorization header value to be used with https_proxy.
    KeepAlive bool
    Whether to use keepalive connections to the IdP. Default: true
    NoProxy string
    A comma-separated list of hosts that should not be proxied.
    SslVerify bool
    Whether to verify the certificate presented by the IdP when using HTTPS. Default: false
    Timeout double
    Network I/O timeout for requests to the IdP in milliseconds. Default: 10000
    AuthMethod string
    The authentication method used in client requests to the IdP. Supported values are: client_secret_basic to send client_id and client_secret in the Authorization: Basic header, client_secret_post to send client_id and client_secret as part of the request body, or client_secret_jwt to send a JWT signed with the client_secret using the client assertion as part of the body. Default: "clientsecretpost"; must be one of ["clientsecretbasic", "clientsecretjwt", "clientsecretpost", "none"]
    ClientSecretJwtAlg string
    The algorithm to use with JWT when using client_secret_jwt authentication. Default: "HS512"; must be one of ["HS256", "HS512"]
    HttpProxy string
    The proxy to use when making HTTP requests to the IdP.
    HttpProxyAuthorization string
    The Proxy-Authorization header value to be used with http_proxy.
    HttpVersion float64
    The HTTP version used for requests made by this plugin. Supported values: 1.1 for HTTP 1.1 and 1.0 for HTTP 1.0.
    HttpsProxy string
    The proxy to use when making HTTPS requests to the IdP.
    HttpsProxyAuthorization string
    The Proxy-Authorization header value to be used with https_proxy.
    KeepAlive bool
    Whether to use keepalive connections to the IdP. Default: true
    NoProxy string
    A comma-separated list of hosts that should not be proxied.
    SslVerify bool
    Whether to verify the certificate presented by the IdP when using HTTPS. Default: false
    Timeout float64
    Network I/O timeout for requests to the IdP in milliseconds. Default: 10000
    authMethod String
    The authentication method used in client requests to the IdP. Supported values are: client_secret_basic to send client_id and client_secret in the Authorization: Basic header, client_secret_post to send client_id and client_secret as part of the request body, or client_secret_jwt to send a JWT signed with the client_secret using the client assertion as part of the body. Default: "clientsecretpost"; must be one of ["clientsecretbasic", "clientsecretjwt", "clientsecretpost", "none"]
    clientSecretJwtAlg String
    The algorithm to use with JWT when using client_secret_jwt authentication. Default: "HS512"; must be one of ["HS256", "HS512"]
    httpProxy String
    The proxy to use when making HTTP requests to the IdP.
    httpProxyAuthorization String
    The Proxy-Authorization header value to be used with http_proxy.
    httpVersion Double
    The HTTP version used for requests made by this plugin. Supported values: 1.1 for HTTP 1.1 and 1.0 for HTTP 1.0.
    httpsProxy String
    The proxy to use when making HTTPS requests to the IdP.
    httpsProxyAuthorization String
    The Proxy-Authorization header value to be used with https_proxy.
    keepAlive Boolean
    Whether to use keepalive connections to the IdP. Default: true
    noProxy String
    A comma-separated list of hosts that should not be proxied.
    sslVerify Boolean
    Whether to verify the certificate presented by the IdP when using HTTPS. Default: false
    timeout Double
    Network I/O timeout for requests to the IdP in milliseconds. Default: 10000
    authMethod string
    The authentication method used in client requests to the IdP. Supported values are: client_secret_basic to send client_id and client_secret in the Authorization: Basic header, client_secret_post to send client_id and client_secret as part of the request body, or client_secret_jwt to send a JWT signed with the client_secret using the client assertion as part of the body. Default: "clientsecretpost"; must be one of ["clientsecretbasic", "clientsecretjwt", "clientsecretpost", "none"]
    clientSecretJwtAlg string
    The algorithm to use with JWT when using client_secret_jwt authentication. Default: "HS512"; must be one of ["HS256", "HS512"]
    httpProxy string
    The proxy to use when making HTTP requests to the IdP.
    httpProxyAuthorization string
    The Proxy-Authorization header value to be used with http_proxy.
    httpVersion number
    The HTTP version used for requests made by this plugin. Supported values: 1.1 for HTTP 1.1 and 1.0 for HTTP 1.0.
    httpsProxy string
    The proxy to use when making HTTPS requests to the IdP.
    httpsProxyAuthorization string
    The Proxy-Authorization header value to be used with https_proxy.
    keepAlive boolean
    Whether to use keepalive connections to the IdP. Default: true
    noProxy string
    A comma-separated list of hosts that should not be proxied.
    sslVerify boolean
    Whether to verify the certificate presented by the IdP when using HTTPS. Default: false
    timeout number
    Network I/O timeout for requests to the IdP in milliseconds. Default: 10000
    auth_method str
    The authentication method used in client requests to the IdP. Supported values are: client_secret_basic to send client_id and client_secret in the Authorization: Basic header, client_secret_post to send client_id and client_secret as part of the request body, or client_secret_jwt to send a JWT signed with the client_secret using the client assertion as part of the body. Default: "clientsecretpost"; must be one of ["clientsecretbasic", "clientsecretjwt", "clientsecretpost", "none"]
    client_secret_jwt_alg str
    The algorithm to use with JWT when using client_secret_jwt authentication. Default: "HS512"; must be one of ["HS256", "HS512"]
    http_proxy str
    The proxy to use when making HTTP requests to the IdP.
    http_proxy_authorization str
    The Proxy-Authorization header value to be used with http_proxy.
    http_version float
    The HTTP version used for requests made by this plugin. Supported values: 1.1 for HTTP 1.1 and 1.0 for HTTP 1.0.
    https_proxy str
    The proxy to use when making HTTPS requests to the IdP.
    https_proxy_authorization str
    The Proxy-Authorization header value to be used with https_proxy.
    keep_alive bool
    Whether to use keepalive connections to the IdP. Default: true
    no_proxy str
    A comma-separated list of hosts that should not be proxied.
    ssl_verify bool
    Whether to verify the certificate presented by the IdP when using HTTPS. Default: false
    timeout float
    Network I/O timeout for requests to the IdP in milliseconds. Default: 10000
    authMethod String
    The authentication method used in client requests to the IdP. Supported values are: client_secret_basic to send client_id and client_secret in the Authorization: Basic header, client_secret_post to send client_id and client_secret as part of the request body, or client_secret_jwt to send a JWT signed with the client_secret using the client assertion as part of the body. Default: "clientsecretpost"; must be one of ["clientsecretbasic", "clientsecretjwt", "clientsecretpost", "none"]
    clientSecretJwtAlg String
    The algorithm to use with JWT when using client_secret_jwt authentication. Default: "HS512"; must be one of ["HS256", "HS512"]
    httpProxy String
    The proxy to use when making HTTP requests to the IdP.
    httpProxyAuthorization String
    The Proxy-Authorization header value to be used with http_proxy.
    httpVersion Number
    The HTTP version used for requests made by this plugin. Supported values: 1.1 for HTTP 1.1 and 1.0 for HTTP 1.0.
    httpsProxy String
    The proxy to use when making HTTPS requests to the IdP.
    httpsProxyAuthorization String
    The Proxy-Authorization header value to be used with https_proxy.
    keepAlive Boolean
    Whether to use keepalive connections to the IdP. Default: true
    noProxy String
    A comma-separated list of hosts that should not be proxied.
    sslVerify Boolean
    Whether to verify the certificate presented by the IdP when using HTTPS. Default: false
    timeout Number
    Network I/O timeout for requests to the IdP in milliseconds. Default: 10000

    GatewayPluginConfluentConsumeConsumer, GatewayPluginConfluentConsumeConsumerArgs

    Id string
    Id string
    id String
    id string
    id str
    id String

    GatewayPluginConfluentConsumeOrdering, GatewayPluginConfluentConsumeOrderingArgs

    GatewayPluginConfluentConsumeOrderingAfter, GatewayPluginConfluentConsumeOrderingAfterArgs

    Accesses List<string>
    Accesses []string
    accesses List<String>
    accesses string[]
    accesses Sequence[str]
    accesses List<String>

    GatewayPluginConfluentConsumeOrderingBefore, GatewayPluginConfluentConsumeOrderingBeforeArgs

    Accesses List<string>
    Accesses []string
    accesses List<String>
    accesses string[]
    accesses Sequence[str]
    accesses List<String>

    GatewayPluginConfluentConsumePartial, GatewayPluginConfluentConsumePartialArgs

    Id string
    A string representing a UUID (universally unique identifier).
    Name string
    A unique string representing a UTF-8 encoded name.
    Path string
    Id string
    A string representing a UUID (universally unique identifier).
    Name string
    A unique string representing a UTF-8 encoded name.
    Path string
    id String
    A string representing a UUID (universally unique identifier).
    name String
    A unique string representing a UTF-8 encoded name.
    path String
    id string
    A string representing a UUID (universally unique identifier).
    name string
    A unique string representing a UTF-8 encoded name.
    path string
    id str
    A string representing a UUID (universally unique identifier).
    name str
    A unique string representing a UTF-8 encoded name.
    path str
    id String
    A string representing a UUID (universally unique identifier).
    name String
    A unique string representing a UTF-8 encoded name.
    path String

    GatewayPluginConfluentConsumeRoute, GatewayPluginConfluentConsumeRouteArgs

    Id string
    Id string
    id String
    id string
    id str
    id String

    GatewayPluginConfluentConsumeService, GatewayPluginConfluentConsumeServiceArgs

    Id string
    Id string
    id String
    id string
    id str
    id String

    Import

    In Terraform v1.5.0 and later, the import block can be used with the id attribute, for example:

    terraform

    import {

    to = konnect_gateway_plugin_confluent_consume.my_konnect_gateway_plugin_confluent_consume

    id = jsonencode({

    control_plane_id = "9524ec7d-36d9-465d-a8c5-83a3c9390458"
    
    id = "3473c251-5b6c-4f45-b1ff-7ede735a366d"
    

    })

    }

    The pulumi import command can be used, for example:

    $ pulumi import konnect:index/gatewayPluginConfluentConsume:GatewayPluginConfluentConsume my_konnect_gateway_plugin_confluent_consume '{"control_plane_id": "9524ec7d-36d9-465d-a8c5-83a3c9390458", "id": "3473c251-5b6c-4f45-b1ff-7ede735a366d"}'
    

    To learn more about importing existing cloud resources, see Importing resources.

    Package Details

    Repository
    konnect kong/terraform-provider-konnect
    License
    Notes
    This Pulumi package is based on the konnect Terraform Provider.
    konnect logo
    konnect 3.4.1 published on Wednesday, Oct 29, 2025 by kong
      Meet Neo: Your AI Platform Teammate