import _m0 from 'protobufjs/minimal';
import { TLSMode, Secret, DataTransformationOptions, NoAuth } from '../../../../../yandex/cloud/datatransfer/v1/endpoint/common';
import { Parser } from '../../../../../yandex/cloud/datatransfer/v1/endpoint/parsers';
import { Serializer } from '../../../../../yandex/cloud/datatransfer/v1/endpoint/serializers';
export declare const protobufPackage = "yandex.cloud.datatransfer.v1.endpoint";
export declare enum KafkaMechanism {
    KAFKA_MECHANISM_UNSPECIFIED = 0,
    KAFKA_MECHANISM_SHA256 = 1,
    KAFKA_MECHANISM_SHA512 = 2,
    UNRECOGNIZED = -1
}
export declare function kafkaMechanismFromJSON(object: any): KafkaMechanism;
export declare function kafkaMechanismToJSON(object: KafkaMechanism): string;
export interface KafkaConnectionOptions {
    /** Managed Service for Kafka cluster ID */
    clusterId: string | undefined;
    /** Connection options for on-premise Kafka */
    onPremise?: OnPremiseKafka | undefined;
}
export interface OnPremiseKafka {
    /** Kafka broker URLs */
    brokerUrls: string[];
    /** Network interface for endpoint. If none will assume public ipv4 */
    subnetId: string;
    /** TLS settings for broker connection. Disabled by default. */
    tlsMode?: TLSMode;
}
export interface KafkaAuth {
    /** Authentication with SASL */
    sasl?: KafkaSaslSecurity | undefined;
    /** No authentication */
    noAuth?: NoAuth | undefined;
}
export interface KafkaSaslSecurity {
    /** User name */
    user: string;
    /** SASL mechanism for authentication */
    mechanism: KafkaMechanism;
    /** Password for user */
    password?: Secret;
}
export interface KafkaSource {
    /** Connection settings */
    connection?: KafkaConnectionOptions;
    /** Authentication settings */
    auth?: KafkaAuth;
    /** Security groups */
    securityGroups: string[];
    /**
     * Full source topic name
     * Deprecated in favor of topic names
     *
     * @deprecated
     */
    topicName: string;
    /** Data transformation rules */
    transformer?: DataTransformationOptions;
    /** Data parsing rules */
    parser?: Parser;
    /** List of topic names to read */
    topicNames: string[];
}
export interface KafkaTarget {
    /** Connection settings */
    connection?: KafkaConnectionOptions;
    /** Authentication settings */
    auth?: KafkaAuth;
    /** Security groups */
    securityGroups: string[];
    /** Target topic settings */
    topicSettings?: KafkaTargetTopicSettings;
    /** Data serialization format settings */
    serializer?: Serializer;
}
export interface KafkaTargetTopicSettings {
    /** Full topic name */
    topic?: KafkaTargetTopic | undefined;
    /**
     * Topic prefix
     *
     * Analogue of the Debezium setting database.server.name.
     * Messages will be sent to topic with name <topic_prefix>.<schema>.<table_name>.
     */
    topicPrefix: string | undefined;
}
export interface KafkaTargetTopic {
    /** Topic name */
    topicName: string;
    /**
     * Save transactions order
     * Not to split events queue into separate per-table queues.
     */
    saveTxOrder: boolean;
}
export declare const KafkaConnectionOptions: {
    encode(message: KafkaConnectionOptions, writer?: _m0.Writer): _m0.Writer;
    decode(input: _m0.Reader | Uint8Array, length?: number): KafkaConnectionOptions;
    fromJSON(object: any): KafkaConnectionOptions;
    toJSON(message: KafkaConnectionOptions): unknown;
    fromPartial<I extends {
        clusterId?: string | undefined;
        onPremise?: {
            brokerUrls?: string[] | undefined;
            subnetId?: string | undefined;
            tlsMode?: {
                disabled?: {} | undefined;
                enabled?: {
                    caCertificate?: string | undefined;
                } | undefined;
            } | undefined;
        } | undefined;
    } & {
        clusterId?: string | undefined;
        onPremise?: ({
            brokerUrls?: string[] | undefined;
            subnetId?: string | undefined;
            tlsMode?: {
                disabled?: {} | undefined;
                enabled?: {
                    caCertificate?: string | undefined;
                } | undefined;
            } | undefined;
        } & {
            brokerUrls?: (string[] & string[] & Record<Exclude<keyof I["onPremise"]["brokerUrls"], keyof string[]>, never>) | undefined;
            subnetId?: string | undefined;
            tlsMode?: ({
                disabled?: {} | undefined;
                enabled?: {
                    caCertificate?: string | undefined;
                } | undefined;
            } & {
                disabled?: ({} & {} & Record<Exclude<keyof I["onPremise"]["tlsMode"]["disabled"], never>, never>) | undefined;
                enabled?: ({
                    caCertificate?: string | undefined;
                } & {
                    caCertificate?: string | undefined;
                } & Record<Exclude<keyof I["onPremise"]["tlsMode"]["enabled"], "caCertificate">, never>) | undefined;
            } & Record<Exclude<keyof I["onPremise"]["tlsMode"], keyof TLSMode>, never>) | undefined;
        } & Record<Exclude<keyof I["onPremise"], keyof OnPremiseKafka>, never>) | undefined;
    } & Record<Exclude<keyof I, keyof KafkaConnectionOptions>, never>>(object: I): KafkaConnectionOptions;
};
export declare const OnPremiseKafka: {
    encode(message: OnPremiseKafka, writer?: _m0.Writer): _m0.Writer;
    decode(input: _m0.Reader | Uint8Array, length?: number): OnPremiseKafka;
    fromJSON(object: any): OnPremiseKafka;
    toJSON(message: OnPremiseKafka): unknown;
    fromPartial<I extends {
        brokerUrls?: string[] | undefined;
        subnetId?: string | undefined;
        tlsMode?: {
            disabled?: {} | undefined;
            enabled?: {
                caCertificate?: string | undefined;
            } | undefined;
        } | undefined;
    } & {
        brokerUrls?: (string[] & string[] & Record<Exclude<keyof I["brokerUrls"], keyof string[]>, never>) | undefined;
        subnetId?: string | undefined;
        tlsMode?: ({
            disabled?: {} | undefined;
            enabled?: {
                caCertificate?: string | undefined;
            } | undefined;
        } & {
            disabled?: ({} & {} & Record<Exclude<keyof I["tlsMode"]["disabled"], never>, never>) | undefined;
            enabled?: ({
                caCertificate?: string | undefined;
            } & {
                caCertificate?: string | undefined;
            } & Record<Exclude<keyof I["tlsMode"]["enabled"], "caCertificate">, never>) | undefined;
        } & Record<Exclude<keyof I["tlsMode"], keyof TLSMode>, never>) | undefined;
    } & Record<Exclude<keyof I, keyof OnPremiseKafka>, never>>(object: I): OnPremiseKafka;
};
export declare const KafkaAuth: {
    encode(message: KafkaAuth, writer?: _m0.Writer): _m0.Writer;
    decode(input: _m0.Reader | Uint8Array, length?: number): KafkaAuth;
    fromJSON(object: any): KafkaAuth;
    toJSON(message: KafkaAuth): unknown;
    fromPartial<I extends {
        sasl?: {
            user?: string | undefined;
            mechanism?: KafkaMechanism | undefined;
            password?: {
                raw?: string | undefined;
            } | undefined;
        } | undefined;
        noAuth?: {} | undefined;
    } & {
        sasl?: ({
            user?: string | undefined;
            mechanism?: KafkaMechanism | undefined;
            password?: {
                raw?: string | undefined;
            } | undefined;
        } & {
            user?: string | undefined;
            mechanism?: KafkaMechanism | undefined;
            password?: ({
                raw?: string | undefined;
            } & {
                raw?: string | undefined;
            } & Record<Exclude<keyof I["sasl"]["password"], "raw">, never>) | undefined;
        } & Record<Exclude<keyof I["sasl"], keyof KafkaSaslSecurity>, never>) | undefined;
        noAuth?: ({} & {} & Record<Exclude<keyof I["noAuth"], never>, never>) | undefined;
    } & Record<Exclude<keyof I, keyof KafkaAuth>, never>>(object: I): KafkaAuth;
};
export declare const KafkaSaslSecurity: {
    encode(message: KafkaSaslSecurity, writer?: _m0.Writer): _m0.Writer;
    decode(input: _m0.Reader | Uint8Array, length?: number): KafkaSaslSecurity;
    fromJSON(object: any): KafkaSaslSecurity;
    toJSON(message: KafkaSaslSecurity): unknown;
    fromPartial<I extends {
        user?: string | undefined;
        mechanism?: KafkaMechanism | undefined;
        password?: {
            raw?: string | undefined;
        } | undefined;
    } & {
        user?: string | undefined;
        mechanism?: KafkaMechanism | undefined;
        password?: ({
            raw?: string | undefined;
        } & {
            raw?: string | undefined;
        } & Record<Exclude<keyof I["password"], "raw">, never>) | undefined;
    } & Record<Exclude<keyof I, keyof KafkaSaslSecurity>, never>>(object: I): KafkaSaslSecurity;
};
export declare const KafkaSource: {
    encode(message: KafkaSource, writer?: _m0.Writer): _m0.Writer;
    decode(input: _m0.Reader | Uint8Array, length?: number): KafkaSource;
    fromJSON(object: any): KafkaSource;
    toJSON(message: KafkaSource): unknown;
    fromPartial<I extends {
        connection?: {
            clusterId?: string | undefined;
            onPremise?: {
                brokerUrls?: string[] | undefined;
                subnetId?: string | undefined;
                tlsMode?: {
                    disabled?: {} | undefined;
                    enabled?: {
                        caCertificate?: string | undefined;
                    } | undefined;
                } | undefined;
            } | undefined;
        } | undefined;
        auth?: {
            sasl?: {
                user?: string | undefined;
                mechanism?: KafkaMechanism | undefined;
                password?: {
                    raw?: string | undefined;
                } | undefined;
            } | undefined;
            noAuth?: {} | undefined;
        } | undefined;
        securityGroups?: string[] | undefined;
        topicName?: string | undefined;
        transformer?: {
            cloudFunction?: string | undefined;
            numberOfRetries?: number | undefined;
            bufferSize?: string | undefined;
            bufferFlushInterval?: string | undefined;
            invocationTimeout?: string | undefined;
            serviceAccountId?: string | undefined;
        } | undefined;
        parser?: {
            jsonParser?: {
                dataSchema?: {
                    jsonFields?: string | undefined;
                    fields?: {
                        fields?: {
                            name?: string | undefined;
                            type?: import("../../../../../yandex/cloud/datatransfer/v1/endpoint/common").ColumnType | undefined;
                            key?: boolean | undefined;
                            required?: boolean | undefined;
                            path?: string | undefined;
                        }[] | undefined;
                    } | undefined;
                } | undefined;
                nullKeysAllowed?: boolean | undefined;
                addRestColumn?: boolean | undefined;
                unescapeStringValues?: boolean | undefined;
            } | undefined;
            auditTrailsV1Parser?: {} | undefined;
            cloudLoggingParser?: {} | undefined;
            tskvParser?: {
                dataSchema?: {
                    jsonFields?: string | undefined;
                    fields?: {
                        fields?: {
                            name?: string | undefined;
                            type?: import("../../../../../yandex/cloud/datatransfer/v1/endpoint/common").ColumnType | undefined;
                            key?: boolean | undefined;
                            required?: boolean | undefined;
                            path?: string | undefined;
                        }[] | undefined;
                    } | undefined;
                } | undefined;
                nullKeysAllowed?: boolean | undefined;
                addRestColumn?: boolean | undefined;
                unescapeStringValues?: boolean | undefined;
            } | undefined;
        } | undefined;
        topicNames?: string[] | undefined;
    } & {
        connection?: ({
            clusterId?: string | undefined;
            onPremise?: {
                brokerUrls?: string[] | undefined;
                subnetId?: string | undefined;
                tlsMode?: {
                    disabled?: {} | undefined;
                    enabled?: {
                        caCertificate?: string | undefined;
                    } | undefined;
                } | undefined;
            } | undefined;
        } & {
            clusterId?: string | undefined;
            onPremise?: ({
                brokerUrls?: string[] | undefined;
                subnetId?: string | undefined;
                tlsMode?: {
                    disabled?: {} | undefined;
                    enabled?: {
                        caCertificate?: string | undefined;
                    } | undefined;
                } | undefined;
            } & {
                brokerUrls?: (string[] & string[] & Record<Exclude<keyof I["connection"]["onPremise"]["brokerUrls"], keyof string[]>, never>) | undefined;
                subnetId?: string | undefined;
                tlsMode?: ({
                    disabled?: {} | undefined;
                    enabled?: {
                        caCertificate?: string | undefined;
                    } | undefined;
                } & {
                    disabled?: ({} & {} & Record<Exclude<keyof I["connection"]["onPremise"]["tlsMode"]["disabled"], never>, never>) | undefined;
                    enabled?: ({
                        caCertificate?: string | undefined;
                    } & {
                        caCertificate?: string | undefined;
                    } & Record<Exclude<keyof I["connection"]["onPremise"]["tlsMode"]["enabled"], "caCertificate">, never>) | undefined;
                } & Record<Exclude<keyof I["connection"]["onPremise"]["tlsMode"], keyof TLSMode>, never>) | undefined;
            } & Record<Exclude<keyof I["connection"]["onPremise"], keyof OnPremiseKafka>, never>) | undefined;
        } & Record<Exclude<keyof I["connection"], keyof KafkaConnectionOptions>, never>) | undefined;
        auth?: ({
            sasl?: {
                user?: string | undefined;
                mechanism?: KafkaMechanism | undefined;
                password?: {
                    raw?: string | undefined;
                } | undefined;
            } | undefined;
            noAuth?: {} | undefined;
        } & {
            sasl?: ({
                user?: string | undefined;
                mechanism?: KafkaMechanism | undefined;
                password?: {
                    raw?: string | undefined;
                } | undefined;
            } & {
                user?: string | undefined;
                mechanism?: KafkaMechanism | undefined;
                password?: ({
                    raw?: string | undefined;
                } & {
                    raw?: string | undefined;
                } & Record<Exclude<keyof I["auth"]["sasl"]["password"], "raw">, never>) | undefined;
            } & Record<Exclude<keyof I["auth"]["sasl"], keyof KafkaSaslSecurity>, never>) | undefined;
            noAuth?: ({} & {} & Record<Exclude<keyof I["auth"]["noAuth"], never>, never>) | undefined;
        } & Record<Exclude<keyof I["auth"], keyof KafkaAuth>, never>) | undefined;
        securityGroups?: (string[] & string[] & Record<Exclude<keyof I["securityGroups"], keyof string[]>, never>) | undefined;
        topicName?: string | undefined;
        transformer?: ({
            cloudFunction?: string | undefined;
            numberOfRetries?: number | undefined;
            bufferSize?: string | undefined;
            bufferFlushInterval?: string | undefined;
            invocationTimeout?: string | undefined;
            serviceAccountId?: string | undefined;
        } & {
            cloudFunction?: string | undefined;
            numberOfRetries?: number | undefined;
            bufferSize?: string | undefined;
            bufferFlushInterval?: string | undefined;
            invocationTimeout?: string | undefined;
            serviceAccountId?: string | undefined;
        } & Record<Exclude<keyof I["transformer"], keyof DataTransformationOptions>, never>) | undefined;
        parser?: ({
            jsonParser?: {
                dataSchema?: {
                    jsonFields?: string | undefined;
                    fields?: {
                        fields?: {
                            name?: string | undefined;
                            type?: import("../../../../../yandex/cloud/datatransfer/v1/endpoint/common").ColumnType | undefined;
                            key?: boolean | undefined;
                            required?: boolean | undefined;
                            path?: string | undefined;
                        }[] | undefined;
                    } | undefined;
                } | undefined;
                nullKeysAllowed?: boolean | undefined;
                addRestColumn?: boolean | undefined;
                unescapeStringValues?: boolean | undefined;
            } | undefined;
            auditTrailsV1Parser?: {} | undefined;
            cloudLoggingParser?: {} | undefined;
            tskvParser?: {
                dataSchema?: {
                    jsonFields?: string | undefined;
                    fields?: {
                        fields?: {
                            name?: string | undefined;
                            type?: import("../../../../../yandex/cloud/datatransfer/v1/endpoint/common").ColumnType | undefined;
                            key?: boolean | undefined;
                            required?: boolean | undefined;
                            path?: string | undefined;
                        }[] | undefined;
                    } | undefined;
                } | undefined;
                nullKeysAllowed?: boolean | undefined;
                addRestColumn?: boolean | undefined;
                unescapeStringValues?: boolean | undefined;
            } | undefined;
        } & {
            jsonParser?: ({
                dataSchema?: {
                    jsonFields?: string | undefined;
                    fields?: {
                        fields?: {
                            name?: string | undefined;
                            type?: import("../../../../../yandex/cloud/datatransfer/v1/endpoint/common").ColumnType | undefined;
                            key?: boolean | undefined;
                            required?: boolean | undefined;
                            path?: string | undefined;
                        }[] | undefined;
                    } | undefined;
                } | undefined;
                nullKeysAllowed?: boolean | undefined;
                addRestColumn?: boolean | undefined;
                unescapeStringValues?: boolean | undefined;
            } & {
                dataSchema?: ({
                    jsonFields?: string | undefined;
                    fields?: {
                        fields?: {
                            name?: string | undefined;
                            type?: import("../../../../../yandex/cloud/datatransfer/v1/endpoint/common").ColumnType | undefined;
                            key?: boolean | undefined;
                            required?: boolean | undefined;
                            path?: string | undefined;
                        }[] | undefined;
                    } | undefined;
                } & {
                    jsonFields?: string | undefined;
                    fields?: ({
                        fields?: {
                            name?: string | undefined;
                            type?: import("../../../../../yandex/cloud/datatransfer/v1/endpoint/common").ColumnType | undefined;
                            key?: boolean | undefined;
                            required?: boolean | undefined;
                            path?: string | undefined;
                        }[] | undefined;
                    } & {
                        fields?: ({
                            name?: string | undefined;
                            type?: import("../../../../../yandex/cloud/datatransfer/v1/endpoint/common").ColumnType | undefined;
                            key?: boolean | undefined;
                            required?: boolean | undefined;
                            path?: string | undefined;
                        }[] & ({
                            name?: string | undefined;
                            type?: import("../../../../../yandex/cloud/datatransfer/v1/endpoint/common").ColumnType | undefined;
                            key?: boolean | undefined;
                            required?: boolean | undefined;
                            path?: string | undefined;
                        } & {
                            name?: string | undefined;
                            type?: import("../../../../../yandex/cloud/datatransfer/v1/endpoint/common").ColumnType | undefined;
                            key?: boolean | undefined;
                            required?: boolean | undefined;
                            path?: string | undefined;
                        } & Record<Exclude<keyof I["parser"]["jsonParser"]["dataSchema"]["fields"]["fields"][number], keyof import("../../../../../yandex/cloud/datatransfer/v1/endpoint/common").ColSchema>, never>)[] & Record<Exclude<keyof I["parser"]["jsonParser"]["dataSchema"]["fields"]["fields"], keyof {
                            name?: string | undefined;
                            type?: import("../../../../../yandex/cloud/datatransfer/v1/endpoint/common").ColumnType | undefined;
                            key?: boolean | undefined;
                            required?: boolean | undefined;
                            path?: string | undefined;
                        }[]>, never>) | undefined;
                    } & Record<Exclude<keyof I["parser"]["jsonParser"]["dataSchema"]["fields"], "fields">, never>) | undefined;
                } & Record<Exclude<keyof I["parser"]["jsonParser"]["dataSchema"], keyof import("../../../../../yandex/cloud/datatransfer/v1/endpoint/common").DataSchema>, never>) | undefined;
                nullKeysAllowed?: boolean | undefined;
                addRestColumn?: boolean | undefined;
                unescapeStringValues?: boolean | undefined;
            } & Record<Exclude<keyof I["parser"]["jsonParser"], keyof import("../../../../../yandex/cloud/datatransfer/v1/endpoint/parsers").GenericParserCommon>, never>) | undefined;
            auditTrailsV1Parser?: ({} & {} & Record<Exclude<keyof I["parser"]["auditTrailsV1Parser"], never>, never>) | undefined;
            cloudLoggingParser?: ({} & {} & Record<Exclude<keyof I["parser"]["cloudLoggingParser"], never>, never>) | undefined;
            tskvParser?: ({
                dataSchema?: {
                    jsonFields?: string | undefined;
                    fields?: {
                        fields?: {
                            name?: string | undefined;
                            type?: import("../../../../../yandex/cloud/datatransfer/v1/endpoint/common").ColumnType | undefined;
                            key?: boolean | undefined;
                            required?: boolean | undefined;
                            path?: string | undefined;
                        }[] | undefined;
                    } | undefined;
                } | undefined;
                nullKeysAllowed?: boolean | undefined;
                addRestColumn?: boolean | undefined;
                unescapeStringValues?: boolean | undefined;
            } & {
                dataSchema?: ({
                    jsonFields?: string | undefined;
                    fields?: {
                        fields?: {
                            name?: string | undefined;
                            type?: import("../../../../../yandex/cloud/datatransfer/v1/endpoint/common").ColumnType | undefined;
                            key?: boolean | undefined;
                            required?: boolean | undefined;
                            path?: string | undefined;
                        }[] | undefined;
                    } | undefined;
                } & {
                    jsonFields?: string | undefined;
                    fields?: ({
                        fields?: {
                            name?: string | undefined;
                            type?: import("../../../../../yandex/cloud/datatransfer/v1/endpoint/common").ColumnType | undefined;
                            key?: boolean | undefined;
                            required?: boolean | undefined;
                            path?: string | undefined;
                        }[] | undefined;
                    } & {
                        fields?: ({
                            name?: string | undefined;
                            type?: import("../../../../../yandex/cloud/datatransfer/v1/endpoint/common").ColumnType | undefined;
                            key?: boolean | undefined;
                            required?: boolean | undefined;
                            path?: string | undefined;
                        }[] & ({
                            name?: string | undefined;
                            type?: import("../../../../../yandex/cloud/datatransfer/v1/endpoint/common").ColumnType | undefined;
                            key?: boolean | undefined;
                            required?: boolean | undefined;
                            path?: string | undefined;
                        } & {
                            name?: string | undefined;
                            type?: import("../../../../../yandex/cloud/datatransfer/v1/endpoint/common").ColumnType | undefined;
                            key?: boolean | undefined;
                            required?: boolean | undefined;
                            path?: string | undefined;
                        } & Record<Exclude<keyof I["parser"]["tskvParser"]["dataSchema"]["fields"]["fields"][number], keyof import("../../../../../yandex/cloud/datatransfer/v1/endpoint/common").ColSchema>, never>)[] & Record<Exclude<keyof I["parser"]["tskvParser"]["dataSchema"]["fields"]["fields"], keyof {
                            name?: string | undefined;
                            type?: import("../../../../../yandex/cloud/datatransfer/v1/endpoint/common").ColumnType | undefined;
                            key?: boolean | undefined;
                            required?: boolean | undefined;
                            path?: string | undefined;
                        }[]>, never>) | undefined;
                    } & Record<Exclude<keyof I["parser"]["tskvParser"]["dataSchema"]["fields"], "fields">, never>) | undefined;
                } & Record<Exclude<keyof I["parser"]["tskvParser"]["dataSchema"], keyof import("../../../../../yandex/cloud/datatransfer/v1/endpoint/common").DataSchema>, never>) | undefined;
                nullKeysAllowed?: boolean | undefined;
                addRestColumn?: boolean | undefined;
                unescapeStringValues?: boolean | undefined;
            } & Record<Exclude<keyof I["parser"]["tskvParser"], keyof import("../../../../../yandex/cloud/datatransfer/v1/endpoint/parsers").GenericParserCommon>, never>) | undefined;
        } & Record<Exclude<keyof I["parser"], keyof Parser>, never>) | undefined;
        topicNames?: (string[] & string[] & Record<Exclude<keyof I["topicNames"], keyof string[]>, never>) | undefined;
    } & Record<Exclude<keyof I, keyof KafkaSource>, never>>(object: I): KafkaSource;
};
export declare const KafkaTarget: {
    encode(message: KafkaTarget, writer?: _m0.Writer): _m0.Writer;
    decode(input: _m0.Reader | Uint8Array, length?: number): KafkaTarget;
    fromJSON(object: any): KafkaTarget;
    toJSON(message: KafkaTarget): unknown;
    fromPartial<I extends {
        connection?: {
            clusterId?: string | undefined;
            onPremise?: {
                brokerUrls?: string[] | undefined;
                subnetId?: string | undefined;
                tlsMode?: {
                    disabled?: {} | undefined;
                    enabled?: {
                        caCertificate?: string | undefined;
                    } | undefined;
                } | undefined;
            } | undefined;
        } | undefined;
        auth?: {
            sasl?: {
                user?: string | undefined;
                mechanism?: KafkaMechanism | undefined;
                password?: {
                    raw?: string | undefined;
                } | undefined;
            } | undefined;
            noAuth?: {} | undefined;
        } | undefined;
        securityGroups?: string[] | undefined;
        topicSettings?: {
            topic?: {
                topicName?: string | undefined;
                saveTxOrder?: boolean | undefined;
            } | undefined;
            topicPrefix?: string | undefined;
        } | undefined;
        serializer?: {
            serializerAuto?: {} | undefined;
            serializerJson?: {} | undefined;
            serializerDebezium?: {
                serializerParameters?: {
                    key?: string | undefined;
                    value?: string | undefined;
                }[] | undefined;
            } | undefined;
        } | undefined;
    } & {
        connection?: ({
            clusterId?: string | undefined;
            onPremise?: {
                brokerUrls?: string[] | undefined;
                subnetId?: string | undefined;
                tlsMode?: {
                    disabled?: {} | undefined;
                    enabled?: {
                        caCertificate?: string | undefined;
                    } | undefined;
                } | undefined;
            } | undefined;
        } & {
            clusterId?: string | undefined;
            onPremise?: ({
                brokerUrls?: string[] | undefined;
                subnetId?: string | undefined;
                tlsMode?: {
                    disabled?: {} | undefined;
                    enabled?: {
                        caCertificate?: string | undefined;
                    } | undefined;
                } | undefined;
            } & {
                brokerUrls?: (string[] & string[] & Record<Exclude<keyof I["connection"]["onPremise"]["brokerUrls"], keyof string[]>, never>) | undefined;
                subnetId?: string | undefined;
                tlsMode?: ({
                    disabled?: {} | undefined;
                    enabled?: {
                        caCertificate?: string | undefined;
                    } | undefined;
                } & {
                    disabled?: ({} & {} & Record<Exclude<keyof I["connection"]["onPremise"]["tlsMode"]["disabled"], never>, never>) | undefined;
                    enabled?: ({
                        caCertificate?: string | undefined;
                    } & {
                        caCertificate?: string | undefined;
                    } & Record<Exclude<keyof I["connection"]["onPremise"]["tlsMode"]["enabled"], "caCertificate">, never>) | undefined;
                } & Record<Exclude<keyof I["connection"]["onPremise"]["tlsMode"], keyof TLSMode>, never>) | undefined;
            } & Record<Exclude<keyof I["connection"]["onPremise"], keyof OnPremiseKafka>, never>) | undefined;
        } & Record<Exclude<keyof I["connection"], keyof KafkaConnectionOptions>, never>) | undefined;
        auth?: ({
            sasl?: {
                user?: string | undefined;
                mechanism?: KafkaMechanism | undefined;
                password?: {
                    raw?: string | undefined;
                } | undefined;
            } | undefined;
            noAuth?: {} | undefined;
        } & {
            sasl?: ({
                user?: string | undefined;
                mechanism?: KafkaMechanism | undefined;
                password?: {
                    raw?: string | undefined;
                } | undefined;
            } & {
                user?: string | undefined;
                mechanism?: KafkaMechanism | undefined;
                password?: ({
                    raw?: string | undefined;
                } & {
                    raw?: string | undefined;
                } & Record<Exclude<keyof I["auth"]["sasl"]["password"], "raw">, never>) | undefined;
            } & Record<Exclude<keyof I["auth"]["sasl"], keyof KafkaSaslSecurity>, never>) | undefined;
            noAuth?: ({} & {} & Record<Exclude<keyof I["auth"]["noAuth"], never>, never>) | undefined;
        } & Record<Exclude<keyof I["auth"], keyof KafkaAuth>, never>) | undefined;
        securityGroups?: (string[] & string[] & Record<Exclude<keyof I["securityGroups"], keyof string[]>, never>) | undefined;
        topicSettings?: ({
            topic?: {
                topicName?: string | undefined;
                saveTxOrder?: boolean | undefined;
            } | undefined;
            topicPrefix?: string | undefined;
        } & {
            topic?: ({
                topicName?: string | undefined;
                saveTxOrder?: boolean | undefined;
            } & {
                topicName?: string | undefined;
                saveTxOrder?: boolean | undefined;
            } & Record<Exclude<keyof I["topicSettings"]["topic"], keyof KafkaTargetTopic>, never>) | undefined;
            topicPrefix?: string | undefined;
        } & Record<Exclude<keyof I["topicSettings"], keyof KafkaTargetTopicSettings>, never>) | undefined;
        serializer?: ({
            serializerAuto?: {} | undefined;
            serializerJson?: {} | undefined;
            serializerDebezium?: {
                serializerParameters?: {
                    key?: string | undefined;
                    value?: string | undefined;
                }[] | undefined;
            } | undefined;
        } & {
            serializerAuto?: ({} & {} & Record<Exclude<keyof I["serializer"]["serializerAuto"], never>, never>) | undefined;
            serializerJson?: ({} & {} & Record<Exclude<keyof I["serializer"]["serializerJson"], never>, never>) | undefined;
            serializerDebezium?: ({
                serializerParameters?: {
                    key?: string | undefined;
                    value?: string | undefined;
                }[] | undefined;
            } & {
                serializerParameters?: ({
                    key?: string | undefined;
                    value?: string | undefined;
                }[] & ({
                    key?: string | undefined;
                    value?: string | undefined;
                } & {
                    key?: string | undefined;
                    value?: string | undefined;
                } & Record<Exclude<keyof I["serializer"]["serializerDebezium"]["serializerParameters"][number], keyof import("../../../../../yandex/cloud/datatransfer/v1/endpoint/serializers").DebeziumSerializerParameter>, never>)[] & Record<Exclude<keyof I["serializer"]["serializerDebezium"]["serializerParameters"], keyof {
                    key?: string | undefined;
                    value?: string | undefined;
                }[]>, never>) | undefined;
            } & Record<Exclude<keyof I["serializer"]["serializerDebezium"], "serializerParameters">, never>) | undefined;
        } & Record<Exclude<keyof I["serializer"], keyof Serializer>, never>) | undefined;
    } & Record<Exclude<keyof I, keyof KafkaTarget>, never>>(object: I): KafkaTarget;
};
export declare const KafkaTargetTopicSettings: {
    encode(message: KafkaTargetTopicSettings, writer?: _m0.Writer): _m0.Writer;
    decode(input: _m0.Reader | Uint8Array, length?: number): KafkaTargetTopicSettings;
    fromJSON(object: any): KafkaTargetTopicSettings;
    toJSON(message: KafkaTargetTopicSettings): unknown;
    fromPartial<I extends {
        topic?: {
            topicName?: string | undefined;
            saveTxOrder?: boolean | undefined;
        } | undefined;
        topicPrefix?: string | undefined;
    } & {
        topic?: ({
            topicName?: string | undefined;
            saveTxOrder?: boolean | undefined;
        } & {
            topicName?: string | undefined;
            saveTxOrder?: boolean | undefined;
        } & Record<Exclude<keyof I["topic"], keyof KafkaTargetTopic>, never>) | undefined;
        topicPrefix?: string | undefined;
    } & Record<Exclude<keyof I, keyof KafkaTargetTopicSettings>, never>>(object: I): KafkaTargetTopicSettings;
};
export declare const KafkaTargetTopic: {
    encode(message: KafkaTargetTopic, writer?: _m0.Writer): _m0.Writer;
    decode(input: _m0.Reader | Uint8Array, length?: number): KafkaTargetTopic;
    fromJSON(object: any): KafkaTargetTopic;
    toJSON(message: KafkaTargetTopic): unknown;
    fromPartial<I extends {
        topicName?: string | undefined;
        saveTxOrder?: boolean | undefined;
    } & {
        topicName?: string | undefined;
        saveTxOrder?: boolean | undefined;
    } & Record<Exclude<keyof I, keyof KafkaTargetTopic>, never>>(object: I): KafkaTargetTopic;
};
type Builtin = Date | Function | Uint8Array | string | number | boolean | undefined;
export type DeepPartial<T> = T extends Builtin ? T : T extends Array<infer U> ? Array<DeepPartial<U>> : T extends ReadonlyArray<infer U> ? ReadonlyArray<DeepPartial<U>> : T extends {} ? {
    [K in keyof T]?: DeepPartial<T[K]>;
} : Partial<T>;
type KeysOfUnion<T> = T extends T ? keyof T : never;
export type Exact<P, I extends P> = P extends Builtin ? P : P & {
    [K in keyof P]: Exact<P[K], I[K]>;
} & Record<Exclude<keyof I, KeysOfUnion<P>>, never>;
export {};