import _m0 from 'protobufjs/minimal'; export declare const protobufPackage = "yandex.cloud.mdb.kafka.v1"; /** * An object that represents an Apache Kafka® connector. * * See [the documentation](/docs/managed-kafka/concepts/connectors) for details. */ export interface ConnectorSpec { /** Name of the connector. */ name: string; /** Maximum number of connector tasks. Default value is the number of brokers. */ tasksMax?: number; /** * A set of properties passed to Managed Service for Apache Kafka® with the connector configuration. * Example: `sync.topics.config.enabled: true`. */ properties: { [key: string]: string; }; /** Configuration of the MirrorMaker connector. */ connectorConfigMirrormaker?: ConnectorConfigMirrorMakerSpec | undefined; /** Configuration of S3-Sink connector. */ connectorConfigS3Sink?: ConnectorConfigS3SinkSpec | undefined; } export interface ConnectorSpec_PropertiesEntry { key: string; value: string; } export interface UpdateConnectorSpec { /** Maximum number of connector tasks to update. */ tasksMax?: number; /** * A set of new or changed properties to update for the connector. They are passed with the connector configuration to Managed Service for Apache Kafka®. * Example: `sync.topics.config.enabled: false`. */ properties: { [key: string]: string; }; /** Configuration of the MirrorMaker connector. */ connectorConfigMirrormaker?: ConnectorConfigMirrorMakerSpec | undefined; /** Update specification for S3-Sink Connector. */ connectorConfigS3Sink?: UpdateConnectorConfigS3SinkSpec | undefined; } export interface UpdateConnectorSpec_PropertiesEntry { key: string; value: string; } export interface ConnectorConfigMirrorMakerSpec { /** Source cluster configuration for the MirrorMaker connector. */ sourceCluster?: ClusterConnectionSpec; /** Target cluster configuration for the MirrorMaker connector. */ targetCluster?: ClusterConnectionSpec; /** List of Kafka topics, separated by `,`. */ topics: string; /** Replication factor for automatically created topics. */ replicationFactor?: number; } export interface ClusterConnectionSpec { /** * Alias of cluster connection configuration. * Examples: `source`, `target`. */ alias: string; /** Connection configuration of the cluster the connector belongs to. As all credentials are already known, leave this parameter empty. */ thisCluster?: ThisClusterSpec | undefined; /** Configuration of connection to an external cluster with all the necessary credentials. */ externalCluster?: ExternalClusterConnectionSpec | undefined; } export interface ThisClusterSpec { } export interface ExternalClusterConnectionSpec { /** List of bootstrap servers of the cluster, separated by `,`. */ bootstrapServers: string; /** SASL username to use for connection to the cluster. */ saslUsername: string; /** SASL password to use for connection to the cluster. */ saslPassword: string; /** SASL mechanism to use for connection to the cluster. */ saslMechanism: string; /** Security protocol to use for connection to the cluster. */ securityProtocol: string; /** * CA in PEM format to connect to external cluster. * Lines of certificate separated by '\n' symbol. */ sslTruststoreCertificates: string; } /** Specification for Kafka S3-Sink Connector. */ export interface ConnectorConfigS3SinkSpec { /** List of Kafka topics, separated by ','. */ topics: string; /** * The compression type used for files put on GCS. * The supported values are: `gzip`, `snappy`, `zstd`, `none`. * Optional, the default is `none`. */ fileCompressionType: string; /** Max records per file. */ fileMaxRecords?: number; /** Credentials for connecting to S3 storage. */ s3Connection?: S3ConnectionSpec; } /** Specification for update Kafka S3-Sink Connector. */ export interface UpdateConnectorConfigS3SinkSpec { /** List of Kafka topics, separated by ','. */ topics: string; /** Max records per file. */ fileMaxRecords?: number; /** Credentials for connecting to S3 storage. */ s3Connection?: S3ConnectionSpec; } /** * Specification for S3Connection - * settings of connection to AWS-compatible S3 storage, that * are source or target of Kafka S3-connectors. * YC Object Storage is AWS-compatible. */ export interface S3ConnectionSpec { bucketName: string; externalS3?: ExternalS3StorageSpec | undefined; } export interface ExternalS3StorageSpec { accessKeyId: string; secretAccessKey: string; endpoint: string; /** Default is 'us-east-1'. */ region: string; } export interface Connector { /** Name of the connector. */ name: string; /** Maximum number of connector tasks. Default value is the number of brokers. */ tasksMax?: number; /** * A set of properties passed to Managed Service for Apache Kafka® with the connector configuration. * Example: `sync.topics.config.enabled: true`. */ properties: { [key: string]: string; }; /** Connector health. */ health: Connector_Health; /** Current status of the connector. */ status: Connector_Status; /** ID of the Apache Kafka® cluster that the connector belongs to. */ clusterId: string; /** Configuration of the MirrorMaker connector. */ connectorConfigMirrormaker?: ConnectorConfigMirrorMaker | undefined; /** Configuration of S3-Sink connector. */ connectorConfigS3Sink?: ConnectorConfigS3Sink | undefined; } export declare enum Connector_Health { /** HEALTH_UNKNOWN - Health of the connector is unknown. */ HEALTH_UNKNOWN = 0, /** ALIVE - Connector is running. */ ALIVE = 1, /** DEAD - Connector has failed to start. */ DEAD = 2, UNRECOGNIZED = -1 } export declare function connector_HealthFromJSON(object: any): Connector_Health; export declare function connector_HealthToJSON(object: Connector_Health): string; export declare enum Connector_Status { /** STATUS_UNKNOWN - Connector state is unknown. */ STATUS_UNKNOWN = 0, /** RUNNING - Connector is running normally. */ RUNNING = 1, /** ERROR - Connector has encountered a problem and cannot operate. */ ERROR = 2, /** PAUSED - Connector is paused. */ PAUSED = 3, UNRECOGNIZED = -1 } export declare function connector_StatusFromJSON(object: any): Connector_Status; export declare function connector_StatusToJSON(object: Connector_Status): string; export interface Connector_PropertiesEntry { key: string; value: string; } export interface ConnectorConfigMirrorMaker { /** Source cluster connection configuration. */ sourceCluster?: ClusterConnection; /** Target cluster connection configuration. */ targetCluster?: ClusterConnection; /** List of Kafka topics, separated by `,`. */ topics: string; /** Replication factor for automatically created topics. */ replicationFactor?: number; } export interface ClusterConnection { /** * Alias of cluster connection configuration. * Examples: `source`, `target`. */ alias: string; /** Connection configuration of the cluster the connector belongs to. As all credentials are already known, leave this parameter empty. */ thisCluster?: ThisCluster | undefined; /** Configuration of connection to an external cluster with all the necessary credentials. */ externalCluster?: ExternalClusterConnection | undefined; } export interface ThisCluster { } export interface ExternalClusterConnection { /** List of bootstrap servers of the cluster, separated by `,`. */ bootstrapServers: string; /** SASL username to use for connection to the cluster. */ saslUsername: string; /** SASL mechanism to use for connection to the cluster. */ saslMechanism: string; /** Security protocol to use for connection to the cluster. */ securityProtocol: string; } /** * An Apache Kafka® S3-Sink * connector resource. */ export interface ConnectorConfigS3Sink { /** List of Kafka topics, separated by ','. */ topics: string; /** * The compression type used for files put on GCS. * The supported values are: `gzip`, `snappy`, `zstd`, `none`. * Optional, the default is `none`. */ fileCompressionType: string; /** Max records per file. */ fileMaxRecords?: number; /** Credentials for connecting to S3 storage. */ s3Connection?: S3Connection; } /** * Resource for S3Connection - * settings of connection to AWS-compatible S3 storage, that * are source or target of Kafka S3-connectors. * YC Object Storage is AWS-compatible. */ export interface S3Connection { bucketName: string; externalS3?: ExternalS3Storage | undefined; } export interface ExternalS3Storage { accessKeyId: string; endpoint: string; /** Default is 'us-east-1' */ region: string; } export declare const ConnectorSpec: { encode(message: ConnectorSpec, writer?: _m0.Writer): _m0.Writer; decode(input: _m0.Reader | Uint8Array, length?: number): ConnectorSpec; fromJSON(object: any): ConnectorSpec; toJSON(message: ConnectorSpec): unknown; fromPartial, never>) | undefined; connectorConfigMirrormaker?: ({ sourceCluster?: { alias?: string | undefined; thisCluster?: {} | undefined; externalCluster?: { bootstrapServers?: string | undefined; saslUsername?: string | undefined; saslPassword?: string | undefined; saslMechanism?: string | undefined; securityProtocol?: string | undefined; sslTruststoreCertificates?: string | undefined; } | undefined; } | undefined; targetCluster?: { alias?: string | undefined; thisCluster?: {} | undefined; externalCluster?: { bootstrapServers?: string | undefined; saslUsername?: string | undefined; saslPassword?: string | undefined; saslMechanism?: string | undefined; securityProtocol?: string | undefined; sslTruststoreCertificates?: string | undefined; } | undefined; } | undefined; topics?: string | undefined; replicationFactor?: number | undefined; } & { sourceCluster?: ({ alias?: string | undefined; thisCluster?: {} | undefined; externalCluster?: { bootstrapServers?: string | undefined; saslUsername?: string | undefined; saslPassword?: string | undefined; saslMechanism?: string | undefined; securityProtocol?: string | undefined; sslTruststoreCertificates?: string | undefined; } | undefined; } & { alias?: string | undefined; thisCluster?: ({} & {} & Record, never>) | undefined; externalCluster?: ({ bootstrapServers?: string | undefined; saslUsername?: string | undefined; saslPassword?: string | undefined; saslMechanism?: string | undefined; securityProtocol?: string | undefined; sslTruststoreCertificates?: string | undefined; } & { bootstrapServers?: string | undefined; saslUsername?: string | undefined; saslPassword?: string | undefined; saslMechanism?: string | undefined; securityProtocol?: string | undefined; sslTruststoreCertificates?: string | undefined; } & Record, never>) | undefined; } & Record, never>) | undefined; targetCluster?: ({ alias?: string | undefined; thisCluster?: {} | undefined; externalCluster?: { bootstrapServers?: string | undefined; saslUsername?: string | undefined; saslPassword?: string | undefined; saslMechanism?: string | undefined; securityProtocol?: string | undefined; sslTruststoreCertificates?: string | undefined; } | undefined; } & { alias?: string | undefined; thisCluster?: ({} & {} & Record, never>) | undefined; externalCluster?: ({ bootstrapServers?: string | undefined; saslUsername?: string | undefined; saslPassword?: string | undefined; saslMechanism?: string | undefined; securityProtocol?: string | undefined; sslTruststoreCertificates?: string | undefined; } & { bootstrapServers?: string | undefined; saslUsername?: string | undefined; saslPassword?: string | undefined; saslMechanism?: string | undefined; securityProtocol?: string | undefined; sslTruststoreCertificates?: string | undefined; } & Record, never>) | undefined; } & Record, never>) | undefined; topics?: string | undefined; replicationFactor?: number | undefined; } & Record, never>) | undefined; connectorConfigS3Sink?: ({ topics?: string | undefined; fileCompressionType?: string | undefined; fileMaxRecords?: number | undefined; s3Connection?: { bucketName?: string | undefined; externalS3?: { accessKeyId?: string | undefined; secretAccessKey?: string | undefined; endpoint?: string | undefined; region?: string | undefined; } | undefined; } | undefined; } & { topics?: string | undefined; fileCompressionType?: string | undefined; fileMaxRecords?: number | undefined; s3Connection?: ({ bucketName?: string | undefined; externalS3?: { accessKeyId?: string | undefined; secretAccessKey?: string | undefined; endpoint?: string | undefined; region?: string | undefined; } | undefined; } & { bucketName?: string | undefined; externalS3?: ({ accessKeyId?: string | undefined; secretAccessKey?: string | undefined; endpoint?: string | undefined; region?: string | undefined; } & { accessKeyId?: string | undefined; secretAccessKey?: string | undefined; endpoint?: string | undefined; region?: string | undefined; } & Record, never>) | undefined; } & Record, never>) | undefined; } & Record, never>) | undefined; } & Record, never>>(object: I): ConnectorSpec; }; export declare const ConnectorSpec_PropertiesEntry: { encode(message: ConnectorSpec_PropertiesEntry, writer?: _m0.Writer): _m0.Writer; decode(input: _m0.Reader | Uint8Array, length?: number): ConnectorSpec_PropertiesEntry; fromJSON(object: any): ConnectorSpec_PropertiesEntry; toJSON(message: ConnectorSpec_PropertiesEntry): unknown; fromPartial, never>>(object: I): ConnectorSpec_PropertiesEntry; }; export declare const UpdateConnectorSpec: { encode(message: UpdateConnectorSpec, writer?: _m0.Writer): _m0.Writer; decode(input: _m0.Reader | Uint8Array, length?: number): UpdateConnectorSpec; fromJSON(object: any): UpdateConnectorSpec; toJSON(message: UpdateConnectorSpec): unknown; fromPartial, never>) | undefined; connectorConfigMirrormaker?: ({ sourceCluster?: { alias?: string | undefined; thisCluster?: {} | undefined; externalCluster?: { bootstrapServers?: string | undefined; saslUsername?: string | undefined; saslPassword?: string | undefined; saslMechanism?: string | undefined; securityProtocol?: string | undefined; sslTruststoreCertificates?: string | undefined; } | undefined; } | undefined; targetCluster?: { alias?: string | undefined; thisCluster?: {} | undefined; externalCluster?: { bootstrapServers?: string | undefined; saslUsername?: string | undefined; saslPassword?: string | undefined; saslMechanism?: string | undefined; securityProtocol?: string | undefined; sslTruststoreCertificates?: string | undefined; } | undefined; } | undefined; topics?: string | undefined; replicationFactor?: number | undefined; } & { sourceCluster?: ({ alias?: string | undefined; thisCluster?: {} | undefined; externalCluster?: { bootstrapServers?: string | undefined; saslUsername?: string | undefined; saslPassword?: string | undefined; saslMechanism?: string | undefined; securityProtocol?: string | undefined; sslTruststoreCertificates?: string | undefined; } | undefined; } & { alias?: string | undefined; thisCluster?: ({} & {} & Record, never>) | undefined; externalCluster?: ({ bootstrapServers?: string | undefined; saslUsername?: string | undefined; saslPassword?: string | undefined; saslMechanism?: string | undefined; securityProtocol?: string | undefined; sslTruststoreCertificates?: string | undefined; } & { bootstrapServers?: string | undefined; saslUsername?: string | undefined; saslPassword?: string | undefined; saslMechanism?: string | undefined; securityProtocol?: string | undefined; sslTruststoreCertificates?: string | undefined; } & Record, never>) | undefined; } & Record, never>) | undefined; targetCluster?: ({ alias?: string | undefined; thisCluster?: {} | undefined; externalCluster?: { bootstrapServers?: string | undefined; saslUsername?: string | undefined; saslPassword?: string | undefined; saslMechanism?: string | undefined; securityProtocol?: string | undefined; sslTruststoreCertificates?: string | undefined; } | undefined; } & { alias?: string | undefined; thisCluster?: ({} & {} & Record, never>) | undefined; externalCluster?: ({ bootstrapServers?: string | undefined; saslUsername?: string | undefined; saslPassword?: string | undefined; saslMechanism?: string | undefined; securityProtocol?: string | undefined; sslTruststoreCertificates?: string | undefined; } & { bootstrapServers?: string | undefined; saslUsername?: string | undefined; saslPassword?: string | undefined; saslMechanism?: string | undefined; securityProtocol?: string | undefined; sslTruststoreCertificates?: string | undefined; } & Record, never>) | undefined; } & Record, never>) | undefined; topics?: string | undefined; replicationFactor?: number | undefined; } & Record, never>) | undefined; connectorConfigS3Sink?: ({ topics?: string | undefined; fileMaxRecords?: number | undefined; s3Connection?: { bucketName?: string | undefined; externalS3?: { accessKeyId?: string | undefined; secretAccessKey?: string | undefined; endpoint?: string | undefined; region?: string | undefined; } | undefined; } | undefined; } & { topics?: string | undefined; fileMaxRecords?: number | undefined; s3Connection?: ({ bucketName?: string | undefined; externalS3?: { accessKeyId?: string | undefined; secretAccessKey?: string | undefined; endpoint?: string | undefined; region?: string | undefined; } | undefined; } & { bucketName?: string | undefined; externalS3?: ({ accessKeyId?: string | undefined; secretAccessKey?: string | undefined; endpoint?: string | undefined; region?: string | undefined; } & { accessKeyId?: string | undefined; secretAccessKey?: string | undefined; endpoint?: string | undefined; region?: string | undefined; } & Record, never>) | undefined; } & Record, never>) | undefined; } & Record, never>) | undefined; } & Record, never>>(object: I): UpdateConnectorSpec; }; export declare const UpdateConnectorSpec_PropertiesEntry: { encode(message: UpdateConnectorSpec_PropertiesEntry, writer?: _m0.Writer): _m0.Writer; decode(input: _m0.Reader | Uint8Array, length?: number): UpdateConnectorSpec_PropertiesEntry; fromJSON(object: any): UpdateConnectorSpec_PropertiesEntry; toJSON(message: UpdateConnectorSpec_PropertiesEntry): unknown; fromPartial, never>>(object: I): UpdateConnectorSpec_PropertiesEntry; }; export declare const ConnectorConfigMirrorMakerSpec: { encode(message: ConnectorConfigMirrorMakerSpec, writer?: _m0.Writer): _m0.Writer; decode(input: _m0.Reader | Uint8Array, length?: number): ConnectorConfigMirrorMakerSpec; fromJSON(object: any): ConnectorConfigMirrorMakerSpec; toJSON(message: ConnectorConfigMirrorMakerSpec): unknown; fromPartial, never>) | undefined; externalCluster?: ({ bootstrapServers?: string | undefined; saslUsername?: string | undefined; saslPassword?: string | undefined; saslMechanism?: string | undefined; securityProtocol?: string | undefined; sslTruststoreCertificates?: string | undefined; } & { bootstrapServers?: string | undefined; saslUsername?: string | undefined; saslPassword?: string | undefined; saslMechanism?: string | undefined; securityProtocol?: string | undefined; sslTruststoreCertificates?: string | undefined; } & Record, never>) | undefined; } & Record, never>) | undefined; targetCluster?: ({ alias?: string | undefined; thisCluster?: {} | undefined; externalCluster?: { bootstrapServers?: string | undefined; saslUsername?: string | undefined; saslPassword?: string | undefined; saslMechanism?: string | undefined; securityProtocol?: string | undefined; sslTruststoreCertificates?: string | undefined; } | undefined; } & { alias?: string | undefined; thisCluster?: ({} & {} & Record, never>) | undefined; externalCluster?: ({ bootstrapServers?: string | undefined; saslUsername?: string | undefined; saslPassword?: string | undefined; saslMechanism?: string | undefined; securityProtocol?: string | undefined; sslTruststoreCertificates?: string | undefined; } & { bootstrapServers?: string | undefined; saslUsername?: string | undefined; saslPassword?: string | undefined; saslMechanism?: string | undefined; securityProtocol?: string | undefined; sslTruststoreCertificates?: string | undefined; } & Record, never>) | undefined; } & Record, never>) | undefined; topics?: string | undefined; replicationFactor?: number | undefined; } & Record, never>>(object: I): ConnectorConfigMirrorMakerSpec; }; export declare const ClusterConnectionSpec: { encode(message: ClusterConnectionSpec, writer?: _m0.Writer): _m0.Writer; decode(input: _m0.Reader | Uint8Array, length?: number): ClusterConnectionSpec; fromJSON(object: any): ClusterConnectionSpec; toJSON(message: ClusterConnectionSpec): unknown; fromPartial, never>) | undefined; externalCluster?: ({ bootstrapServers?: string | undefined; saslUsername?: string | undefined; saslPassword?: string | undefined; saslMechanism?: string | undefined; securityProtocol?: string | undefined; sslTruststoreCertificates?: string | undefined; } & { bootstrapServers?: string | undefined; saslUsername?: string | undefined; saslPassword?: string | undefined; saslMechanism?: string | undefined; securityProtocol?: string | undefined; sslTruststoreCertificates?: string | undefined; } & Record, never>) | undefined; } & Record, never>>(object: I): ClusterConnectionSpec; }; export declare const ThisClusterSpec: { encode(_: ThisClusterSpec, writer?: _m0.Writer): _m0.Writer; decode(input: _m0.Reader | Uint8Array, length?: number): ThisClusterSpec; fromJSON(_: any): ThisClusterSpec; toJSON(_: ThisClusterSpec): unknown; fromPartial, never>>(_: I): ThisClusterSpec; }; export declare const ExternalClusterConnectionSpec: { encode(message: ExternalClusterConnectionSpec, writer?: _m0.Writer): _m0.Writer; decode(input: _m0.Reader | Uint8Array, length?: number): ExternalClusterConnectionSpec; fromJSON(object: any): ExternalClusterConnectionSpec; toJSON(message: ExternalClusterConnectionSpec): unknown; fromPartial, never>>(object: I): ExternalClusterConnectionSpec; }; export declare const ConnectorConfigS3SinkSpec: { encode(message: ConnectorConfigS3SinkSpec, writer?: _m0.Writer): _m0.Writer; decode(input: _m0.Reader | Uint8Array, length?: number): ConnectorConfigS3SinkSpec; fromJSON(object: any): ConnectorConfigS3SinkSpec; toJSON(message: ConnectorConfigS3SinkSpec): unknown; fromPartial, never>) | undefined; } & Record, never>) | undefined; } & Record, never>>(object: I): ConnectorConfigS3SinkSpec; }; export declare const UpdateConnectorConfigS3SinkSpec: { encode(message: UpdateConnectorConfigS3SinkSpec, writer?: _m0.Writer): _m0.Writer; decode(input: _m0.Reader | Uint8Array, length?: number): UpdateConnectorConfigS3SinkSpec; fromJSON(object: any): UpdateConnectorConfigS3SinkSpec; toJSON(message: UpdateConnectorConfigS3SinkSpec): unknown; fromPartial, never>) | undefined; } & Record, never>) | undefined; } & Record, never>>(object: I): UpdateConnectorConfigS3SinkSpec; }; export declare const S3ConnectionSpec: { encode(message: S3ConnectionSpec, writer?: _m0.Writer): _m0.Writer; decode(input: _m0.Reader | Uint8Array, length?: number): S3ConnectionSpec; fromJSON(object: any): S3ConnectionSpec; toJSON(message: S3ConnectionSpec): unknown; fromPartial, never>) | undefined; } & Record, never>>(object: I): S3ConnectionSpec; }; export declare const ExternalS3StorageSpec: { encode(message: ExternalS3StorageSpec, writer?: _m0.Writer): _m0.Writer; decode(input: _m0.Reader | Uint8Array, length?: number): ExternalS3StorageSpec; fromJSON(object: any): ExternalS3StorageSpec; toJSON(message: ExternalS3StorageSpec): unknown; fromPartial, never>>(object: I): ExternalS3StorageSpec; }; export declare const Connector: { encode(message: Connector, writer?: _m0.Writer): _m0.Writer; decode(input: _m0.Reader | Uint8Array, length?: number): Connector; fromJSON(object: any): Connector; toJSON(message: Connector): unknown; fromPartial, never>) | undefined; health?: Connector_Health | undefined; status?: Connector_Status | undefined; clusterId?: string | undefined; connectorConfigMirrormaker?: ({ sourceCluster?: { alias?: string | undefined; thisCluster?: {} | undefined; externalCluster?: { bootstrapServers?: string | undefined; saslUsername?: string | undefined; saslMechanism?: string | undefined; securityProtocol?: string | undefined; } | undefined; } | undefined; targetCluster?: { alias?: string | undefined; thisCluster?: {} | undefined; externalCluster?: { bootstrapServers?: string | undefined; saslUsername?: string | undefined; saslMechanism?: string | undefined; securityProtocol?: string | undefined; } | undefined; } | undefined; topics?: string | undefined; replicationFactor?: number | undefined; } & { sourceCluster?: ({ alias?: string | undefined; thisCluster?: {} | undefined; externalCluster?: { bootstrapServers?: string | undefined; saslUsername?: string | undefined; saslMechanism?: string | undefined; securityProtocol?: string | undefined; } | undefined; } & { alias?: string | undefined; thisCluster?: ({} & {} & Record, never>) | undefined; externalCluster?: ({ bootstrapServers?: string | undefined; saslUsername?: string | undefined; saslMechanism?: string | undefined; securityProtocol?: string | undefined; } & { bootstrapServers?: string | undefined; saslUsername?: string | undefined; saslMechanism?: string | undefined; securityProtocol?: string | undefined; } & Record, never>) | undefined; } & Record, never>) | undefined; targetCluster?: ({ alias?: string | undefined; thisCluster?: {} | undefined; externalCluster?: { bootstrapServers?: string | undefined; saslUsername?: string | undefined; saslMechanism?: string | undefined; securityProtocol?: string | undefined; } | undefined; } & { alias?: string | undefined; thisCluster?: ({} & {} & Record, never>) | undefined; externalCluster?: ({ bootstrapServers?: string | undefined; saslUsername?: string | undefined; saslMechanism?: string | undefined; securityProtocol?: string | undefined; } & { bootstrapServers?: string | undefined; saslUsername?: string | undefined; saslMechanism?: string | undefined; securityProtocol?: string | undefined; } & Record, never>) | undefined; } & Record, never>) | undefined; topics?: string | undefined; replicationFactor?: number | undefined; } & Record, never>) | undefined; connectorConfigS3Sink?: ({ topics?: string | undefined; fileCompressionType?: string | undefined; fileMaxRecords?: number | undefined; s3Connection?: { bucketName?: string | undefined; externalS3?: { accessKeyId?: string | undefined; endpoint?: string | undefined; region?: string | undefined; } | undefined; } | undefined; } & { topics?: string | undefined; fileCompressionType?: string | undefined; fileMaxRecords?: number | undefined; s3Connection?: ({ bucketName?: string | undefined; externalS3?: { accessKeyId?: string | undefined; endpoint?: string | undefined; region?: string | undefined; } | undefined; } & { bucketName?: string | undefined; externalS3?: ({ accessKeyId?: string | undefined; endpoint?: string | undefined; region?: string | undefined; } & { accessKeyId?: string | undefined; endpoint?: string | undefined; region?: string | undefined; } & Record, never>) | undefined; } & Record, never>) | undefined; } & Record, never>) | undefined; } & Record, never>>(object: I): Connector; }; export declare const Connector_PropertiesEntry: { encode(message: Connector_PropertiesEntry, writer?: _m0.Writer): _m0.Writer; decode(input: _m0.Reader | Uint8Array, length?: number): Connector_PropertiesEntry; fromJSON(object: any): Connector_PropertiesEntry; toJSON(message: Connector_PropertiesEntry): unknown; fromPartial, never>>(object: I): Connector_PropertiesEntry; }; export declare const ConnectorConfigMirrorMaker: { encode(message: ConnectorConfigMirrorMaker, writer?: _m0.Writer): _m0.Writer; decode(input: _m0.Reader | Uint8Array, length?: number): ConnectorConfigMirrorMaker; fromJSON(object: any): ConnectorConfigMirrorMaker; toJSON(message: ConnectorConfigMirrorMaker): unknown; fromPartial, never>) | undefined; externalCluster?: ({ bootstrapServers?: string | undefined; saslUsername?: string | undefined; saslMechanism?: string | undefined; securityProtocol?: string | undefined; } & { bootstrapServers?: string | undefined; saslUsername?: string | undefined; saslMechanism?: string | undefined; securityProtocol?: string | undefined; } & Record, never>) | undefined; } & Record, never>) | undefined; targetCluster?: ({ alias?: string | undefined; thisCluster?: {} | undefined; externalCluster?: { bootstrapServers?: string | undefined; saslUsername?: string | undefined; saslMechanism?: string | undefined; securityProtocol?: string | undefined; } | undefined; } & { alias?: string | undefined; thisCluster?: ({} & {} & Record, never>) | undefined; externalCluster?: ({ bootstrapServers?: string | undefined; saslUsername?: string | undefined; saslMechanism?: string | undefined; securityProtocol?: string | undefined; } & { bootstrapServers?: string | undefined; saslUsername?: string | undefined; saslMechanism?: string | undefined; securityProtocol?: string | undefined; } & Record, never>) | undefined; } & Record, never>) | undefined; topics?: string | undefined; replicationFactor?: number | undefined; } & Record, never>>(object: I): ConnectorConfigMirrorMaker; }; export declare const ClusterConnection: { encode(message: ClusterConnection, writer?: _m0.Writer): _m0.Writer; decode(input: _m0.Reader | Uint8Array, length?: number): ClusterConnection; fromJSON(object: any): ClusterConnection; toJSON(message: ClusterConnection): unknown; fromPartial, never>) | undefined; externalCluster?: ({ bootstrapServers?: string | undefined; saslUsername?: string | undefined; saslMechanism?: string | undefined; securityProtocol?: string | undefined; } & { bootstrapServers?: string | undefined; saslUsername?: string | undefined; saslMechanism?: string | undefined; securityProtocol?: string | undefined; } & Record, never>) | undefined; } & Record, never>>(object: I): ClusterConnection; }; export declare const ThisCluster: { encode(_: ThisCluster, writer?: _m0.Writer): _m0.Writer; decode(input: _m0.Reader | Uint8Array, length?: number): ThisCluster; fromJSON(_: any): ThisCluster; toJSON(_: ThisCluster): unknown; fromPartial, never>>(_: I): ThisCluster; }; export declare const ExternalClusterConnection: { encode(message: ExternalClusterConnection, writer?: _m0.Writer): _m0.Writer; decode(input: _m0.Reader | Uint8Array, length?: number): ExternalClusterConnection; fromJSON(object: any): ExternalClusterConnection; toJSON(message: ExternalClusterConnection): unknown; fromPartial, never>>(object: I): ExternalClusterConnection; }; export declare const ConnectorConfigS3Sink: { encode(message: ConnectorConfigS3Sink, writer?: _m0.Writer): _m0.Writer; decode(input: _m0.Reader | Uint8Array, length?: number): ConnectorConfigS3Sink; fromJSON(object: any): ConnectorConfigS3Sink; toJSON(message: ConnectorConfigS3Sink): unknown; fromPartial, never>) | undefined; } & Record, never>) | undefined; } & Record, never>>(object: I): ConnectorConfigS3Sink; }; export declare const S3Connection: { encode(message: S3Connection, writer?: _m0.Writer): _m0.Writer; decode(input: _m0.Reader | Uint8Array, length?: number): S3Connection; fromJSON(object: any): S3Connection; toJSON(message: S3Connection): unknown; fromPartial, never>) | undefined; } & Record, never>>(object: I): S3Connection; }; export declare const ExternalS3Storage: { encode(message: ExternalS3Storage, writer?: _m0.Writer): _m0.Writer; decode(input: _m0.Reader | Uint8Array, length?: number): ExternalS3Storage; fromJSON(object: any): ExternalS3Storage; toJSON(message: ExternalS3Storage): unknown; fromPartial, never>>(object: I): ExternalS3Storage; }; type Builtin = Date | Function | Uint8Array | string | number | boolean | undefined; export type DeepPartial = T extends Builtin ? T : T extends Array ? Array> : T extends ReadonlyArray ? ReadonlyArray> : T extends {} ? { [K in keyof T]?: DeepPartial; } : Partial; type KeysOfUnion = T extends T ? keyof T : never; export type Exact = P extends Builtin ? P : P & { [K in keyof P]: Exact; } & Record>, never>; export {};