[Yandex Cloud documentation](../../../../index.md) > [Yandex Managed Service for Apache Kafka®](../../../index.md) > API reference > [gRPC](../index.md) > [Connector](index.md) > Get

# Managed Service for Apache Kafka® API, gRPC: ConnectorService.Get

Returns information about an Apache Kafka® connector.

## gRPC request

**rpc Get ([GetConnectorRequest](#yandex.cloud.mdb.kafka.v1.GetConnectorRequest)) returns ([Connector](#yandex.cloud.mdb.kafka.v1.Connector))**

## GetConnectorRequest {#yandex.cloud.mdb.kafka.v1.GetConnectorRequest}

```json
{
  "cluster_id": "string",
  "connector_name": "string"
}
```

#|
||Field | Description ||
|| cluster_id | **string**

Required field. ID of the Apache Kafka® cluster the connector belongs to.
To get this ID, make a [ClusterService.List](../Cluster/list.md#List) request.

The maximum string length in characters is 50. ||
|| connector_name | **string**

Required field. Name of the Apache Kafka® connector to return information about.
To get this name, make a [ConnectorService.List](list.md#List) request.

The maximum string length in characters is 256. Value must match the regular expression ` [-_.a-zA-Z0-9]* `. ||
|#

## Connector {#yandex.cloud.mdb.kafka.v1.Connector}

```json
{
  "name": "string",
  "tasks_max": "google.protobuf.Int64Value",
  "properties": "map<string, string>",
  "health": "Health",
  "status": "Status",
  "cluster_id": "string",
  // Includes only one of the fields `connector_config_mirrormaker`, `connector_config_s3_sink`, `connector_config_iceberg_sink`
  "connector_config_mirrormaker": {
    "source_cluster": {
      "alias": "string",
      // Includes only one of the fields `this_cluster`, `external_cluster`
      "this_cluster": "ThisCluster",
      "external_cluster": {
        "bootstrap_servers": "string",
        "sasl_username": "string",
        "sasl_mechanism": "string",
        "security_protocol": "string"
      }
      // end of the list of possible fields
    },
    "target_cluster": {
      "alias": "string",
      // Includes only one of the fields `this_cluster`, `external_cluster`
      "this_cluster": "ThisCluster",
      "external_cluster": {
        "bootstrap_servers": "string",
        "sasl_username": "string",
        "sasl_mechanism": "string",
        "security_protocol": "string"
      }
      // end of the list of possible fields
    },
    "topics": "string",
    "replication_factor": "google.protobuf.Int64Value"
  },
  "connector_config_s3_sink": {
    "topics": "string",
    "file_compression_type": "string",
    "file_max_records": "google.protobuf.Int64Value",
    "s3_connection": {
      "bucket_name": "string",
      // Includes only one of the fields `external_s3`
      "external_s3": {
        "access_key_id": "string",
        "endpoint": "string",
        "region": "string"
      }
      // end of the list of possible fields
    }
  },
  "connector_config_iceberg_sink": {
    // Includes only one of the fields `topics`, `topics_regex`
    "topics": "string",
    "topics_regex": "string",
    // end of the list of possible fields
    "control_topic": "string",
    "metastore_connection": {
      "catalog_uri": "string",
      "warehouse": "string"
    },
    "s3_connection": {
      // Includes only one of the fields `external_s3`
      "external_s3": {
        "access_key_id": "string",
        "endpoint": "string",
        "region": "string"
      }
      // end of the list of possible fields
    },
    // Includes only one of the fields `static_tables`, `dynamic_tables`
    "static_tables": {
      "tables": "string"
    },
    "dynamic_tables": {
      "route_field": "string"
    },
    // end of the list of possible fields
    "tables_config": {
      "default_commit_branch": "string",
      "default_id_columns": "string",
      "default_partition_by": "string",
      "evolve_schema_enabled": "bool",
      "schema_force_optional": "bool",
      "schema_case_insensitive": "bool"
    },
    "control_config": {
      "group_id_prefix": "string",
      "commit_interval_ms": "google.protobuf.Int64Value",
      "commit_timeout_ms": "google.protobuf.Int64Value",
      "commit_threads": "google.protobuf.Int64Value",
      "transactional_prefix": "string"
    }
  }
  // end of the list of possible fields
}
```

#|
||Field | Description ||
|| name | **string**

Name of the connector. ||
|| tasks_max | **[google.protobuf.Int64Value](https://developers.google.com/protocol-buffers/docs/reference/csharp/class/google/protobuf/well-known-types/int64-value)**

Maximum number of connector tasks. Default value is the number of brokers. ||
|| properties | **object** (map<**string**, **string**>)

A set of properties passed to Managed Service for Apache Kafka® with the connector configuration.
Example: `sync.topics.config.enabled: true`. ||
|| health | enum **Health**

Connector health.

- `HEALTH_UNKNOWN`: Health of the connector is unknown.
- `ALIVE`: Connector is running.
- `DEAD`: Connector has failed to start. ||
|| status | enum **Status**

Current status of the connector.

- `STATUS_UNKNOWN`: Connector state is unknown.
- `RUNNING`: Connector is running normally.
- `ERROR`: Connector has encountered a problem and cannot operate.
- `PAUSED`: Connector is paused. ||
|| cluster_id | **string**

ID of the Apache Kafka® cluster that the connector belongs to. ||
|| connector_config_mirrormaker | **[ConnectorConfigMirrorMaker](#yandex.cloud.mdb.kafka.v1.ConnectorConfigMirrorMaker)**

Configuration of the MirrorMaker connector.

Includes only one of the fields `connector_config_mirrormaker`, `connector_config_s3_sink`, `connector_config_iceberg_sink`.

Additional settings for the connector. ||
|| connector_config_s3_sink | **[ConnectorConfigS3Sink](#yandex.cloud.mdb.kafka.v1.ConnectorConfigS3Sink)**

Configuration of S3-Sink connector.

Includes only one of the fields `connector_config_mirrormaker`, `connector_config_s3_sink`, `connector_config_iceberg_sink`.

Additional settings for the connector. ||
|| connector_config_iceberg_sink | **[ConnectorConfigIcebergSink](#yandex.cloud.mdb.kafka.v1.ConnectorConfigIcebergSink)**

Configuration of Iceberg Sink connector.

Includes only one of the fields `connector_config_mirrormaker`, `connector_config_s3_sink`, `connector_config_iceberg_sink`.

Additional settings for the connector. ||
|#

## ConnectorConfigMirrorMaker {#yandex.cloud.mdb.kafka.v1.ConnectorConfigMirrorMaker}

#|
||Field | Description ||
|| source_cluster | **[ClusterConnection](#yandex.cloud.mdb.kafka.v1.ClusterConnection)**

Source cluster connection configuration. ||
|| target_cluster | **[ClusterConnection](#yandex.cloud.mdb.kafka.v1.ClusterConnection)**

Target cluster connection configuration. ||
|| topics | **string**

List of Kafka topics, separated by `,`. ||
|| replication_factor | **[google.protobuf.Int64Value](https://developers.google.com/protocol-buffers/docs/reference/csharp/class/google/protobuf/well-known-types/int64-value)**

Replication factor for automatically created topics. ||
|#

## ClusterConnection {#yandex.cloud.mdb.kafka.v1.ClusterConnection}

#|
||Field | Description ||
|| alias | **string**

Alias of cluster connection configuration.
Examples: `source`, `target`. ||
|| this_cluster | **[ThisCluster](#yandex.cloud.mdb.kafka.v1.ThisCluster)**

Connection configuration of the cluster the connector belongs to. As all credentials are already known, leave this parameter empty.

Includes only one of the fields `this_cluster`, `external_cluster`.

Type of connection to Apache Kafka® cluster. ||
|| external_cluster | **[ExternalClusterConnection](#yandex.cloud.mdb.kafka.v1.ExternalClusterConnection)**

Configuration of connection to an external cluster with all the necessary credentials.

Includes only one of the fields `this_cluster`, `external_cluster`.

Type of connection to Apache Kafka® cluster. ||
|#

## ThisCluster {#yandex.cloud.mdb.kafka.v1.ThisCluster}

#|
||Field | Description ||
|| Empty | > ||
|#

## ExternalClusterConnection {#yandex.cloud.mdb.kafka.v1.ExternalClusterConnection}

#|
||Field | Description ||
|| bootstrap_servers | **string**

List of bootstrap servers of the cluster, separated by `,`. ||
|| sasl_username | **string**

SASL username to use for connection to the cluster. ||
|| sasl_mechanism | **string**

SASL mechanism to use for connection to the cluster. ||
|| security_protocol | **string**

Security protocol to use for connection to the cluster. ||
|#

## ConnectorConfigS3Sink {#yandex.cloud.mdb.kafka.v1.ConnectorConfigS3Sink}

An Apache Kafka® S3-Sink
connector resource.

#|
||Field | Description ||
|| topics | **string**

List of Kafka topics, separated by ','. ||
|| file_compression_type | **string**

The compression type used for files put on GCS.
The supported values are: `gzip`, `snappy`, `zstd`, `none`.
Optional, the default is `none`. ||
|| file_max_records | **[google.protobuf.Int64Value](https://developers.google.com/protocol-buffers/docs/reference/csharp/class/google/protobuf/well-known-types/int64-value)**

Max records per file. ||
|| s3_connection | **[S3Connection](#yandex.cloud.mdb.kafka.v1.S3Connection)**

Credentials for connecting to S3 storage. ||
|#

## S3Connection {#yandex.cloud.mdb.kafka.v1.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.

#|
||Field | Description ||
|| bucket_name | **string**

Name of the bucket. ||
|| external_s3 | **[ExternalS3Storage](#yandex.cloud.mdb.kafka.v1.ExternalS3Storage)**

Configuration for connection to S3 storage.

Includes only one of the fields `external_s3`. ||
|#

## ExternalS3Storage {#yandex.cloud.mdb.kafka.v1.ExternalS3Storage}

#|
||Field | Description ||
|| access_key_id | **string**

ID of the AWS access key. ||
|| endpoint | **string**

S3 endpoint. ||
|| region | **string**

AWS region. Default is 'us-east-1'. ||
|#

## ConnectorConfigIcebergSink {#yandex.cloud.mdb.kafka.v1.ConnectorConfigIcebergSink}

Resource for Kafka Iceberg Sink Connector.

#|
||Field | Description ||
|| topics | **string**

List of Kafka topics, separated by ','.

Includes only one of the fields `topics`, `topics_regex`. ||
|| topics_regex | **string**

Regex of Kafka topics.

Includes only one of the fields `topics`, `topics_regex`. ||
|| control_topic | **string**

Control topic name for Iceberg connector. ||
|| metastore_connection | **[MetastoreConnection](#yandex.cloud.mdb.kafka.v1.MetastoreConnection)**

Credentials for connecting to Managed Hive Metastore. ||
|| s3_connection | **[IcebergS3Connection](#yandex.cloud.mdb.kafka.v1.IcebergS3Connection)**

Credentials for connecting to S3 storage. ||
|| static_tables | **[StaticTables](#yandex.cloud.mdb.kafka.v1.StaticTables)**

Static table routing

Includes only one of the fields `static_tables`, `dynamic_tables`.

Table routing strategy ||
|| dynamic_tables | **[DynamicTables](#yandex.cloud.mdb.kafka.v1.DynamicTables)**

Dynamic table routing

Includes only one of the fields `static_tables`, `dynamic_tables`.

Table routing strategy ||
|| tables_config | **[IcebergTablesConfig](#yandex.cloud.mdb.kafka.v1.IcebergTablesConfig)**

Optional table settings ||
|| control_config | **[IcebergControl](#yandex.cloud.mdb.kafka.v1.IcebergControl)**

Optional control settings ||
|#

## MetastoreConnection {#yandex.cloud.mdb.kafka.v1.MetastoreConnection}

#|
||Field | Description ||
|| catalog_uri | **string**

Thrift URI of Hive Metastore
Format: "thrift://host:9083" ||
|| warehouse | **string**

Warehouse root directory in S3
Format: "s3a://bucket-name/path/to/warehouse"
Can be any path within the bucket, not necessarily "/warehouse" ||
|#

## IcebergS3Connection {#yandex.cloud.mdb.kafka.v1.IcebergS3Connection}

Resource for IcebergS3Connection -
settings of connection to AWS-compatible S3 storage, that
are target of Kafka Iceberg-connectors.
YC Object Storage is AWS-compatible.

#|
||Field | Description ||
|| external_s3 | **[ExternalIcebergS3Storage](#yandex.cloud.mdb.kafka.v1.ExternalIcebergS3Storage)**

Configuration for connection to S3 storage.

Includes only one of the fields `external_s3`. ||
|#

## ExternalIcebergS3Storage {#yandex.cloud.mdb.kafka.v1.ExternalIcebergS3Storage}

#|
||Field | Description ||
|| access_key_id | **string**

ID of the AWS access key. ||
|| endpoint | **string**

S3 endpoint. ||
|| region | **string**

AWS region. Default is 'us-east-1'. ||
|#

## StaticTables {#yandex.cloud.mdb.kafka.v1.StaticTables}

#|
||Field | Description ||
|| tables | **string**

List of tables, separated by ','. ||
|#

## DynamicTables {#yandex.cloud.mdb.kafka.v1.DynamicTables}

#|
||Field | Description ||
|| route_field | **string**

Field in the message to define the target table
The iceberg.tables.dynamic-enabled field is set to true ||
|#

## IcebergTablesConfig {#yandex.cloud.mdb.kafka.v1.IcebergTablesConfig}

#|
||Field | Description ||
|| default_commit_branch | **string**

Default Git-like branch name for Iceberg commits.
Default: "main" ||
|| default_id_columns | **string**

List of columns used as identifiers for upsert operations, separated by ','. ||
|| default_partition_by | **string**

Comma-separated list of columns or transform expressions for table partitioning.
Defines physical data layout for query optimization.
Examples:
- "date"
- "year,month"
- "year(timestamp),month(timestamp)"
- "days(timestamp)"
- "bucket(16,user_id)" ||
|| evolve_schema_enabled | **bool**

Enable automatic schema evolution.
Default: false ||
|| schema_force_optional | **bool**

Force all columns to be nullable (optional).
Default: false ||
|| schema_case_insensitive | **bool**

Enable case-insensitive field name matching.
Default: false ||
|#

## IcebergControl {#yandex.cloud.mdb.kafka.v1.IcebergControl}

#|
||Field | Description ||
|| group_id_prefix | **string**

Consumer group ID prefix for control topic.
Default: "cg-control" ||
|| commit_interval_ms | **[google.protobuf.Int64Value](https://developers.google.com/protocol-buffers/docs/reference/csharp/class/google/protobuf/well-known-types/int64-value)**

Interval between commits in milliseconds.
Default: 300000 (5 minutes) ||
|| commit_timeout_ms | **[google.protobuf.Int64Value](https://developers.google.com/protocol-buffers/docs/reference/csharp/class/google/protobuf/well-known-types/int64-value)**

Commit operation timeout in milliseconds.
Default: 30000 (30 seconds) ||
|| commit_threads | **[google.protobuf.Int64Value](https://developers.google.com/protocol-buffers/docs/reference/csharp/class/google/protobuf/well-known-types/int64-value)**

Number of threads for commit operations.
Default: cores * 2 ||
|| transactional_prefix | **string**

Prefix for transactional operations.
Default: "" ||
|#