Yandex Cloud
Search
Discuss with expertTry it for free
  • Customer Stories
  • Documentation
  • Blog
  • All Services
    • Cloud Interconnect
    • Cloud Backup
    • Cloud Registry
    • Yandex AI Studio
    • Compute Cloud
    • Object Storage
    • Managed Service for Kubernetes®
    • Yandex BareMetal
    • Smart Web Security
    • Security Deck
    • Managed Service for PostgreSQL
    • Managed Service for ClickHouse®
    • Monium
    • Cloud CDN
    • Network Load Balancer
    • Virtual Private Cloud
    • Cloud DNS
    • Application Load Balancer
    • Yandex Cloud Video
    • Stackland
    • Yandex Cloud Router
    • Yandex Managed Service for Trino
    • Managed Service for MySQL®
    • Managed Service for Valkey™
    • Managed Service for Apache Spark™
    • Yandex StoreDoc
    • Managed Service for OpenSearch
    • Managed Service for Apache Kafka®
    • Data Transfer
    • Yandex MPP Analytics Engine for PostgreSQL
    • Yandex Managed Service for Apache Airflow®
    • Data Processing
    • Yandex MetaData Hub
    • Managed Service for YDB
    • Managed Service for Sharded PostgreSQL
    • Managed Service for YTsaurus
    • Yandex WebSQL
    • DataLens
    • Yandex Search API
    • SpeechSense
    • SpeechKit
    • DataSphere
    • Vision OCR
    • Translate
    • Yandex Identity Hub
    • Key Management Service
    • Certificate Manager
    • Yandex Lockbox
    • Audit Trails
    • SmartCaptcha
    • Cloud Desktop
    • Yandex SIEM
    • SourceCraft Code Assistant
    • Container Registry
    • Managed Service for GitLab
    • Managed Service for Prometheus®
    • Cloud Functions
    • API Gateway
    • Yandex Cloud Postbox
    • Message Queue
    • Serverless Integrations
    • IoT Core
    • Data Streams
    • Serverless Containers
    • Cloud Notification Service
    • Yandex Query
    • Identity and Access Management
    • Yandex Cloud Console
    • Resource Manager
    • Yandex Cloud Billing
    • Yandex Cloud Quota Manager
    • Cloud Apps
  • System Status
  • Marketplace
    • Featured
    • Infrastructure & Network
    • Data Platform
    • AI for business
    • Security
    • DevOps tools
    • Serverless
    • Monitoring & Resources
  • All Solutions
    • By industry
    • By use case
    • Economics and Pricing
    • Security
    • Technical Support
    • Start testing with double trial credits
    • Cloud credits to scale your IT product
    • Gateway to Russia
    • Cloud for Startups
    • Center for Technologies and Society
    • Yandex Cloud Partner program
    • Price calculator
    • Pricing plans
  • Customer Stories
  • Documentation
  • Blog
© 2026 Direct Cursus Technology L.L.C.
Terraform in Yandex Cloud
  • Getting started
  • Setting up Yandex Cloud Terraform provider authentication
  • Solution library
    • Overview
    • Release notes
          • mdb_kafka_cluster
          • mdb_kafka_connector
          • mdb_kafka_topic
          • mdb_kafka_user

In this article:

  • Example usage
  • Arguments & Attributes Reference
  1. Terraform reference
  2. Resources
  3. Managed Service for Apache Kafka®
  4. Data Sources
  5. mdb_kafka_connector

yandex_mdb_kafka_connector (DataSource)

Written by
Yandex Cloud
Updated at September 23, 2026
View in Markdown
  • Example usage
  • Arguments & Attributes Reference

Get information about a connector of the Yandex Managed Kafka cluster. For more information, see the official documentation.

Example usageExample usage

//
// Get information about existing MDB Kafka Connector.
//
data "yandex_mdb_kafka_connector" "foo" {
  cluster_id = "some_cluster_id"
  name       = "test"
}

output "tasks_max" {
  value = data.yandex_mdb_kafka_connector.foo.tasks_max
}

Arguments & Attributes ReferenceArguments & Attributes Reference

  • cluster_id (Required)(String). The ID of the Kafka cluster.
  • connector_config_iceberg_sink (Read-Only) (List Of Object). Settings for Iceberg Sink connector.
    • control_config .
      • commit_interval_ms .
      • commit_threads .
      • commit_timeout_ms .
      • group_id_prefix .
      • transactional_prefix .
    • control_topic .
    • dynamic_tables .
      • route_field .
    • metastore_connection .
      • catalog_uri .
      • warehouse .
    • s3_connection .
      • external_s3 .
        • access_key_id .
        • endpoint .
        • region .
        • secret_access_key .
    • static_tables .
      • tables .
    • tables_config .
      • default_commit_branch .
      • default_id_columns .
      • default_partition_by .
      • evolve_schema_enabled .
      • schema_case_insensitive .
      • schema_force_optional .
    • topics .
    • topics_regex .
  • connector_config_mirrormaker (Read-Only) (List Of Object). Settings for MirrorMaker2 connector.
    • replication_factor .
    • source_cluster .
      • alias .
      • external_cluster .
        • bootstrap_servers .
        • sasl_mechanism .
        • sasl_password .
        • sasl_username .
        • security_protocol .
      • this_cluster .
    • target_cluster .
      • alias .
      • external_cluster .
        • bootstrap_servers .
        • sasl_mechanism .
        • sasl_password .
        • sasl_username .
        • security_protocol .
      • this_cluster .
    • topics .
  • connector_config_s3_sink (Read-Only) (List Of Object). Settings for S3 Sink connector.
    • file_compression_type .
    • file_max_records .
    • s3_connection .
      • bucket_name .
      • external_s3 .
        • access_key_id .
        • endpoint .
        • region .
        • secret_access_key .
    • topics .
  • id (String).
  • name (Required)(String). The resource name.
  • properties (Read-Only) (Map Of String). Additional properties for connector.
  • tasks_max (Read-Only) (Number). The number of the connector's parallel working tasks. Default is the number of brokers.

Was the article helpful?

Previous
mdb_kafka_cluster
Next
mdb_kafka_topic
© 2026 Direct Cursus Technology L.L.C.