| <!doctype html> |
| <html lang="en" dir="ltr" class="docs-wrapper docs-doc-page docs-version-3.1.x plugin-docs plugin-id-default docs-doc-id-io-connectors"> |
| <head> |
| <meta charset="UTF-8"> |
| <meta name="generator" content="Docusaurus v2.4.0"> |
| <title data-rh="true">Built-in connector | Apache Pulsar</title><meta data-rh="true" name="viewport" content="width=device-width,initial-scale=1"><meta data-rh="true" name="twitter:card" content="summary_large_image"><meta data-rh="true" property="og:image" content="https://pulsar.apache.org/img/pulsar-social-media-card.png"><meta data-rh="true" name="twitter:image" content="https://pulsar.apache.org/img/pulsar-social-media-card.png"><meta data-rh="true" property="og:url" content="https://pulsar.apache.org/docs/3.1.x/io-connectors/"><meta data-rh="true" name="docusaurus_locale" content="en"><meta data-rh="true" name="docsearch:language" content="en"><meta data-rh="true" name="docusaurus_version" content="3.1.x"><meta data-rh="true" name="docusaurus_tag" content="docs-default-3.1.x"><meta data-rh="true" name="docsearch:version" content="3.1.x"><meta data-rh="true" name="docsearch:docusaurus_tag" content="docs-default-3.1.x"><meta data-rh="true" property="og:title" content="Built-in connector | Apache Pulsar"><meta data-rh="true" name="description" content="Pulsar distribution includes a set of common connectors that have been packaged and tested with the rest of Apache Pulsar. These connectors import and export data from some of the most commonly used data systems."><meta data-rh="true" property="og:description" content="Pulsar distribution includes a set of common connectors that have been packaged and tested with the rest of Apache Pulsar. These connectors import and export data from some of the most commonly used data systems."><link data-rh="true" rel="icon" href="/img/favicon.ico"><link data-rh="true" rel="alternate" href="https://pulsar.apache.org/docs/3.1.x/io-connectors/" hreflang="en"><link data-rh="true" rel="alternate" href="https://pulsar.apache.org/docs/3.1.x/io-connectors/" hreflang="x-default"><link data-rh="true" rel="canonical" href="https://pulsar.apache.org/docs/io-connectors/"><link data-rh="true" rel="preconnect" href="https://WK2YL0SALL-dsn.algolia.net" crossorigin="anonymous"><link rel="alternate" type="application/rss+xml" href="/blog/rss.xml" title="Apache Pulsar RSS Feed"> |
| <link rel="alternate" type="application/atom+xml" href="/blog/atom.xml" title="Apache Pulsar Atom Feed"> |
| |
| |
| |
| <link rel="search" type="application/opensearchdescription+xml" title="Apache Pulsar" href="/opensearch.xml"> |
| |
| |
| |
| |
| |
| <link rel="stylesheet" href="/css/katex-0.13.24.min.css" media="print" onload="this.media='all'"> |
| <script src="/js/sine-waves.min.js" async></script> |
| <script src="/js/matomo-agent.js"></script><link rel="stylesheet" href="/assets/css/styles.83bad5a1.css"> |
| <link rel="preload" href="/assets/js/runtime~main.919123c5.js" as="script"> |
| <link rel="preload" href="/assets/js/main.e40a64d4.js" as="script"> |
| </head> |
| <body class="navigation-with-keyboard"> |
| <script>!function(){function t(t){document.documentElement.setAttribute("data-theme",t)}var e=function(){var t=null;try{t=new URLSearchParams(window.location.search).get("docusaurus-theme")}catch(t){}return t}()||function(){var t=null;try{t=localStorage.getItem("theme")}catch(t){}return t}();t(null!==e?e:"light")}(),document.documentElement.setAttribute("data-announcement-bar-initially-dismissed",function(){try{return"true"===localStorage.getItem("docusaurus.announcement.dismiss")}catch(t){}return!1}())</script><div id="__docusaurus"> |
| <div role="region" aria-label="Skip to main content"><a class="skipToContent_fXgn" href="#docusaurus_skipToContent_fallback">Skip to main content</a></div><div class="announcementBar_mb4j" style="background-color:#282826;color:#fff" role="banner"><div class="content_knG7 announcementBarContent_xLdY"> |
| <a class="announcement-bar" href="https://registration.socio.events/e/pulsarvirtualsummiteurope2024" target="_blank"> |
| <div class="announcement-bar__content"> |
| <svg class="announcement-bar__icon"> |
| |
| <svg viewBox="0 0 33 32" fill="none" xmlns="http://www.w3.org/2000/svg"> |
| <path d="M6.5 19.6001H16.1L15.3 29.2001L26.5 12.4H17.06L18.1 2.80005L6.5 19.6001Z" stroke="#F7F7F7" stroke-width="1.5" stroke-linejoin="round"/> |
| </svg> |
| |
| </svg> |
| |
| <span> |
| Get your free pass for Pulsar Virtual Summit Europe 2024 on May 14, 2024 🗓️ |
| </span> |
| |
| <svg class="announcement-bar__icon"> |
| |
| <svg viewBox="0 0 32 32" fill="none" xmlns="http://www.w3.org/2000/svg"> |
| <rect width="20" height="20" transform="translate(6 6)" fill="white" fill-opacity="0.01"/> |
| <path d="M17.6667 10.1667L23.5 16.0001M23.5 16.0001L17.6667 21.8334M23.5 16.0001L8.5 16.0001" stroke="white" stroke-linecap="round" stroke-linejoin="round"/> |
| <rect x="0.5" y="0.5" width="31" height="31" rx="15.5" stroke="white"/> |
| </svg> |
| |
| </svg> |
| </div> |
| </a> |
| </div></div><nav aria-label="Main" class="navbar navbar--fixed-top"><div class="navbar__inner"><div class="navbar__items"><button aria-label="Toggle navigation bar" aria-expanded="false" class="navbar__toggle clean-btn" type="button"><svg width="30" height="30" viewBox="0 0 30 30" aria-hidden="true"><path stroke="currentColor" stroke-linecap="round" stroke-miterlimit="10" stroke-width="2" d="M4 7h22M4 15h22M4 23h22"></path></svg></button><a class="navbar__brand" href="/"><div class="navbar__logo"><img src="/img/logo-black.svg" alt="Apache Pulsar logo" class="themedImage_ToTc themedImage--light_HNdA" height="25" width="127"><img src="/img/logo-black.svg" alt="Apache Pulsar logo" class="themedImage_ToTc themedImage--dark_i4oU" height="25" width="127"></div><b class="navbar__title text--truncate"></b></a><div class="navbar__item dropdown dropdown--hoverable"><a href="#" aria-haspopup="true" aria-expanded="false" role="button" class="navbar__link">Get Started</a><ul class="dropdown__menu"><li><a class="dropdown__link" href="/docs/3.2.x/concepts-overview/">Concepts</a></li><li><a class="dropdown__link" href="/docs/3.2.x/">Quickstart</a></li><li><a class="dropdown__link" href="/ecosystem/">Ecosystem</a></li></ul></div><a aria-current="page" class="navbar__item navbar__link navbar__link--active" href="/docs/3.1.x/">Docs</a><a class="navbar__item navbar__link" href="/features/">Features</a><a class="navbar__item navbar__link" href="/use-cases/">Use Cases</a><div class="navbar__item dropdown dropdown--hoverable"><a href="#" aria-haspopup="true" aria-expanded="false" role="button" class="navbar__link community-dropdown">Community</a><ul class="dropdown__menu"><li><a class="dropdown__link scroll-link scroll-welcome" id="scroll-welcome" href="/community/">Welcome</a></li><li><a class="dropdown__link scroll-link scroll-discussions" id="scroll-discussions" href="/community/#section-discussions">Discussions</a></li><li><a class="dropdown__link scroll-link" id="scroll-governance" href="/community/#section-governance">Governance</a></li><li><a class="dropdown__link scroll-link" id="scroll-community" href="/community/#section-community">Meet the Community</a></li><li><a class="dropdown__link scroll-link" id="scroll-contribute" href="/community/#section-contribute">Contribute</a></li><li><a class="dropdown__link" href="/contribute/">Contribution Guide</a></li><li><a href="https://github.com/apache/pulsar/wiki" target="_blank" rel="noopener noreferrer" class="dropdown__link">Wiki</a></li><li><a href="https://github.com/apache/pulsar/issues" target="_blank" rel="noopener noreferrer" class="dropdown__link">Issue Tracking</a></li></ul></div><div class="navbar__item dropdown dropdown--hoverable"><a href="#" aria-haspopup="true" aria-expanded="false" role="button" class="navbar__link">Learn</a><ul class="dropdown__menu"><li><a class="dropdown__link" href="/blog/">Blog</a></li><li><a class="dropdown__link" href="/books/">Books</a></li><li><a class="dropdown__link" href="/case-studies/">Case Studies</a></li><li><a class="dropdown__link" href="/articles/">Articles</a></li><li><a class="dropdown__link" href="/presentations/">Presentations</a></li><li><a class="dropdown__link" href="/events/">Events</a></li></ul></div></div><div class="navbar__items navbar__items--right"><a class="navbar__item navbar__link navbar_download_button" href="/download/">Download</a><div class="searchBox_ZlJk"><button type="button" class="DocSearch DocSearch-Button" aria-label="Search"><span class="DocSearch-Button-Container"><svg width="20" height="20" class="DocSearch-Search-Icon" viewBox="0 0 20 20" aria-hidden="true"><path d="M14.386 14.386l4.0877 4.0877-4.0877-4.0877c-2.9418 2.9419-7.7115 2.9419-10.6533 0-2.9419-2.9418-2.9419-7.7115 0-10.6533 2.9418-2.9419 7.7115-2.9419 10.6533 0 2.9419 2.9418 2.9419 7.7115 0 10.6533z" stroke="currentColor" fill="none" fill-rule="evenodd" stroke-linecap="round" stroke-linejoin="round"></path></svg><span class="DocSearch-Button-Placeholder">Search</span></span><span class="DocSearch-Button-Keys"></span></button></div></div></div><div role="presentation" class="navbar-sidebar__backdrop"></div></nav><div id="docusaurus_skipToContent_fallback" class="main-wrapper mainWrapper_z2l0 docsWrapper_BCFX"><button aria-label="Scroll back to top" class="clean-btn theme-back-to-top-button backToTopButton_sjWU" type="button"></button><div class="docPage__5DB"><aside class="theme-doc-sidebar-container docSidebarContainer_b6E3"><div class="sidebarViewport_Xe31"><div class="sidebar_mhZE"><div class="sidebarVersionSwitch_EHpo">Version:<div class="navbar__item dropdown dropdown--hoverable"><a aria-current="page" class="navbar__link active" aria-haspopup="true" aria-expanded="false" role="button" href="/docs/3.1.x/">3.1.x</a><ul class="dropdown__menu"><li><a class="dropdown__link">Next</a></li><li><a class="dropdown__link">3.2.x</a></li><li><a class="dropdown__link">3.0.x LTS</a></li><li><a class="dropdown__link">Others</a></li></ul></div></div><nav aria-label="Docs sidebar" class="menu thin-scrollbar menu_SIkG menuWithAnnouncementBar_GW3s"><ul class="theme-doc-sidebar-menu menu__list"><li class="theme-doc-sidebar-item-link theme-doc-sidebar-item-link-level-1 menu__list-item"><a class="menu__link" href="/docs/3.1.x/">About</a></li><li class="theme-doc-sidebar-item-category theme-doc-sidebar-item-category-level-1 menu__list-item menu__list-item--collapsed"><div class="menu__list-item-collapsible"><a class="menu__link menu__link--sublist" aria-expanded="false" href="/docs/3.1.x/getting-started-home/">Get Started</a><button aria-label="Toggle the collapsible sidebar category 'Get Started'" type="button" class="clean-btn menu__caret"></button></div></li><li class="theme-doc-sidebar-item-category theme-doc-sidebar-item-category-level-1 menu__list-item menu__list-item--collapsed"><div class="menu__list-item-collapsible"><a class="menu__link menu__link--sublist menu__link--sublist-caret" aria-expanded="false" href="/docs/3.1.x/concepts-overview/">Concepts and Architecture</a></div></li><li class="theme-doc-sidebar-item-category theme-doc-sidebar-item-category-level-1 menu__list-item menu__list-item--collapsed"><div class="menu__list-item-collapsible"><a class="menu__link menu__link--sublist menu__link--sublist-caret" aria-expanded="false" href="/docs/3.1.x/schema-overview/">Pulsar Schema</a></div></li><li class="theme-doc-sidebar-item-category theme-doc-sidebar-item-category-level-1 menu__list-item menu__list-item--collapsed"><div class="menu__list-item-collapsible"><a class="menu__link menu__link--sublist menu__link--sublist-caret" aria-expanded="false" href="/docs/3.1.x/functions-overview/">Pulsar Functions</a></div></li><li class="theme-doc-sidebar-item-category theme-doc-sidebar-item-category-level-1 menu__list-item"><div class="menu__list-item-collapsible"><a class="menu__link menu__link--sublist menu__link--sublist-caret menu__link--active" aria-expanded="true" href="/docs/3.1.x/io-overview/">Pulsar IO</a></div><ul style="display:block;overflow:visible;height:auto" class="menu__list"><li class="theme-doc-sidebar-item-link theme-doc-sidebar-item-link-level-2 menu__list-item"><a class="menu__link" tabindex="0" href="/docs/3.1.x/io-overview/">Overview</a></li><li class="theme-doc-sidebar-item-link theme-doc-sidebar-item-link-level-2 menu__list-item"><a class="menu__link" tabindex="0" href="/docs/3.1.x/io-quickstart/">Get started</a></li><li class="theme-doc-sidebar-item-link theme-doc-sidebar-item-link-level-2 menu__list-item"><a class="menu__link" tabindex="0" href="/docs/3.1.x/io-use/">Use</a></li><li class="theme-doc-sidebar-item-link theme-doc-sidebar-item-link-level-2 menu__list-item"><a class="menu__link" tabindex="0" href="/docs/3.1.x/io-debug/">Debug</a></li><li class="theme-doc-sidebar-item-link theme-doc-sidebar-item-link-level-2 menu__list-item"><a class="menu__link menu__link--active" aria-current="page" tabindex="0" href="/docs/3.1.x/io-connectors/">Built-in connector</a></li><li class="theme-doc-sidebar-item-link theme-doc-sidebar-item-link-level-2 menu__list-item"><a class="menu__link" tabindex="0" href="/docs/3.1.x/io-cdc/">CDC connector</a></li><li class="theme-doc-sidebar-item-link theme-doc-sidebar-item-link-level-2 menu__list-item"><a class="menu__link" tabindex="0" href="/docs/3.1.x/io-develop/">Develop</a></li></ul></li><li class="theme-doc-sidebar-item-category theme-doc-sidebar-item-category-level-1 menu__list-item menu__list-item--collapsed"><div class="menu__list-item-collapsible"><a class="menu__link menu__link--sublist menu__link--sublist-caret" aria-expanded="false" href="/docs/3.1.x/sql-overview/">Pulsar SQL</a></div></li><li class="theme-doc-sidebar-item-category theme-doc-sidebar-item-category-level-1 menu__list-item menu__list-item--collapsed"><div class="menu__list-item-collapsible"><a class="menu__link menu__link--sublist menu__link--sublist-caret" aria-expanded="false" href="/docs/3.1.x/tiered-storage-overview/">Tiered Storage</a></div></li><li class="theme-doc-sidebar-item-category theme-doc-sidebar-item-category-level-1 menu__list-item menu__list-item--collapsed"><div class="menu__list-item-collapsible"><a class="menu__link menu__link--sublist menu__link--sublist-caret" aria-expanded="false" href="/docs/3.1.x/txn-why/">Transactions</a></div></li><li class="theme-doc-sidebar-item-category theme-doc-sidebar-item-category-level-1 menu__list-item menu__list-item--collapsed"><div class="menu__list-item-collapsible"><a class="menu__link menu__link--sublist" aria-expanded="false" href="/docs/3.1.x/install-deploy-upgrade-landing/">Deployment</a><button aria-label="Toggle the collapsible sidebar category 'Deployment'" type="button" class="clean-btn menu__caret"></button></div></li><li class="theme-doc-sidebar-item-category theme-doc-sidebar-item-category-level-1 menu__list-item menu__list-item--collapsed"><div class="menu__list-item-collapsible"><a class="menu__link menu__link--sublist menu__link--sublist-caret" aria-expanded="false" href="/docs/3.1.x/administration-zk-bk/">Administration</a></div></li><li class="theme-doc-sidebar-item-category theme-doc-sidebar-item-category-level-1 menu__list-item menu__list-item--collapsed"><div class="menu__list-item-collapsible"><a class="menu__link menu__link--sublist menu__link--sublist-caret" aria-expanded="false" href="/docs/3.1.x/administration-stats/">Observability</a></div></li><li class="theme-doc-sidebar-item-category theme-doc-sidebar-item-category-level-1 menu__list-item menu__list-item--collapsed"><div class="menu__list-item-collapsible"><a class="menu__link menu__link--sublist menu__link--sublist-caret" aria-expanded="false" href="/docs/3.1.x/security-overview/">Security</a></div></li><li class="theme-doc-sidebar-item-category theme-doc-sidebar-item-category-level-1 menu__list-item menu__list-item--collapsed"><div class="menu__list-item-collapsible"><a class="menu__link menu__link--sublist menu__link--sublist-caret" aria-expanded="false" href="/docs/3.1.x/performance-pulsar-perf/">Performance</a></div></li><li class="theme-doc-sidebar-item-category theme-doc-sidebar-item-category-level-1 menu__list-item menu__list-item--collapsed"><div class="menu__list-item-collapsible"><a class="menu__link menu__link--sublist menu__link--sublist-caret" aria-expanded="false" href="/docs/3.1.x/client-libraries/">Client Libraries</a></div></li><li class="theme-doc-sidebar-item-category theme-doc-sidebar-item-category-level-1 menu__list-item menu__list-item--collapsed"><div class="menu__list-item-collapsible"><a class="menu__link menu__link--sublist menu__link--sublist-caret" aria-expanded="false" href="/docs/3.1.x/admin-api-overview/">Admin API</a></div></li><li class="theme-doc-sidebar-item-category theme-doc-sidebar-item-category-level-1 menu__list-item menu__list-item--collapsed"><div class="menu__list-item-collapsible"><a class="menu__link menu__link--sublist menu__link--sublist-caret" aria-expanded="false" href="/docs/3.1.x/adaptors-kafka/">Adaptors</a></div></li><li class="theme-doc-sidebar-item-category theme-doc-sidebar-item-category-level-1 menu__list-item menu__list-item--collapsed"><div class="menu__list-item-collapsible"><a class="menu__link menu__link--sublist" aria-expanded="false" href="/docs/3.1.x/how-to-landing/">Tutorials</a><button aria-label="Toggle the collapsible sidebar category 'Tutorials'" type="button" class="clean-btn menu__caret"></button></div></li><li class="theme-doc-sidebar-item-category theme-doc-sidebar-item-category-level-1 menu__list-item menu__list-item--collapsed"><div class="menu__list-item-collapsible"><a class="menu__link menu__link--sublist" aria-expanded="false" href="/docs/3.1.x/developers-landing/">Development</a><button aria-label="Toggle the collapsible sidebar category 'Development'" type="button" class="clean-btn menu__caret"></button></div></li><li class="theme-doc-sidebar-item-category theme-doc-sidebar-item-category-level-1 menu__list-item menu__list-item--collapsed"><div class="menu__list-item-collapsible"><a class="menu__link menu__link--sublist" aria-expanded="false" href="/docs/3.1.x/reference-landing/">Reference</a><button aria-label="Toggle the collapsible sidebar category 'Reference'" type="button" class="clean-btn menu__caret"></button></div></li></ul></nav></div></div></aside><main class="docMainContainer_gTbr"><div class="container padding-top--md padding-bottom--lg"><div class="row"><div class="col docItemCol_VOVn"><div class="docItemContainer_Djhp"><article><nav class="theme-doc-breadcrumbs breadcrumbsContainer_Z_bl" aria-label="Breadcrumbs"><ul class="breadcrumbs" itemscope="" itemtype="https://schema.org/BreadcrumbList"><li class="breadcrumbs__item"><a aria-label="Home page" class="breadcrumbs__link" href="/"><svg viewBox="0 0 24 24" class="breadcrumbHomeIcon_YNFT"><path d="M10 19v-5h4v5c0 .55.45 1 1 1h3c.55 0 1-.45 1-1v-7h1.7c.46 0 .68-.57.33-.87L12.67 3.6c-.38-.34-.96-.34-1.34 0l-8.36 7.53c-.34.3-.13.87.33.87H5v7c0 .55.45 1 1 1h3c.55 0 1-.45 1-1z" fill="currentColor"></path></svg></a></li><li class="breadcrumbs__item"><span class="breadcrumbs__link">Pulsar IO</span><meta itemprop="position" content="1"></li><li itemscope="" itemprop="itemListElement" itemtype="https://schema.org/ListItem" class="breadcrumbs__item breadcrumbs__item--active"><span class="breadcrumbs__link" itemprop="name">Built-in connector</span><meta itemprop="position" content="2"></li></ul></nav><div class="tocCollapsible_ETCw theme-doc-toc-mobile tocMobile_ITEo"><button type="button" class="clean-btn tocCollapsibleButton_TO0P">On this page</button></div><div class="theme-doc-markdown markdown"><header><h1>Built-in connector</h1></header><p>Pulsar distribution includes a set of common connectors that have been packaged and tested with the rest of Apache Pulsar. These connectors import and export data from some of the most commonly used data systems.</p><p>Using any of these connectors is as easy as writing a simple connector and running the connector locally or submitting the connector to a Pulsar Functions cluster.</p><h2 class="anchor anchorWithStickyNavbar_LWe7" id="source-connector">Source connector<a href="#source-connector" class="hash-link" aria-label="Direct link to Source connector" title="Direct link to Source connector"></a></h2><p>Pulsar has various source connectors, which are sorted alphabetically as below.</p><h3 class="anchor anchorWithStickyNavbar_LWe7" id="canal">Canal<a href="#canal" class="hash-link" aria-label="Direct link to Canal" title="Direct link to Canal"></a></h3><ul><li><p><a href="/docs/3.1.x/io-canal-source/#configuration">Configuration</a></p></li><li><p><a href="/docs/3.1.x/io-canal-source/#usage">Example</a></p></li><li><p><a href="https://github.com/apache/pulsar/blob/master/pulsar-io/canal/src/main/java/org/apache/pulsar/io/canal/CanalStringSource.java" target="_blank" rel="noopener noreferrer">Java class</a></p></li></ul><h3 class="anchor anchorWithStickyNavbar_LWe7" id="debezium-mysql">Debezium MySQL<a href="#debezium-mysql" class="hash-link" aria-label="Direct link to Debezium MySQL" title="Direct link to Debezium MySQL"></a></h3><ul><li><p><a href="/docs/3.1.x/io-debezium-source/#configuration">Configuration</a></p></li><li><p><a href="/docs/3.1.x/io-debezium-source/#example-of-mysql">Example</a></p></li><li><p><a href="https://github.com/apache/pulsar/blob/master/pulsar-io/debezium/mysql/src/main/java/org/apache/pulsar/io/debezium/mysql/DebeziumMysqlSource.java" target="_blank" rel="noopener noreferrer">Java class</a></p></li></ul><h3 class="anchor anchorWithStickyNavbar_LWe7" id="debezium-postgresql">Debezium PostgreSQL<a href="#debezium-postgresql" class="hash-link" aria-label="Direct link to Debezium PostgreSQL" title="Direct link to Debezium PostgreSQL"></a></h3><ul><li><p><a href="/docs/3.1.x/io-debezium-source/#configuration">Configuration</a></p></li><li><p><a href="/docs/3.1.x/io-debezium-source/#example-of-postgresql">Example</a></p></li><li><p><a href="https://github.com/apache/pulsar/blob/master/pulsar-io/debezium/postgres/src/main/java/org/apache/pulsar/io/debezium/postgres/DebeziumPostgresSource.java" target="_blank" rel="noopener noreferrer">Java class</a></p></li></ul><h3 class="anchor anchorWithStickyNavbar_LWe7" id="debezium-mongodb">Debezium MongoDB<a href="#debezium-mongodb" class="hash-link" aria-label="Direct link to Debezium MongoDB" title="Direct link to Debezium MongoDB"></a></h3><ul><li><p><a href="/docs/3.1.x/io-debezium-source/#configuration">Configuration</a></p></li><li><p><a href="/docs/3.1.x/io-debezium-source/#example-of-mongodb">Example</a></p></li><li><p><a href="https://github.com/apache/pulsar/blob/master/pulsar-io/debezium/mongodb/src/main/java/org/apache/pulsar/io/debezium/mongodb/DebeziumMongoDbSource.java" target="_blank" rel="noopener noreferrer">Java class</a></p></li></ul><h3 class="anchor anchorWithStickyNavbar_LWe7" id="debezium-oracle">Debezium Oracle<a href="#debezium-oracle" class="hash-link" aria-label="Direct link to Debezium Oracle" title="Direct link to Debezium Oracle"></a></h3><ul><li><p><a href="/docs/3.1.x/io-debezium-source/#configuration">Configuration</a></p></li><li><p><a href="/docs/3.1.x/io-debezium-source/#example-of-oracle">Example</a></p></li><li><p><a href="https://github.com/apache/pulsar/blob/master/pulsar-io/debezium/oracle/src/main/java/org/apache/pulsar/io/debezium/oracle/DebeziumOracleSource.java" target="_blank" rel="noopener noreferrer">Java class</a></p></li></ul><h3 class="anchor anchorWithStickyNavbar_LWe7" id="debezium-microsoft-sql-server">Debezium Microsoft SQL Server<a href="#debezium-microsoft-sql-server" class="hash-link" aria-label="Direct link to Debezium Microsoft SQL Server" title="Direct link to Debezium Microsoft SQL Server"></a></h3><ul><li><p><a href="/docs/3.1.x/io-debezium-source/#configuration">Configuration</a></p></li><li><p><a href="/docs/3.1.x/io-debezium-source/#example-of-microsoft-sql">Example</a></p></li><li><p><a href="https://github.com/apache/pulsar/blob/master/pulsar-io/debezium/mssql/src/main/java/org/apache/pulsar/io/debezium/mssql/DebeziumMsSqlSource.java" target="_blank" rel="noopener noreferrer">Java class</a></p></li></ul><h3 class="anchor anchorWithStickyNavbar_LWe7" id="dynamodb">DynamoDB<a href="#dynamodb" class="hash-link" aria-label="Direct link to DynamoDB" title="Direct link to DynamoDB"></a></h3><ul><li><p><a href="/docs/3.1.x/io-dynamodb-source/#configuration">Configuration</a></p></li><li><p><a href="https://github.com/apache/pulsar/blob/master/pulsar-io/dynamodb/src/main/java/org/apache/pulsar/io/dynamodb/DynamoDBSource.java" target="_blank" rel="noopener noreferrer">Java class</a></p></li></ul><h3 class="anchor anchorWithStickyNavbar_LWe7" id="file">File<a href="#file" class="hash-link" aria-label="Direct link to File" title="Direct link to File"></a></h3><ul><li><p><a href="/docs/3.1.x/io-file-source/#configuration">Configuration</a></p></li><li><p><a href="/docs/3.1.x/io-file-source/#usage">Example</a></p></li><li><p><a href="https://github.com/apache/pulsar/blob/master/pulsar-io/file/src/main/java/org/apache/pulsar/io/file/FileSource.java" target="_blank" rel="noopener noreferrer">Java class</a></p></li></ul><h3 class="anchor anchorWithStickyNavbar_LWe7" id="flume">Flume<a href="#flume" class="hash-link" aria-label="Direct link to Flume" title="Direct link to Flume"></a></h3><ul><li><p><a href="/docs/3.1.x/io-flume-source/#configuration">Configuration</a></p></li><li><p><a href="https://github.com/apache/pulsar/blob/master/pulsar-io/flume/src/main/java/org/apache/pulsar/io/flume/FlumeConnector.java" target="_blank" rel="noopener noreferrer">Java class</a></p></li></ul><h3 class="anchor anchorWithStickyNavbar_LWe7" id="twitter-firehose">Twitter firehose<a href="#twitter-firehose" class="hash-link" aria-label="Direct link to Twitter firehose" title="Direct link to Twitter firehose"></a></h3><ul><li><p><a href="/docs/3.1.x/io-twitter-source/#configuration">Configuration</a></p></li><li><p><a href="https://github.com/apache/pulsar/blob/master/pulsar-io/twitter/src/main/java/org/apache/pulsar/io/twitter/TwitterFireHose.java" target="_blank" rel="noopener noreferrer">Java class</a></p></li></ul><h3 class="anchor anchorWithStickyNavbar_LWe7" id="kafka">Kafka<a href="#kafka" class="hash-link" aria-label="Direct link to Kafka" title="Direct link to Kafka"></a></h3><ul><li><p><a href="/docs/3.1.x/io-kafka-source/#configuration">Configuration</a></p></li><li><p><a href="/docs/3.1.x/io-kafka-source/#usage">Example</a></p></li><li><p><a href="https://github.com/apache/pulsar/blob/master/pulsar-io/kafka/src/main/java/org/apache/pulsar/io/kafka/KafkaAbstractSource.java" target="_blank" rel="noopener noreferrer">Java class</a></p></li></ul><h3 class="anchor anchorWithStickyNavbar_LWe7" id="kinesis">Kinesis<a href="#kinesis" class="hash-link" aria-label="Direct link to Kinesis" title="Direct link to Kinesis"></a></h3><ul><li><p><a href="/docs/3.1.x/io-kinesis-source/#configuration">Configuration</a></p></li><li><p><a href="https://github.com/apache/pulsar/blob/master/pulsar-io/kinesis/src/main/java/org/apache/pulsar/io/kinesis/KinesisSource.java" target="_blank" rel="noopener noreferrer">Java class</a></p></li></ul><h3 class="anchor anchorWithStickyNavbar_LWe7" id="mongodb">MongoDB<a href="#mongodb" class="hash-link" aria-label="Direct link to MongoDB" title="Direct link to MongoDB"></a></h3><ul><li><p><a href="/docs/3.1.x/io-mongo-source/#configuration">Configuration</a></p></li><li><p><a href="https://github.com/apache/pulsar/blob/master/pulsar-io/mongo/src/main/java/org/apache/pulsar/io/mongodb/MongoSource.java" target="_blank" rel="noopener noreferrer">Java class</a></p></li></ul><h3 class="anchor anchorWithStickyNavbar_LWe7" id="netty">Netty<a href="#netty" class="hash-link" aria-label="Direct link to Netty" title="Direct link to Netty"></a></h3><ul><li><p><a href="/docs/3.1.x/io-netty-source/#configuration">Configuration</a></p></li><li><p><a href="/docs/3.1.x/io-netty-source/#tcp">Example of TCP</a></p></li><li><p><a href="/docs/3.1.x/io-netty-source/#http">Example of HTTP</a></p></li><li><p><a href="https://github.com/apache/pulsar/blob/master/pulsar-io/netty/src/main/java/org/apache/pulsar/io/netty/NettySource.java" target="_blank" rel="noopener noreferrer">Java class</a></p></li></ul><h3 class="anchor anchorWithStickyNavbar_LWe7" id="nsq">NSQ<a href="#nsq" class="hash-link" aria-label="Direct link to NSQ" title="Direct link to NSQ"></a></h3><ul><li><p><a href="/docs/3.1.x/io-nsq-source/#configuration">Configuration</a></p></li><li><p><a href="https://github.com/apache/pulsar/blob/master/pulsar-io/nsq/src/main/java/org/apache/pulsar/io/nsq/NSQSource.java" target="_blank" rel="noopener noreferrer">Java class</a></p></li></ul><h3 class="anchor anchorWithStickyNavbar_LWe7" id="rabbitmq">RabbitMQ<a href="#rabbitmq" class="hash-link" aria-label="Direct link to RabbitMQ" title="Direct link to RabbitMQ"></a></h3><ul><li><p><a href="/docs/3.1.x/io-rabbitmq-source/#configuration">Configuration</a></p></li><li><p><a href="https://github.com/apache/pulsar/blob/master/pulsar-io/rabbitmq/src/main/java/org/apache/pulsar/io/rabbitmq/RabbitMQSource.java" target="_blank" rel="noopener noreferrer">Java class</a></p></li></ul><h2 class="anchor anchorWithStickyNavbar_LWe7" id="sink-connector">Sink connector<a href="#sink-connector" class="hash-link" aria-label="Direct link to Sink connector" title="Direct link to Sink connector"></a></h2><p>Pulsar has various sink connectors, which are sorted alphabetically as below.</p><h3 class="anchor anchorWithStickyNavbar_LWe7" id="aerospike">Aerospike<a href="#aerospike" class="hash-link" aria-label="Direct link to Aerospike" title="Direct link to Aerospike"></a></h3><ul><li><p><a href="/docs/3.1.x/io-aerospike-sink/#configuration">Configuration</a></p></li><li><p><a href="https://github.com/apache/pulsar/blob/master/pulsar-io/aerospike/src/main/java/org/apache/pulsar/io/aerospike/AerospikeStringSink.java" target="_blank" rel="noopener noreferrer">Java class</a></p></li></ul><h3 class="anchor anchorWithStickyNavbar_LWe7" id="alluxio">Alluxio<a href="#alluxio" class="hash-link" aria-label="Direct link to Alluxio" title="Direct link to Alluxio"></a></h3><ul><li><p><a href="/docs/3.1.x/io-alluxio/#configuration">Configuration</a></p></li><li><p><a href="https://github.com/apache/pulsar/blob/master/pulsar-io/alluxio/src/main/java/org/apache/pulsar/io/alluxio/sink/AlluxioSink.java" target="_blank" rel="noopener noreferrer">Java class</a></p></li></ul><h3 class="anchor anchorWithStickyNavbar_LWe7" id="cassandra">Cassandra<a href="#cassandra" class="hash-link" aria-label="Direct link to Cassandra" title="Direct link to Cassandra"></a></h3><ul><li><p><a href="/docs/3.1.x/io-cassandra-sink/#configuration">Configuration</a></p></li><li><p><a href="/docs/3.1.x/io-cassandra-sink/#usage">Example</a></p></li><li><p><a href="https://github.com/apache/pulsar/blob/master/pulsar-io/cassandra/src/main/java/org/apache/pulsar/io/cassandra/CassandraStringSink.java" target="_blank" rel="noopener noreferrer">Java class</a></p></li></ul><h3 class="anchor anchorWithStickyNavbar_LWe7" id="elasticsearch">ElasticSearch<a href="#elasticsearch" class="hash-link" aria-label="Direct link to ElasticSearch" title="Direct link to ElasticSearch"></a></h3><ul><li><p><a href="/docs/3.1.x/io-elasticsearch-sink/#configuration">Configuration</a></p></li><li><p><a href="https://github.com/apache/pulsar/blob/master/pulsar-io/elastic-search/src/main/java/org/apache/pulsar/io/elasticsearch/ElasticSearchSink.java" target="_blank" rel="noopener noreferrer">Java class</a></p></li></ul><h3 class="anchor anchorWithStickyNavbar_LWe7" id="flume-1">Flume<a href="#flume-1" class="hash-link" aria-label="Direct link to Flume" title="Direct link to Flume"></a></h3><ul><li><p><a href="/docs/3.1.x/io-flume-sink/#configuration">Configuration</a></p></li><li><p><a href="https://github.com/apache/pulsar/blob/master/pulsar-io/flume/src/main/java/org/apache/pulsar/io/flume/sink/StringSink.java" target="_blank" rel="noopener noreferrer">Java class</a></p></li></ul><h3 class="anchor anchorWithStickyNavbar_LWe7" id="hbase">HBase<a href="#hbase" class="hash-link" aria-label="Direct link to HBase" title="Direct link to HBase"></a></h3><ul><li><p><a href="/docs/3.1.x/io-hbase-sink/#configuration">Configuration</a></p></li><li><p><a href="https://github.com/apache/pulsar/blob/master/pulsar-io/hbase/src/main/java/org/apache/pulsar/io/hbase/HbaseAbstractConfig.java" target="_blank" rel="noopener noreferrer">Java class</a></p></li></ul><h3 class="anchor anchorWithStickyNavbar_LWe7" id="hdfs2">HDFS2<a href="#hdfs2" class="hash-link" aria-label="Direct link to HDFS2" title="Direct link to HDFS2"></a></h3><ul><li><p><a href="/docs/3.1.x/io-hdfs2-sink/#configuration">Configuration</a></p></li><li><p><a href="https://github.com/apache/pulsar/blob/master/pulsar-io/hdfs2/src/main/java/org/apache/pulsar/io/hdfs2/AbstractHdfsConnector.java" target="_blank" rel="noopener noreferrer">Java class</a></p></li></ul><h3 class="anchor anchorWithStickyNavbar_LWe7" id="hdfs3">HDFS3<a href="#hdfs3" class="hash-link" aria-label="Direct link to HDFS3" title="Direct link to HDFS3"></a></h3><ul><li><p><a href="/docs/3.1.x/io-hdfs3-sink/#configuration">Configuration</a></p></li><li><p><a href="https://github.com/apache/pulsar/blob/master/pulsar-io/hdfs3/src/main/java/org/apache/pulsar/io/hdfs3/AbstractHdfsConnector.java" target="_blank" rel="noopener noreferrer">Java class</a></p></li></ul><h3 class="anchor anchorWithStickyNavbar_LWe7" id="http">HTTP<a href="#http" class="hash-link" aria-label="Direct link to HTTP" title="Direct link to HTTP"></a></h3><ul><li><p><a href="/docs/3.1.x/io-http-sink/#configuration">Configuration</a></p></li><li><p><a href="https://github.com/apache/pulsar/blob/master/pulsar-io/http/src/main/java/org/apache/pulsar/io/http/HttpSink.java" target="_blank" rel="noopener noreferrer">Java class</a></p></li></ul><h3 class="anchor anchorWithStickyNavbar_LWe7" id="influxdb">InfluxDB<a href="#influxdb" class="hash-link" aria-label="Direct link to InfluxDB" title="Direct link to InfluxDB"></a></h3><ul><li><p><a href="/docs/3.1.x/io-influxdb-sink/#configuration">Configuration</a></p></li><li><p><a href="https://github.com/apache/pulsar/blob/master/pulsar-io/influxdb/src/main/java/org/apache/pulsar/io/influxdb/InfluxDBGenericRecordSink.java" target="_blank" rel="noopener noreferrer">Java class</a></p></li></ul><h3 class="anchor anchorWithStickyNavbar_LWe7" id="jdbc-clickhouse">JDBC ClickHouse<a href="#jdbc-clickhouse" class="hash-link" aria-label="Direct link to JDBC ClickHouse" title="Direct link to JDBC ClickHouse"></a></h3><ul><li><p><a href="/docs/3.1.x/io-jdbc-sink/#configuration">Configuration</a></p></li><li><p><a href="/docs/3.1.x/io-jdbc-sink/#example-of-clickhouse">Example</a></p></li><li><p><a href="https://github.com/apache/pulsar/blob/master/pulsar-io/jdbc/clickhouse/src/main/java/org/apache/pulsar/io/jdbc/ClickHouseJdbcAutoSchemaSink.java" target="_blank" rel="noopener noreferrer">Java class</a></p></li></ul><h3 class="anchor anchorWithStickyNavbar_LWe7" id="jdbc-mariadb">JDBC MariaDB<a href="#jdbc-mariadb" class="hash-link" aria-label="Direct link to JDBC MariaDB" title="Direct link to JDBC MariaDB"></a></h3><ul><li><p><a href="/docs/3.1.x/io-jdbc-sink/#configuration">Configuration</a></p></li><li><p><a href="/docs/3.1.x/io-jdbc-sink/#example-of-mariadb">Example</a></p></li><li><p><a href="https://github.com/apache/pulsar/blob/master/pulsar-io/jdbc/mariadb/src/main/java/org/apache/pulsar/io/jdbc/MariadbJdbcAutoSchemaSink.java" target="_blank" rel="noopener noreferrer">Java class</a></p></li></ul><h3 class="anchor anchorWithStickyNavbar_LWe7" id="jdbc-openmldb">JDBC OpenMLDB<a href="#jdbc-openmldb" class="hash-link" aria-label="Direct link to JDBC OpenMLDB" title="Direct link to JDBC OpenMLDB"></a></h3><ul><li><p><a href="/docs/3.1.x/io-jdbc-sink/#configuration">Configuration</a></p></li><li><p><a href="/docs/3.1.x/io-jdbc-sink/#example-of-openmldb">Example</a></p></li><li><p><a href="https://github.com/apache/pulsar/blob/master/pulsar-io/jdbc/openmldb/src/main/java/org/apache/pulsar/io/jdbc/OpenMLDBJdbcAutoSchemaSink.java" target="_blank" rel="noopener noreferrer">Java class</a></p></li></ul><h3 class="anchor anchorWithStickyNavbar_LWe7" id="jdbc-postgresql">JDBC PostgreSQL<a href="#jdbc-postgresql" class="hash-link" aria-label="Direct link to JDBC PostgreSQL" title="Direct link to JDBC PostgreSQL"></a></h3><ul><li><p><a href="/docs/3.1.x/io-jdbc-sink/#configuration">Configuration</a></p></li><li><p><a href="/docs/3.1.x/io-jdbc-sink/#example-of-postgresql">Example</a></p></li><li><p><a href="https://github.com/apache/pulsar/blob/master/pulsar-io/jdbc/postgres/src/main/java/org/apache/pulsar/io/jdbc/PostgresJdbcAutoSchemaSink.java" target="_blank" rel="noopener noreferrer">Java class</a></p></li></ul><h3 class="anchor anchorWithStickyNavbar_LWe7" id="jdbc-sqlite">JDBC SQLite<a href="#jdbc-sqlite" class="hash-link" aria-label="Direct link to JDBC SQLite" title="Direct link to JDBC SQLite"></a></h3><ul><li><p><a href="/docs/3.1.x/io-jdbc-sink/#configuration">Configuration</a></p></li><li><p><a href="/docs/3.1.x/io-jdbc-sink/#example-of-sqlite">Example</a></p></li><li><p><a href="https://github.com/apache/pulsar/blob/master/pulsar-io/jdbc/sqlite/src/main/java/org/apache/pulsar/io/jdbc/SqliteJdbcAutoSchemaSink.java" target="_blank" rel="noopener noreferrer">Java class</a></p></li></ul><h3 class="anchor anchorWithStickyNavbar_LWe7" id="kafka-1">Kafka<a href="#kafka-1" class="hash-link" aria-label="Direct link to Kafka" title="Direct link to Kafka"></a></h3><ul><li><p><a href="/docs/3.1.x/io-kafka-sink/#configuration">Configuration</a></p></li><li><p><a href="https://github.com/apache/pulsar/blob/master/pulsar-io/kafka/src/main/java/org/apache/pulsar/io/kafka/KafkaAbstractSink.java" target="_blank" rel="noopener noreferrer">Java class</a></p></li></ul><h3 class="anchor anchorWithStickyNavbar_LWe7" id="kinesis-1">Kinesis<a href="#kinesis-1" class="hash-link" aria-label="Direct link to Kinesis" title="Direct link to Kinesis"></a></h3><ul><li><p><a href="/docs/3.1.x/io-kinesis-sink/#configuration">Configuration</a></p></li><li><p><a href="https://github.com/apache/pulsar/blob/master/pulsar-io/kinesis/src/main/java/org/apache/pulsar/io/kinesis/KinesisSink.java" target="_blank" rel="noopener noreferrer">Java class</a></p></li></ul><h3 class="anchor anchorWithStickyNavbar_LWe7" id="mongodb-1">MongoDB<a href="#mongodb-1" class="hash-link" aria-label="Direct link to MongoDB" title="Direct link to MongoDB"></a></h3><ul><li><p><a href="/docs/3.1.x/io-mongo-sink/#configuration">Configuration</a></p></li><li><p><a href="https://github.com/apache/pulsar/blob/master/pulsar-io/mongo/src/main/java/org/apache/pulsar/io/mongodb/MongoSink.java" target="_blank" rel="noopener noreferrer">Java class</a></p></li></ul><h3 class="anchor anchorWithStickyNavbar_LWe7" id="rabbitmq-1">RabbitMQ<a href="#rabbitmq-1" class="hash-link" aria-label="Direct link to RabbitMQ" title="Direct link to RabbitMQ"></a></h3><ul><li><p><a href="/docs/3.1.x/io-rabbitmq-sink/#configuration">Configuration</a></p></li><li><p><a href="https://github.com/apache/pulsar/blob/master/pulsar-io/rabbitmq/src/main/java/org/apache/pulsar/io/rabbitmq/RabbitMQSink.java" target="_blank" rel="noopener noreferrer">Java class</a></p></li></ul><h3 class="anchor anchorWithStickyNavbar_LWe7" id="redis">Redis<a href="#redis" class="hash-link" aria-label="Direct link to Redis" title="Direct link to Redis"></a></h3><ul><li><p><a href="/docs/3.1.x/io-redis-sink/#configuration">Configuration</a></p></li><li><p><a href="https://github.com/apache/pulsar/blob/master/pulsar-io/redis/src/main/java/org/apache/pulsar/io/redis/RedisAbstractConfig.java" target="_blank" rel="noopener noreferrer">Java class</a></p></li></ul><h3 class="anchor anchorWithStickyNavbar_LWe7" id="solr">Solr<a href="#solr" class="hash-link" aria-label="Direct link to Solr" title="Direct link to Solr"></a></h3><ul><li><p><a href="/docs/3.1.x/io-solr-sink/#configuration">Configuration</a></p></li><li><p><a href="https://github.com/apache/pulsar/blob/master/pulsar-io/solr/src/main/java/org/apache/pulsar/io/solr/SolrSinkConfig.java" target="_blank" rel="noopener noreferrer">Java class</a></p></li></ul></div><footer class="theme-doc-footer docusaurus-mt-lg"><div class="theme-doc-footer-edit-meta-row row"><div class="col"><a href="https://github.com/apache/pulsar-site/edit/main/versioned_docs/version-3.1.x/io-connectors.md" target="_blank" rel="noreferrer noopener" class="theme-edit-this-page"><svg fill="currentColor" height="20" width="20" viewBox="0 0 40 40" class="iconEdit_Z9Sw" aria-hidden="true"><g><path d="m34.5 11.7l-3 3.1-6.3-6.3 3.1-3q0.5-0.5 1.2-0.5t1.1 0.5l3.9 3.9q0.5 0.4 0.5 1.1t-0.5 1.2z m-29.5 17.1l18.4-18.5 6.3 6.3-18.4 18.4h-6.3v-6.2z"></path></g></svg>Edit this page</a></div><div class="col lastUpdated_vwxv"></div></div></footer></article><nav class="pagination-nav docusaurus-mt-lg" aria-label="Docs pages navigation"><a class="pagination-nav__link pagination-nav__link--prev" href="/docs/3.1.x/io-debug/"><div class="pagination-nav__sublabel">Previous</div><div class="pagination-nav__label">Debug</div></a><a class="pagination-nav__link pagination-nav__link--next" href="/docs/3.1.x/io-cdc/"><div class="pagination-nav__sublabel">Next</div><div class="pagination-nav__label">CDC connector</div></a></nav></div></div><div class="col col--3"><div class="tableOfContents_jeP5 thin-scrollbar theme-doc-toc-desktop"><div class="border"><div style="color:var(--ifm-toc-link-color)">Was this helpful?</div><div style="border-width:1px;padding:3px;display:flex"><div style="justify-content:center;display:flex;border-radius:99999px;width:2.5rem;height:2.5rem;cursor:pointer;background:;color:"><svg style="width:initial;height:initial" width="12" height="24" viewBox="0 0 24 24" fill="none" xmlns="http://www.w3.org/2000/svg"><path fill-rule="evenodd" clip-rule="evenodd" d="M10.086 1.594A1 1 0 0 1 11 1a4 4 0 0 1 4 4v3h4.655a3 3 0 0 1 2.994 3.45l-1.38 9A3.002 3.002 0 0 1 18.275 23H4a3 3 0 0 1-3-3v-7a3 3 0 0 1 3-3h2.35l3.736-8.406ZM8 11.212l3.608-8.117A2 2 0 0 1 13 5v4a1 1 0 0 0 1 1h5.671a1 1 0 0 1 1 1.15l-1.38 9a1 1 0 0 1-1 .85H8v-9.788ZM6 21v-9H4a1 1 0 0 0-1 1v7a1 1 0 0 0 1 1h2Z" fill="currentColor"></path></svg></div><div style="justify-content:center;display:flex;border-radius:99999px;width:2.5rem;height:2.5rem;cursor:pointer;background:;color:"><svg style="width:initial;height:initial" width="12" height="24" viewBox="0 0 24 24" fill="none" xmlns="http://www.w3.org/2000/svg"><path fill-rule="evenodd" clip-rule="evenodd" d="M20.563 3.316A1.31 1.31 0 0 0 19.687 3h-1.688v9h1.688a1.31 1.31 0 0 0 1.312-1.077V4.077a1.31 1.31 0 0 0-.436-.761ZM16 12.788l-3.608 8.117A1.999 1.999 0 0 1 11 19v-4a1 1 0 0 0-1-1H4.328a1.002 1.002 0 0 1-1-1.15l1.38-9a1 1 0 0 1 1-.85h10.291v9.788ZM19.661 1a3.31 3.31 0 0 1 3.329 2.866c.006.044.01.09.01.134v7c0 .045-.004.09-.01.134A3.31 3.31 0 0 1 19.661 14h-2.012l-3.736 8.406a1 1 0 0 1-.914.594 4 4 0 0 1-4-4v-3H4.344a3 3 0 0 1-2.994-3.45l1.38-9A3.002 3.002 0 0 1 5.724 1h13.937Z" fill="currentColor"></path></svg></div></div><div class="Actions_uugI"><a target="_blank" class="Action_iBHd" href="https://github.com/apache/pulsar/issues/new?assignees=&labels=doc-required&projects=&template=doc.yml&title=%5BDoc%5D+">💡 Suggest changes</a><a target="_blank" class="Action_iBHd" href="https://github.com/apache/pulsar/discussions/new?category=q-a">🛟 Get support</a></div></div><ul class="table-of-contents table-of-contents__left-border"><li><a href="#source-connector" class="table-of-contents__link toc-highlight">Source connector</a><ul><li><a href="#canal" class="table-of-contents__link toc-highlight">Canal</a></li><li><a href="#debezium-mysql" class="table-of-contents__link toc-highlight">Debezium MySQL</a></li><li><a href="#debezium-postgresql" class="table-of-contents__link toc-highlight">Debezium PostgreSQL</a></li><li><a href="#debezium-mongodb" class="table-of-contents__link toc-highlight">Debezium MongoDB</a></li><li><a href="#debezium-oracle" class="table-of-contents__link toc-highlight">Debezium Oracle</a></li><li><a href="#debezium-microsoft-sql-server" class="table-of-contents__link toc-highlight">Debezium Microsoft SQL Server</a></li><li><a href="#dynamodb" class="table-of-contents__link toc-highlight">DynamoDB</a></li><li><a href="#file" class="table-of-contents__link toc-highlight">File</a></li><li><a href="#flume" class="table-of-contents__link toc-highlight">Flume</a></li><li><a href="#twitter-firehose" class="table-of-contents__link toc-highlight">Twitter firehose</a></li><li><a href="#kafka" class="table-of-contents__link toc-highlight">Kafka</a></li><li><a href="#kinesis" class="table-of-contents__link toc-highlight">Kinesis</a></li><li><a href="#mongodb" class="table-of-contents__link toc-highlight">MongoDB</a></li><li><a href="#netty" class="table-of-contents__link toc-highlight">Netty</a></li><li><a href="#nsq" class="table-of-contents__link toc-highlight">NSQ</a></li><li><a href="#rabbitmq" class="table-of-contents__link toc-highlight">RabbitMQ</a></li></ul></li><li><a href="#sink-connector" class="table-of-contents__link toc-highlight">Sink connector</a><ul><li><a href="#aerospike" class="table-of-contents__link toc-highlight">Aerospike</a></li><li><a href="#alluxio" class="table-of-contents__link toc-highlight">Alluxio</a></li><li><a href="#cassandra" class="table-of-contents__link toc-highlight">Cassandra</a></li><li><a href="#elasticsearch" class="table-of-contents__link toc-highlight">ElasticSearch</a></li><li><a href="#flume-1" class="table-of-contents__link toc-highlight">Flume</a></li><li><a href="#hbase" class="table-of-contents__link toc-highlight">HBase</a></li><li><a href="#hdfs2" class="table-of-contents__link toc-highlight">HDFS2</a></li><li><a href="#hdfs3" class="table-of-contents__link toc-highlight">HDFS3</a></li><li><a href="#http" class="table-of-contents__link toc-highlight">HTTP</a></li><li><a href="#influxdb" class="table-of-contents__link toc-highlight">InfluxDB</a></li><li><a href="#jdbc-clickhouse" class="table-of-contents__link toc-highlight">JDBC ClickHouse</a></li><li><a href="#jdbc-mariadb" class="table-of-contents__link toc-highlight">JDBC MariaDB</a></li><li><a href="#jdbc-openmldb" class="table-of-contents__link toc-highlight">JDBC OpenMLDB</a></li><li><a href="#jdbc-postgresql" class="table-of-contents__link toc-highlight">JDBC PostgreSQL</a></li><li><a href="#jdbc-sqlite" class="table-of-contents__link toc-highlight">JDBC SQLite</a></li><li><a href="#kafka-1" class="table-of-contents__link toc-highlight">Kafka</a></li><li><a href="#kinesis-1" class="table-of-contents__link toc-highlight">Kinesis</a></li><li><a href="#mongodb-1" class="table-of-contents__link toc-highlight">MongoDB</a></li><li><a href="#rabbitmq-1" class="table-of-contents__link toc-highlight">RabbitMQ</a></li><li><a href="#redis" class="table-of-contents__link toc-highlight">Redis</a></li><li><a href="#solr" class="table-of-contents__link toc-highlight">Solr</a></li></ul></li></ul></div></div></div></div></main></div></div><footer class="footer"><div class="container container-fluid"><div class="row footer__links"><div class="col footer__col"><div class="footer__title"></div><ul class="footer__items clean-list"><li class="footer__item"><a href="https://www.apache.org/" target="_blank" rel="noopener noreferrer" class="footer__link-item">Foundation<svg width="13.5" height="13.5" aria-hidden="true" viewBox="0 0 24 24" class="iconExternalLink_nPIU"><path fill="currentColor" d="M21 13v10h-21v-19h12v2h-10v15h17v-8h2zm3-12h-10.988l4.035 4-6.977 7.07 2.828 2.828 6.977-7.07 4.125 4.172v-11z"></path></svg></a></li><li class="footer__item"><a href="https://www.apache.org/events/current-event.html" target="_blank" rel="noopener noreferrer" class="footer__link-item">Events<svg width="13.5" height="13.5" aria-hidden="true" viewBox="0 0 24 24" class="iconExternalLink_nPIU"><path fill="currentColor" d="M21 13v10h-21v-19h12v2h-10v15h17v-8h2zm3-12h-10.988l4.035 4-6.977 7.07 2.828 2.828 6.977-7.07 4.125 4.172v-11z"></path></svg></a></li></ul></div><div class="col footer__col"><div class="footer__title"></div><ul class="footer__items clean-list"><li class="footer__item"><a href="https://www.apache.org/licenses/" target="_blank" rel="noopener noreferrer" class="footer__link-item">License<svg width="13.5" height="13.5" aria-hidden="true" viewBox="0 0 24 24" class="iconExternalLink_nPIU"><path fill="currentColor" d="M21 13v10h-21v-19h12v2h-10v15h17v-8h2zm3-12h-10.988l4.035 4-6.977 7.07 2.828 2.828 6.977-7.07 4.125 4.172v-11z"></path></svg></a></li><li class="footer__item"><a href="https://www.apache.org/foundation/thanks" target="_blank" rel="noopener noreferrer" class="footer__link-item">Thanks<svg width="13.5" height="13.5" aria-hidden="true" viewBox="0 0 24 24" class="iconExternalLink_nPIU"><path fill="currentColor" d="M21 13v10h-21v-19h12v2h-10v15h17v-8h2zm3-12h-10.988l4.035 4-6.977 7.07 2.828 2.828 6.977-7.07 4.125 4.172v-11z"></path></svg></a></li><li class="footer__item"><a href="https://www.apache.org/foundation/sponsorship" target="_blank" rel="noopener noreferrer" class="footer__link-item">Sponsorship<svg width="13.5" height="13.5" aria-hidden="true" viewBox="0 0 24 24" class="iconExternalLink_nPIU"><path fill="currentColor" d="M21 13v10h-21v-19h12v2h-10v15h17v-8h2zm3-12h-10.988l4.035 4-6.977 7.07 2.828 2.828 6.977-7.07 4.125 4.172v-11z"></path></svg></a></li></ul></div><div class="col footer__col"><div class="footer__title"></div><ul class="footer__items clean-list"><li class="footer__item"><a class="footer__link-item" href="/security/">Security</a></li><li class="footer__item"><a href="https://www.apache.org/foundation/policies/privacy.html" target="_blank" rel="noopener noreferrer" class="footer__link-item">Privacy<svg width="13.5" height="13.5" aria-hidden="true" viewBox="0 0 24 24" class="iconExternalLink_nPIU"><path fill="currentColor" d="M21 13v10h-21v-19h12v2h-10v15h17v-8h2zm3-12h-10.988l4.035 4-6.977 7.07 2.828 2.828 6.977-7.07 4.125 4.172v-11z"></path></svg></a></li><li class="footer__item"><a class="footer__link-item" href="/contact/">Contact</a></li></ul></div><div class="col footer__col"><div class="footer__title"></div><ul class="footer__items clean-list"><li class="footer__item"> |
| <div class="social-icons"> |
| <a target="_blank" href="https://communityinviter.com/apps/apache-pulsar/apache-pulsar" aria-label="Join the Apache Pulsar Slack workspace"> |
| <img alt="Slack logo" src="/img/slack-white.svg" width="26"> |
| </a> |
| <a target="_blank" href="https://github.com/apache/pulsar/" aria-label="View the Apache Pulsar project on GitHub"> |
| <img alt="GitHub logo" src="/img/github-white.svg" width="26"> |
| </a> |
| </div> |
| </li></ul></div></div><div class="footer__bottom text--center"><div class="margin-bottom--sm"><a class="footerLogoLink_BH7S" href="/"><img src="/img/pulsar-white.svg" alt="Pulsar Logo" class="themedImage_ToTc themedImage--light_HNdA footer__logo"><img src="/img/pulsar-white.svg" alt="Pulsar Logo" class="themedImage_ToTc themedImage--dark_i4oU footer__logo"></a></div><div class="footer__copyright"> |
| <div> |
| <img class="footer-apache-logo" src="/img/feather-logo-white.svg" alt="" width="20"> |
| The Apache Software Foundation |
| </div> |
| <p>Apache Pulsar is available under the Apache License, version 2.0. Apache Pulsar is an open-source, distributed messaging and streaming platform built for the cloud.</p> |
| <p>Copyright © 2024 The Apache Software Foundation. All Rights Reserved. Apache, Pulsar, Apache Pulsar, and the Apache feather logo are trademarks or registered trademarks of The Apache Software Foundation.</p> |
| </div></div></div></footer></div> |
| <script src="/assets/js/runtime~main.919123c5.js"></script> |
| <script src="/assets/js/main.e40a64d4.js"></script> |
| </body> |
| </html> |
