{"id":12834,"date":"2026-10-09T00:00:28","date_gmt":"2026-10-09T07:00:28","guid":{"rendered":"https:\/\/devblogs.microsoft.com\/cosmosdb\/?p=12834"},"modified":"2026-10-02T07:49:08","modified_gmt":"2026-10-02T14:49:08","slug":"introducing-the-native-confluent-cloud-connector-experience-in-azure-cosmos-db","status":"publish","type":"post","link":"https:\/\/devblogs.microsoft.com\/cosmosdb\/introducing-the-native-confluent-cloud-connector-experience-in-azure-cosmos-db\/","title":{"rendered":"Introducing the Native Confluent Cloud Connector Experience in Azure Cosmos DB!"},"content":{"rendered":"<p><em>Co-authored with <strong>Praveen Raja P<\/strong><\/em><\/p>\n<p><div class=\"alert alert-success\"><p class=\"alert-divider\"><i class=\"fabric-icon fabric-icon--Lightbulb\"><\/i><strong>Quick hint<\/strong><\/p>Connectors run in a Confluent organization provisioned through <a href=\"https:\/\/learn.microsoft.com\/azure\/partner-solutions\/apache-kafka-confluent-cloud\/overview\"><strong>Apache Kafka &amp; Apache Flink on Confluent Cloud, an Azure Native Integrations service<\/strong><\/a>. The organization is managed as an Azure resource, uses Microsoft Entra ID single sign-on, and is billed through your Azure invoice.<\/p>\n<p>&nbsp;<\/p>\n<p>No organization yet? Select <strong>Create Confluent organization<\/strong> on the <strong>Integrations &gt; Apache Kafka on Confluent Cloud<\/strong> page to launch the <a href=\"https:\/\/learn.microsoft.com\/azure\/partner-solutions\/apache-kafka-confluent-cloud\/create\">creation experience<\/a> in place. Confluent also offers a free trial with credits to get started with the <strong>Confluent Cloud \u2013 Pay as you Go<\/strong> plan. Once the organization is created, it\u2019s selected automatically, so you can move straight to creating a connector.<\/div><\/p>\n<p>Azure Cosmos DB already includes a powerful event foundation: <a href=\"https:\/\/learn.microsoft.com\/azure\/cosmos-db\/change-feed\" target=\"_blank\" rel=\"noopener\">change feed<\/a> provides a durable, ordered record of item changes within each logical partition. It is ideal for reacting to operational data as it changes, building projections, and driving workflows directly from the database. Confluent Cloud adds a complementary event layer rather than replacing change feed. Kafka topics can carry database changes alongside explicit business events from many systems, retain them independently from the operational database, and let multiple consumer groups process and replay each stream at their own pace. Teams also gain Kafka\u2019s broad ecosystem for stream processing, integration, governance, and cross-system event distribution, while Azure Cosmos DB continues to serve globally distributed operational state with low latency.<\/p>\n<p>Together, they support data movement in both directions: publish Azure Cosmos DB changes to Kafka for independent downstream consumers, or project Kafka events into Azure Cosmos DB as application-ready views. This existing integration is backed by the <a title=\"\" draggable=\"false\" href=\"https:\/\/devblogs.microsoft.com\/cosmosdb\/confluent-cloud-releases-managed-v2-kafka-connector-for-azure-cosmos-db\/\" data-href=\"https:\/\/devblogs.microsoft.com\/cosmosdb\/confluent-cloud-releases-managed-v2-kafka-connector-for-azure-cosmos-db\/\">fully managed V2 Kafka connector for Azure Cosmos DB<\/a>, and today we are announcing a new native Azure portal experience. Connector discovery, resource selection, validation, and cluster creation can now happen directly from your Azure Cosmos DB account, without custom relay plumbing or switching between consoles.<\/p>\n<p><a href=\"https:\/\/devblogs.microsoft.com\/cosmosdb\/wp-content\/uploads\/sites\/52\/2026\/08\/event-sourcing-architecture.png\"><img decoding=\"async\" class=\"alignnone size-full wp-image-12835\" src=\"https:\/\/devblogs.microsoft.com\/cosmosdb\/wp-content\/uploads\/sites\/52\/2026\/08\/event-sourcing-architecture.png\" alt=\"event sourcing architecture image\" width=\"2484\" height=\"1416\" srcset=\"https:\/\/devblogs.microsoft.com\/cosmosdb\/wp-content\/uploads\/sites\/52\/2026\/08\/event-sourcing-architecture.png 2484w, https:\/\/devblogs.microsoft.com\/cosmosdb\/wp-content\/uploads\/sites\/52\/2026\/08\/event-sourcing-architecture-300x171.png 300w, https:\/\/devblogs.microsoft.com\/cosmosdb\/wp-content\/uploads\/sites\/52\/2026\/08\/event-sourcing-architecture-1024x584.png 1024w, https:\/\/devblogs.microsoft.com\/cosmosdb\/wp-content\/uploads\/sites\/52\/2026\/08\/event-sourcing-architecture-768x438.png 768w, https:\/\/devblogs.microsoft.com\/cosmosdb\/wp-content\/uploads\/sites\/52\/2026\/08\/event-sourcing-architecture-1536x876.png 1536w, https:\/\/devblogs.microsoft.com\/cosmosdb\/wp-content\/uploads\/sites\/52\/2026\/08\/event-sourcing-architecture-2048x1167.png 2048w\" sizes=\"(max-width: 2484px) 100vw, 2484px\" \/><\/a><\/p>\n<div class=\"markdown-heading\" dir=\"auto\">\n<h2 class=\"heading-element\" dir=\"auto\" tabindex=\"-1\">Start where your operational data lives<\/h2>\n<\/div>\n<p dir=\"auto\">In an Azure Cosmos DB for NoSQL account, open <strong>Integrations<\/strong>\u00a0&gt;\u00a0<strong>Apache Kafka on Confluent Cloud<\/strong>. Select a Confluent organization, environment, and cluster to view connectors or create one.<\/p>\n<p dir=\"auto\"><a href=\"https:\/\/devblogs.microsoft.com\/cosmosdb\/wp-content\/uploads\/sites\/52\/2026\/08\/02-apache-kafka-landing.png\"><img decoding=\"async\" class=\"alignnone size-full wp-image-12836\" src=\"https:\/\/devblogs.microsoft.com\/cosmosdb\/wp-content\/uploads\/sites\/52\/2026\/08\/02-apache-kafka-landing.png\" alt=\"02 apache kafka landing image\" width=\"2484\" height=\"1416\" srcset=\"https:\/\/devblogs.microsoft.com\/cosmosdb\/wp-content\/uploads\/sites\/52\/2026\/08\/02-apache-kafka-landing.png 2484w, https:\/\/devblogs.microsoft.com\/cosmosdb\/wp-content\/uploads\/sites\/52\/2026\/08\/02-apache-kafka-landing-300x171.png 300w, https:\/\/devblogs.microsoft.com\/cosmosdb\/wp-content\/uploads\/sites\/52\/2026\/08\/02-apache-kafka-landing-1024x584.png 1024w, https:\/\/devblogs.microsoft.com\/cosmosdb\/wp-content\/uploads\/sites\/52\/2026\/08\/02-apache-kafka-landing-768x438.png 768w, https:\/\/devblogs.microsoft.com\/cosmosdb\/wp-content\/uploads\/sites\/52\/2026\/08\/02-apache-kafka-landing-1536x876.png 1536w, https:\/\/devblogs.microsoft.com\/cosmosdb\/wp-content\/uploads\/sites\/52\/2026\/08\/02-apache-kafka-landing-2048x1167.png 2048w\" sizes=\"(max-width: 2484px) 100vw, 2484px\" \/><\/a><\/p>\n<div class=\"markdown-heading\" dir=\"auto\">\n<h2 dir=\"auto\" tabindex=\"-1\"><\/h2>\n<h2 class=\"heading-element\" dir=\"auto\" tabindex=\"-1\">Choose the data direction<\/h2>\n<\/div>\n<p dir=\"auto\">Select\u00a0<strong>Create new connector<\/strong>. The guided workflow covers Basics, Authentication, Configuration, and Review + Create while carrying the Azure Cosmos DB account and selected Confluent resources forward.<\/p>\n<p><a href=\"https:\/\/devblogs.microsoft.com\/cosmosdb\/wp-content\/uploads\/sites\/52\/2026\/08\/05-connector-basics-loaded.png\"><img decoding=\"async\" class=\"alignnone size-full wp-image-12837\" src=\"https:\/\/devblogs.microsoft.com\/cosmosdb\/wp-content\/uploads\/sites\/52\/2026\/08\/05-connector-basics-loaded.png\" alt=\"05 connector basics loaded image\" width=\"2484\" height=\"1416\" srcset=\"https:\/\/devblogs.microsoft.com\/cosmosdb\/wp-content\/uploads\/sites\/52\/2026\/08\/05-connector-basics-loaded.png 2484w, https:\/\/devblogs.microsoft.com\/cosmosdb\/wp-content\/uploads\/sites\/52\/2026\/08\/05-connector-basics-loaded-300x171.png 300w, https:\/\/devblogs.microsoft.com\/cosmosdb\/wp-content\/uploads\/sites\/52\/2026\/08\/05-connector-basics-loaded-1024x584.png 1024w, https:\/\/devblogs.microsoft.com\/cosmosdb\/wp-content\/uploads\/sites\/52\/2026\/08\/05-connector-basics-loaded-768x438.png 768w, https:\/\/devblogs.microsoft.com\/cosmosdb\/wp-content\/uploads\/sites\/52\/2026\/08\/05-connector-basics-loaded-1536x876.png 1536w, https:\/\/devblogs.microsoft.com\/cosmosdb\/wp-content\/uploads\/sites\/52\/2026\/08\/05-connector-basics-loaded-2048x1167.png 2048w\" sizes=\"(max-width: 2484px) 100vw, 2484px\" \/><\/a><\/p>\n<ul dir=\"auto\">\n<li><strong>Send to Confluent<\/strong>\u00a0streams Cosmos DB changes to Kafka for downstream consumers.<\/li>\n<li><strong>Receive from Confluent<\/strong>\u00a0writes Kafka records to Cosmos DB to build application-ready projections.<\/li>\n<\/ul>\n<p dir=\"auto\">Before starting, prepare a Confluent cluster and topic, an Azure Cosmos DB database and container, and permissions for both services. The Basics step validates these dependencies in place.<\/p>\n<div class=\"markdown-heading\" dir=\"auto\">\n<h2 dir=\"auto\" tabindex=\"-1\"><\/h2>\n<h2 class=\"heading-element\" dir=\"auto\" tabindex=\"-1\">Resource creation stays in context<\/h2>\n<\/div>\n<p dir=\"auto\">If the environment has no cluster, select\u00a0<strong>Create new cluster<\/strong>. A side pane keeps the connector form in place and carries over the organization and environment.<\/p>\n<p><a href=\"https:\/\/devblogs.microsoft.com\/cosmosdb\/wp-content\/uploads\/sites\/52\/2026\/08\/11-create-cluster-retry.png\"><img decoding=\"async\" class=\"alignnone size-full wp-image-12838\" src=\"https:\/\/devblogs.microsoft.com\/cosmosdb\/wp-content\/uploads\/sites\/52\/2026\/08\/11-create-cluster-retry.png\" alt=\"11 create cluster retry image\" width=\"2484\" height=\"1416\" srcset=\"https:\/\/devblogs.microsoft.com\/cosmosdb\/wp-content\/uploads\/sites\/52\/2026\/08\/11-create-cluster-retry.png 2484w, https:\/\/devblogs.microsoft.com\/cosmosdb\/wp-content\/uploads\/sites\/52\/2026\/08\/11-create-cluster-retry-300x171.png 300w, https:\/\/devblogs.microsoft.com\/cosmosdb\/wp-content\/uploads\/sites\/52\/2026\/08\/11-create-cluster-retry-1024x584.png 1024w, https:\/\/devblogs.microsoft.com\/cosmosdb\/wp-content\/uploads\/sites\/52\/2026\/08\/11-create-cluster-retry-768x438.png 768w, https:\/\/devblogs.microsoft.com\/cosmosdb\/wp-content\/uploads\/sites\/52\/2026\/08\/11-create-cluster-retry-1536x876.png 1536w, https:\/\/devblogs.microsoft.com\/cosmosdb\/wp-content\/uploads\/sites\/52\/2026\/08\/11-create-cluster-retry-2048x1167.png 2048w\" sizes=\"(max-width: 2484px) 100vw, 2484px\" \/><\/a><\/p>\n<div class=\"markdown-heading\" dir=\"auto\">\n<h2 class=\"heading-element\" dir=\"auto\" tabindex=\"-1\">From event log to global application state<\/h2>\n<\/div>\n<p dir=\"auto\">Confluent Cloud preserves events for processing and replay; Cosmos DB serves the resulting state to applications worldwide. The native connector experience reduces the setup between them to one guided Azure workflow, helping teams move faster from event streams to responsive applications.<\/p>\n<div class=\"markdown-heading\" dir=\"auto\">\n<h2 dir=\"auto\" tabindex=\"-1\"><\/h2>\n<h2 class=\"heading-element\" dir=\"auto\" tabindex=\"-1\">About Azure Cosmos DB<\/h2>\n<\/div>\n<p dir=\"auto\">Azure Cosmos DB is a fully managed and serverless NoSQL and vector database for modern app development, including AI applications. With its SLA-backed speed and availability as well as instant dynamic scalability, it is ideal for real-time NoSQL and MongoDB applications that require high performance and global distribution.<\/p>\n<p dir=\"auto\">To stay in the loop on Azure Cosmos DB updates, follow us on\u00a0<a href=\"https:\/\/twitter.com\/AzureCosmosDB\" rel=\"nofollow\">X<\/a>,\u00a0<a href=\"https:\/\/aka.ms\/AzureCosmosDBYouTube\" rel=\"nofollow\">YouTube<\/a>, and\u00a0<a href=\"https:\/\/www.linkedin.com\/company\/azure-cosmos-db\/\" rel=\"nofollow\">LinkedIn<\/a>.<\/p>\n","protected":false},"excerpt":{"rendered":"<p>Co-authored with Praveen Raja P Azure Cosmos DB already includes a powerful event foundation: change feed provides a durable, ordered record of item changes within each logical partition. It is ideal for reacting to operational data as it changes, building projections, and driving workflows directly from the database. Confluent Cloud adds a complementary event layer [&hellip;]<\/p>\n","protected":false},"author":9387,"featured_media":12851,"comment_status":"open","ping_status":"closed","sticky":false,"template":"","format":"standard","meta":{"_acf_changed":false,"footnotes":""},"categories":[643,1941],"tags":[],"class_list":["post-12834","post","type-post","status-publish","format-standard","has-post-thumbnail","hentry","category-java-sdk","category-kafka-connectors"],"acf":[],"blog_post_summary":"<p>Co-authored with Praveen Raja P Azure Cosmos DB already includes a powerful event foundation: change feed provides a durable, ordered record of item changes within each logical partition. It is ideal for reacting to operational data as it changes, building projections, and driving workflows directly from the database. Confluent Cloud adds a complementary event layer [&hellip;]<\/p>\n","_links":{"self":[{"href":"https:\/\/devblogs.microsoft.com\/cosmosdb\/wp-json\/wp\/v2\/posts\/12834","targetHints":{"allow":["GET"]}}],"collection":[{"href":"https:\/\/devblogs.microsoft.com\/cosmosdb\/wp-json\/wp\/v2\/posts"}],"about":[{"href":"https:\/\/devblogs.microsoft.com\/cosmosdb\/wp-json\/wp\/v2\/types\/post"}],"author":[{"embeddable":true,"href":"https:\/\/devblogs.microsoft.com\/cosmosdb\/wp-json\/wp\/v2\/users\/9387"}],"replies":[{"embeddable":true,"href":"https:\/\/devblogs.microsoft.com\/cosmosdb\/wp-json\/wp\/v2\/comments?post=12834"}],"version-history":[{"count":1,"href":"https:\/\/devblogs.microsoft.com\/cosmosdb\/wp-json\/wp\/v2\/posts\/12834\/revisions"}],"predecessor-version":[{"id":12959,"href":"https:\/\/devblogs.microsoft.com\/cosmosdb\/wp-json\/wp\/v2\/posts\/12834\/revisions\/12959"}],"wp:featuredmedia":[{"embeddable":true,"href":"https:\/\/devblogs.microsoft.com\/cosmosdb\/wp-json\/wp\/v2\/media\/12851"}],"wp:attachment":[{"href":"https:\/\/devblogs.microsoft.com\/cosmosdb\/wp-json\/wp\/v2\/media?parent=12834"}],"wp:term":[{"taxonomy":"category","embeddable":true,"href":"https:\/\/devblogs.microsoft.com\/cosmosdb\/wp-json\/wp\/v2\/categories?post=12834"},{"taxonomy":"post_tag","embeddable":true,"href":"https:\/\/devblogs.microsoft.com\/cosmosdb\/wp-json\/wp\/v2\/tags?post=12834"}],"curies":[{"name":"wp","href":"https:\/\/api.w.org\/{rel}","templated":true}]}}