import * as pulumi from "@pulumi/pulumi"; import * as inputs from "./types/input"; import * as outputs from "./types/output"; export declare class ConnectionKafka extends pulumi.CustomResource { /** * Get an existing ConnectionKafka resource's state with the given name, ID, and optional extra * properties used to qualify the lookup. * * @param name The _unique_ name of the resulting resource. * @param id The _unique_ provider ID of the resource to lookup. * @param state Any extra arguments used during the lookup. * @param opts Optional settings to control the behavior of the CustomResource. */ static get(name: string, id: pulumi.Input, state?: ConnectionKafkaState, opts?: pulumi.CustomResourceOptions): ConnectionKafka; /** * Returns true if the given object is an instance of ConnectionKafka. This is designed to work even * when multiple copies of the Pulumi SDK have been loaded into the same process. */ static isInstance(obj: any): obj is ConnectionKafka; /** * The AWS connection to use for IAM authentication. */ readonly awsConnection: pulumi.Output; /** * AWS PrivateLink configuration. Conflicts with `kafka_broker`. */ readonly awsPrivatelink: pulumi.Output; /** * Comment on an object in the database. */ readonly comment: pulumi.Output; readonly connectionKafkaId: pulumi.Output; /** * The identifier for the connection database in Materialize. Defaults to `MZ_DATABASE` environment variable if set or `materialize` if environment variable is not set. */ readonly databaseName: pulumi.Output; /** * The Kafka broker's configuration. */ readonly kafkaBrokers: pulumi.Output; /** * The identifier for the connection. */ readonly name: pulumi.Output; /** * The owernship role of the object. */ readonly ownershipRole: pulumi.Output; /** * The name of a topic that Kafka sinks can use to track internal consistency metadata. */ readonly progressTopic: pulumi.Output; /** * The replication factor to use when creating the Kafka progress topic (if the Kafka topic does not already exist). */ readonly progressTopicReplicationFactor: pulumi.Output; /** * The fully qualified name of the connection. */ readonly qualifiedSqlName: pulumi.Output; /** * The region to use for the resource connection. If not set, the default region is used. */ readonly region: pulumi.Output; /** * The SASL mechanism for the Kafka broker. */ readonly saslMechanisms: pulumi.Output; /** * The SASL password for the Kafka broker. */ readonly saslPassword: pulumi.Output; /** * The SASL username for the Kafka broker.. Can be supplied as either free text using `text` or reference to a secret object using `secret`. */ readonly saslUsername: pulumi.Output; /** * The identifier for the connection schema in Materialize. Defaults to `public`. */ readonly schemaName: pulumi.Output; /** * The security protocol to use: `PLAINTEXT`, `SSL`, `SASL_PLAINTEXT`, or `SASL_SSL`. */ readonly securityProtocol: pulumi.Output; /** * The default SSH tunnel configuration for the Kafka brokers. */ readonly sshTunnel: pulumi.Output; /** * The client certificate for the Kafka broker.. Can be supplied as either free text using `text` or reference to a secret object using `secret`. */ readonly sslCertificate: pulumi.Output; /** * The CA certificate for the Kafka broker.. Can be supplied as either free text using `text` or reference to a secret object using `secret`. */ readonly sslCertificateAuthority: pulumi.Output; /** * The client key for the Kafka broker. */ readonly sslKey: pulumi.Output; /** * If the connection should wait for validation. */ readonly validate: pulumi.Output; /** * Create a ConnectionKafka resource with the given unique name, arguments, and options. * * @param name The _unique_ name of the resource. * @param args The arguments to use to populate this resource's properties. * @param opts A bag of options that control this resource's behavior. */ constructor(name: string, args?: ConnectionKafkaArgs, opts?: pulumi.CustomResourceOptions); } /** * Input properties used for looking up and filtering ConnectionKafka resources. */ export interface ConnectionKafkaState { /** * The AWS connection to use for IAM authentication. */ awsConnection?: pulumi.Input; /** * AWS PrivateLink configuration. Conflicts with `kafka_broker`. */ awsPrivatelink?: pulumi.Input; /** * Comment on an object in the database. */ comment?: pulumi.Input; connectionKafkaId?: pulumi.Input; /** * The identifier for the connection database in Materialize. Defaults to `MZ_DATABASE` environment variable if set or `materialize` if environment variable is not set. */ databaseName?: pulumi.Input; /** * The Kafka broker's configuration. */ kafkaBrokers?: pulumi.Input[]>; /** * The identifier for the connection. */ name?: pulumi.Input; /** * The owernship role of the object. */ ownershipRole?: pulumi.Input; /** * The name of a topic that Kafka sinks can use to track internal consistency metadata. */ progressTopic?: pulumi.Input; /** * The replication factor to use when creating the Kafka progress topic (if the Kafka topic does not already exist). */ progressTopicReplicationFactor?: pulumi.Input; /** * The fully qualified name of the connection. */ qualifiedSqlName?: pulumi.Input; /** * The region to use for the resource connection. If not set, the default region is used. */ region?: pulumi.Input; /** * The SASL mechanism for the Kafka broker. */ saslMechanisms?: pulumi.Input; /** * The SASL password for the Kafka broker. */ saslPassword?: pulumi.Input; /** * The SASL username for the Kafka broker.. Can be supplied as either free text using `text` or reference to a secret object using `secret`. */ saslUsername?: pulumi.Input; /** * The identifier for the connection schema in Materialize. Defaults to `public`. */ schemaName?: pulumi.Input; /** * The security protocol to use: `PLAINTEXT`, `SSL`, `SASL_PLAINTEXT`, or `SASL_SSL`. */ securityProtocol?: pulumi.Input; /** * The default SSH tunnel configuration for the Kafka brokers. */ sshTunnel?: pulumi.Input; /** * The client certificate for the Kafka broker.. Can be supplied as either free text using `text` or reference to a secret object using `secret`. */ sslCertificate?: pulumi.Input; /** * The CA certificate for the Kafka broker.. Can be supplied as either free text using `text` or reference to a secret object using `secret`. */ sslCertificateAuthority?: pulumi.Input; /** * The client key for the Kafka broker. */ sslKey?: pulumi.Input; /** * If the connection should wait for validation. */ validate?: pulumi.Input; } /** * The set of arguments for constructing a ConnectionKafka resource. */ export interface ConnectionKafkaArgs { /** * The AWS connection to use for IAM authentication. */ awsConnection?: pulumi.Input; /** * AWS PrivateLink configuration. Conflicts with `kafka_broker`. */ awsPrivatelink?: pulumi.Input; /** * Comment on an object in the database. */ comment?: pulumi.Input; connectionKafkaId?: pulumi.Input; /** * The identifier for the connection database in Materialize. Defaults to `MZ_DATABASE` environment variable if set or `materialize` if environment variable is not set. */ databaseName?: pulumi.Input; /** * The Kafka broker's configuration. */ kafkaBrokers?: pulumi.Input[]>; /** * The identifier for the connection. */ name?: pulumi.Input; /** * The owernship role of the object. */ ownershipRole?: pulumi.Input; /** * The name of a topic that Kafka sinks can use to track internal consistency metadata. */ progressTopic?: pulumi.Input; /** * The replication factor to use when creating the Kafka progress topic (if the Kafka topic does not already exist). */ progressTopicReplicationFactor?: pulumi.Input; /** * The region to use for the resource connection. If not set, the default region is used. */ region?: pulumi.Input; /** * The SASL mechanism for the Kafka broker. */ saslMechanisms?: pulumi.Input; /** * The SASL password for the Kafka broker. */ saslPassword?: pulumi.Input; /** * The SASL username for the Kafka broker.. Can be supplied as either free text using `text` or reference to a secret object using `secret`. */ saslUsername?: pulumi.Input; /** * The identifier for the connection schema in Materialize. Defaults to `public`. */ schemaName?: pulumi.Input; /** * The security protocol to use: `PLAINTEXT`, `SSL`, `SASL_PLAINTEXT`, or `SASL_SSL`. */ securityProtocol?: pulumi.Input; /** * The default SSH tunnel configuration for the Kafka brokers. */ sshTunnel?: pulumi.Input; /** * The client certificate for the Kafka broker.. Can be supplied as either free text using `text` or reference to a secret object using `secret`. */ sslCertificate?: pulumi.Input; /** * The CA certificate for the Kafka broker.. Can be supplied as either free text using `text` or reference to a secret object using `secret`. */ sslCertificateAuthority?: pulumi.Input; /** * The client key for the Kafka broker. */ sslKey?: pulumi.Input; /** * If the connection should wait for validation. */ validate?: pulumi.Input; }