| <!doctype html> | |
| <html lang="zh" dir="ltr" class="docs-wrapper docs-doc-page docs-version-v1.5.0 plugin-docs plugin-id-default docs-doc-id-design-document/stream" data-has-hydrated="false"> | |
| <head> | |
| <meta charset="UTF-8"> | |
| <meta name="generator" content="Docusaurus v2.4.3"> | |
| <title data-rh="true">EventMesh Stream | Apache EventMesh</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:url" content="https://eventmesh.apache.org/zh/docs/v1.5.0/design-document/stream"><meta data-rh="true" name="docusaurus_locale" content="zh"><meta data-rh="true" name="docsearch:language" content="zh"><meta data-rh="true" name="docusaurus_version" content="v1.5.0"><meta data-rh="true" name="docusaurus_tag" content="docs-default-v1.5.0"><meta data-rh="true" name="docsearch:version" content="v1.5.0"><meta data-rh="true" name="docsearch:docusaurus_tag" content="docs-default-v1.5.0"><meta data-rh="true" property="og:title" content="EventMesh Stream | Apache EventMesh"><meta data-rh="true" name="description" content="事件流概述"><meta data-rh="true" property="og:description" content="事件流概述"><link data-rh="true" rel="icon" href="/zh/images/favicon.ico"><link data-rh="true" rel="canonical" href="https://eventmesh.apache.org/zh/docs/v1.5.0/design-document/stream"><link data-rh="true" rel="alternate" href="https://eventmesh.apache.org/docs/v1.5.0/design-document/stream" hreflang="en"><link data-rh="true" rel="alternate" href="https://eventmesh.apache.org/zh/docs/v1.5.0/design-document/stream" hreflang="zh"><link data-rh="true" rel="alternate" href="https://eventmesh.apache.org/docs/v1.5.0/design-document/stream" hreflang="x-default"><link data-rh="true" rel="preconnect" href="https://D5N4C17BGA-dsn.algolia.net" crossorigin="anonymous"><link rel="alternate" type="application/rss+xml" href="/zh/blog/rss.xml" title="Apache EventMesh RSS Feed"> | |
| <link rel="alternate" type="application/atom+xml" href="/zh/blog/atom.xml" title="Apache EventMesh Atom Feed"> | |
| <link rel="search" type="application/opensearchdescription+xml" title="Apache EventMesh" href="/zh/opensearch.xml"><link rel="stylesheet" href="/zh/assets/css/styles.49656ca2.css"> | |
| <link rel="preload" href="/zh/assets/js/runtime~main.fa98e277.js" as="script"> | |
| <link rel="preload" href="/zh/assets/js/main.9ebd247a.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")}()</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><nav aria-label="主导航" 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="/zh/"><div class="navbar__logo"><img src="/zh/images/logo.png" alt="Apache EventMesh Logo" class="themedImage_ToTc themedImage--light_HNdA"><img src="/zh/images/logo.png" alt="Apache EventMesh Logo" class="themedImage_ToTc themedImage--dark_i4oU"></div><b class="navbar__title text--truncate">Apache EventMesh</b></a><a aria-current="page" class="navbar__item navbar__link navbar__link--active" href="/zh/docs/v1.5.0/introduction">文档</a><a class="navbar__item navbar__link" href="/zh/download">下载</a><a class="navbar__item navbar__link" href="/zh/blog">博客</a><a class="navbar__item navbar__link" href="/zh/events/release-notes/v1.10.0">动态</a><a class="navbar__item navbar__link" href="/zh/community/how-to-subscribe">社区</a><a class="navbar__item navbar__link" href="/zh/team">团队</a></div><div class="navbar__items navbar__items--right"><div class="navbar__item dropdown dropdown--hoverable dropdown--right"><a class="navbar__link" aria-haspopup="true" aria-expanded="false" role="button" href="/zh/docs/v1.5.0/introduction">v1.5.0</a><ul class="dropdown__menu"><li><a class="dropdown__link" href="/zh/docs/next/design-document/stream">Next</a></li><li><a class="dropdown__link" href="/zh/docs/design-document/stream">v1.10.0</a></li><li><a class="dropdown__link" href="/zh/docs/v1.9.0/design-document/stream">v1.9.0</a></li><li><a class="dropdown__link" href="/zh/docs/v1.8.0/design-document/stream">v1.8.0</a></li><li><a class="dropdown__link" href="/zh/docs/v1.7.0/design-document/stream">v1.7.0</a></li><li><a class="dropdown__link" href="/zh/docs/v1.6.0/design-document/stream">v1.6.0</a></li><li><a aria-current="page" class="dropdown__link dropdown__link--active" href="/zh/docs/v1.5.0/design-document/stream">v1.5.0</a></li><li><a class="dropdown__link" href="/zh/docs/v1.4.0/design-document/stream">v1.4.0</a></li><li><a class="dropdown__link" href="/zh/docs/v1.3.0/design-document/stream">v1.3.0</a></li><li><a class="dropdown__link" href="/zh/docs/v1.2.0/introduction">v1.2.0</a></li><li><a class="dropdown__link" href="/zh/docs/v1.1.1/introduction">v1.1.1</a></li><li><a class="dropdown__link" href="/zh/docs/v1.0.0/introduction">v1.0.0</a></li></ul></div><div class="navbar__item dropdown dropdown--hoverable dropdown--right"><a href="#" aria-haspopup="true" aria-expanded="false" role="button" class="navbar__link"><svg viewBox="0 0 24 24" width="20" height="20" aria-hidden="true" class="iconLanguage_nlXk"><path fill="currentColor" d="M12.87 15.07l-2.54-2.51.03-.03c1.74-1.94 2.98-4.17 3.71-6.53H17V4h-7V2H8v2H1v1.99h11.17C11.5 7.92 10.44 9.75 9 11.35 8.07 10.32 7.3 9.19 6.69 8h-2c.73 1.63 1.73 3.17 2.98 4.56l-5.09 5.02L4 19l5-5 3.11 3.11.76-2.04zM18.5 10h-2L12 22h2l1.12-3h4.75L21 22h2l-4.5-12zm-2.62 7l1.62-4.33L19.12 17h-3.24z"></path></svg>简体中文</a><ul class="dropdown__menu"><li><a href="/docs/v1.5.0/design-document/stream" target="_self" rel="noopener noreferrer" class="dropdown__link" lang="en">English</a></li><li><a href="/zh/docs/v1.5.0/design-document/stream" target="_self" rel="noopener noreferrer" class="dropdown__link dropdown__link--active" lang="zh">简体中文</a></li></ul></div><a href="https://github.com/apache/eventmesh" target="_blank" rel="noopener noreferrer" class="navbar__item navbar__link header-github-link" aria-label="GitHub"></a><div class="toggle_vylO colorModeToggle_DEke"><button class="clean-btn toggleButton_gllP toggleButtonDisabled_aARS" type="button" disabled="" title="切换浅色/暗黑模式（当前为浅色模式）" aria-label="切换浅色/暗黑模式（当前为浅色模式）" aria-live="polite"><svg viewBox="0 0 24 24" width="24" height="24" class="lightToggleIcon_pyhR"><path fill="currentColor" d="M12,9c1.65,0,3,1.35,3,3s-1.35,3-3,3s-3-1.35-3-3S10.35,9,12,9 M12,7c-2.76,0-5,2.24-5,5s2.24,5,5,5s5-2.24,5-5 S14.76,7,12,7L12,7z M2,13l2,0c0.55,0,1-0.45,1-1s-0.45-1-1-1l-2,0c-0.55,0-1,0.45-1,1S1.45,13,2,13z M20,13l2,0c0.55,0,1-0.45,1-1 s-0.45-1-1-1l-2,0c-0.55,0-1,0.45-1,1S19.45,13,20,13z M11,2v2c0,0.55,0.45,1,1,1s1-0.45,1-1V2c0-0.55-0.45-1-1-1S11,1.45,11,2z M11,20v2c0,0.55,0.45,1,1,1s1-0.45,1-1v-2c0-0.55-0.45-1-1-1C11.45,19,11,19.45,11,20z M5.99,4.58c-0.39-0.39-1.03-0.39-1.41,0 c-0.39,0.39-0.39,1.03,0,1.41l1.06,1.06c0.39,0.39,1.03,0.39,1.41,0s0.39-1.03,0-1.41L5.99,4.58z M18.36,16.95 c-0.39-0.39-1.03-0.39-1.41,0c-0.39,0.39-0.39,1.03,0,1.41l1.06,1.06c0.39,0.39,1.03,0.39,1.41,0c0.39-0.39,0.39-1.03,0-1.41 L18.36,16.95z M19.42,5.99c0.39-0.39,0.39-1.03,0-1.41c-0.39-0.39-1.03-0.39-1.41,0l-1.06,1.06c-0.39,0.39-0.39,1.03,0,1.41 s1.03,0.39,1.41,0L19.42,5.99z M7.05,18.36c0.39-0.39,0.39-1.03,0-1.41c-0.39-0.39-1.03-0.39-1.41,0l-1.06,1.06 c-0.39,0.39-0.39,1.03,0,1.41s1.03,0.39,1.41,0L7.05,18.36z"></path></svg><svg viewBox="0 0 24 24" width="24" height="24" class="darkToggleIcon_wfgR"><path fill="currentColor" d="M9.37,5.51C9.19,6.15,9.1,6.82,9.1,7.5c0,4.08,3.32,7.4,7.4,7.4c0.68,0,1.35-0.09,1.99-0.27C17.45,17.19,14.93,19,12,19 c-3.86,0-7-3.14-7-7C5,9.07,6.81,6.55,9.37,5.51z M12,3c-4.97,0-9,4.03-9,9s4.03,9,9,9s9-4.03,9-9c0-0.46-0.04-0.92-0.1-1.36 c-0.98,1.37-2.58,2.26-4.4,2.26c-2.98,0-5.4-2.42-5.4-5.4c0-1.81,0.89-3.42,2.26-4.4C12.92,3.04,12.46,3,12,3L12,3z"></path></svg></button></div><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"><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="回到顶部" 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_njMd"><nav aria-label="文档侧边栏" class="menu thin-scrollbar menu_SIkG"><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="/zh/docs/v1.5.0/introduction">Apache EventMesh</a></li><li class="theme-doc-sidebar-item-link theme-doc-sidebar-item-link-level-1 menu__list-item"><a class="menu__link" href="/zh/docs/v1.5.0/roadmap">EventMesh产品路线图</a></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" aria-expanded="true" href="/zh/docs/v1.5.0/instruction/eclipse">安装与部署</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="/zh/docs/v1.5.0/instruction/eclipse">导入 Eclipse 快速入门说明</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="/zh/docs/v1.5.0/instruction/store">部署 EventMesh 的事件存储</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="/zh/docs/v1.5.0/instruction/store-with-docker">部署 EventMesh 的事件存储（使用 Docker）</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="/zh/docs/v1.5.0/instruction/runtime">Eventmesh-runtime 快速入门说明</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="/zh/docs/v1.5.0/instruction/runtime-with-docker">使用 Docker 快速入门 EventMesh（暂时只支持到1.4.0版本）</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="/zh/docs/v1.5.0/instruction/demo">运行 eventmesh-sdk-java demo</a></li></ul></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="/zh/docs/v1.5.0/design-document/event-handling-and-integration/runtime-protocol">设计文档</a></div><ul style="display:block;overflow:visible;height:auto" class="menu__list"><li class="theme-doc-sidebar-item-category theme-doc-sidebar-item-category-level-2 menu__list-item"><div class="menu__list-item-collapsible"><a class="menu__link menu__link--sublist menu__link--sublist-caret" aria-expanded="true" tabindex="0" href="/zh/docs/v1.5.0/design-document/event-handling-and-integration/runtime-protocol">事件处理和集成</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-3 menu__list-item"><a class="menu__link" tabindex="0" href="/zh/docs/v1.5.0/design-document/event-handling-and-integration/runtime-protocol">TCP 协议文档</a></li><li class="theme-doc-sidebar-item-link theme-doc-sidebar-item-link-level-3 menu__list-item"><a class="menu__link" tabindex="0" href="/zh/docs/v1.5.0/design-document/event-handling-and-integration/https">HTTPS</a></li><li class="theme-doc-sidebar-item-link theme-doc-sidebar-item-link-level-3 menu__list-item"><a class="menu__link" tabindex="0" href="/zh/docs/v1.5.0/design-document/event-handling-and-integration/cloudevents">CloudEvents 集成</a></li><li class="theme-doc-sidebar-item-link theme-doc-sidebar-item-link-level-3 menu__list-item"><a class="menu__link" tabindex="0" href="/zh/docs/v1.5.0/design-document/event-handling-and-integration/event-bridge">Event Bridge</a></li></ul></li><li class="theme-doc-sidebar-item-category theme-doc-sidebar-item-category-level-2 menu__list-item"><div class="menu__list-item-collapsible"><a class="menu__link menu__link--sublist menu__link--sublist-caret" aria-expanded="true" tabindex="0" href="/zh/docs/v1.5.0/design-document/observability/metrics-export">可观测性</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-3 menu__list-item"><a class="menu__link" tabindex="0" href="/zh/docs/v1.5.0/design-document/observability/metrics-export">EventMesh 指标（OpenTelemetry 和 Prometheus）</a></li><li class="theme-doc-sidebar-item-link theme-doc-sidebar-item-link-level-3 menu__list-item"><a class="menu__link" tabindex="0" href="/zh/docs/v1.5.0/design-document/observability/tracing">分布式追踪</a></li><li class="theme-doc-sidebar-item-link theme-doc-sidebar-item-link-level-3 menu__list-item"><a class="menu__link" tabindex="0" href="/zh/docs/v1.5.0/design-document/observability/prometheus">通过 Prometheus 观察 Metrics</a></li><li class="theme-doc-sidebar-item-link theme-doc-sidebar-item-link-level-3 menu__list-item"><a class="menu__link" tabindex="0" href="/zh/docs/v1.5.0/design-document/observability/zipkin">通过 Zipkin 观察 Trace</a></li></ul></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="/zh/docs/v1.5.0/design-document/schema-registry">EventMesh 模式注册中心 (OpenSchema)</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="/zh/docs/v1.5.0/design-document/spi">EventMesh SPI</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="/zh/docs/v1.5.0/design-document/stream">EventMesh Stream</a></li></ul></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" aria-expanded="true" href="/zh/docs/v1.5.0/sdk-java/intro">EventMesh SDK for Java</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="/zh/docs/v1.5.0/sdk-java/intro">安装 SDK</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="/zh/docs/v1.5.0/sdk-java/http">HTTP 协议</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="/zh/docs/v1.5.0/sdk-java/tcp">TCP 协议</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="/zh/docs/v1.5.0/sdk-java/grpc">gRPC 协议</a></li></ul></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" aria-expanded="true" href="/zh/docs/v1.5.0/upgrade-guide/upgrade-guide">升级指南</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="/zh/docs/v1.5.0/upgrade-guide/upgrade-guide">EventMesh 升级指引</a></li></ul></li></ul></nav><button type="button" title="Collapse sidebar" aria-label="Collapse sidebar" class="button button--secondary button--outline collapseSidebarButton_PEFL"><svg width="20" height="20" aria-hidden="true" class="collapseSidebarButtonIcon_kv0_"><g fill="#7a7a7a"><path d="M9.992 10.023c0 .2-.062.399-.172.547l-4.996 7.492a.982.982 0 01-.828.454H1c-.55 0-1-.453-1-1 0-.2.059-.403.168-.551l4.629-6.942L.168 3.078A.939.939 0 010 2.528c0-.548.45-.997 1-.997h2.996c.352 0 .649.18.828.45L9.82 9.472c.11.148.172.347.172.55zm0 0"></path><path d="M19.98 10.023c0 .2-.058.399-.168.547l-4.996 7.492a.987.987 0 01-.828.454h-3c-.547 0-.996-.453-.996-1 0-.2.059-.403.168-.551l4.625-6.942-4.625-6.945a.939.939 0 01-.168-.55 1 1 0 01.996-.997h3c.348 0 .649.18.828.45l4.996 7.492c.11.148.168.347.168.55zm0 0"></path></g></svg></button></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="theme-doc-version-banner alert alert--warning margin-bottom--md" role="alert"><div>This is documentation for <!-- -->Apache EventMesh<!-- --> <b>v1.5.0</b>, which is no longer actively maintained.</div><div class="margin-top--md">For up-to-date documentation, see the <b><a href="/zh/docs/design-document/stream">latest version</a></b> (<!-- -->v1.10.0<!-- -->).</div></div><div class="docItemContainer_Djhp"><article><nav class="theme-doc-breadcrumbs breadcrumbsContainer_Z_bl" aria-label="页面路径"><ul class="breadcrumbs" itemscope="" itemtype="https://schema.org/BreadcrumbList"><li class="breadcrumbs__item"><a aria-label="主页面" class="breadcrumbs__link" href="/zh/"><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">设计文档</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">EventMesh Stream</span><meta itemprop="position" content="2"></li></ul></nav><span class="theme-doc-version-badge badge badge--secondary">版本：v1.5.0</span><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"><h1>EventMesh Stream</h1><h2 class="anchor anchorWithStickyNavbar_LWe7" id="事件流概述">事件流概述<a href="#事件流概述" class="hash-link" aria-label="Direct link to heading" title="Direct link to heading"></a></h2><p>事件流是发布/订阅架构模式的一种实现，它包括以下几个部分</p><ul><li><p>消息或事件：状态变化。</p></li><li><p>主题：消息中间件代理中的分区。</p></li><li><p>消费者：可以从代理主题订阅读取事件。</p></li><li><p>生产者：生成事件</p></li></ul><p>事件流是事件的连续流动，为了维持事件之间的秩序，事件流应该以特定的方式从生产者流向消费者。</p><h2 class="anchor anchorWithStickyNavbar_LWe7" id="要求">要求<a href="#要求" class="hash-link" aria-label="Direct link to heading" title="Direct link to heading"></a></h2><h3 class="anchor anchorWithStickyNavbar_LWe7" id="功能要求">功能要求<a href="#功能要求" class="hash-link" aria-label="Direct link to heading" title="Direct link to heading"></a></h3><table><thead><tr><th>需求编号</th><th>需求描述</th><th>注释</th></tr></thead><tbody><tr><td>F-1</td><td>EventMesh用户应该能够在 EventMesh 中实现事件流功能</td><td>功能性</td></tr><tr><td>F-2</td><td>EventMesh用户可以为路由、过滤、转换等应用动态用户特定逻辑</td><td>功能性</td></tr></tbody></table><h2 class="anchor anchorWithStickyNavbar_LWe7" id="设计细节">设计细节<a href="#设计细节" class="hash-link" aria-label="Direct link to heading" title="Direct link to heading"></a></h2><p>我们引入了 EventMesh Stream 组件，允许我们在 Apache Camel 中本地使用来自 Spring Cloud Stream 的编程模型和绑定器抽象。</p><p><a href="https://spring.io/projects/spring-cloud-stream" target="_blank" rel="noopener noreferrer">Spring-Cloud-Stream</a> Spring Cloud Stream是一个用于构建 | |
| 与共享消息传递系统连接的、高度可扩展的事件驱动微服务框架。</p><p><a href="https://camel.apache.org/" target="_blank" rel="noopener noreferrer">Apache Camel</a> Camel 是一个开源集成框架，使您能够快速轻松地集成各种消费或生产数据的系统。</p><h2 class="anchor anchorWithStickyNavbar_LWe7" id="架构">架构<a href="#架构" class="hash-link" aria-label="Direct link to heading" title="Direct link to heading"></a></h2><p><img loading="lazy" alt="Stream Architecture" src="/zh/assets/images/stream-architecture-619e3498c1cc2a3afa0830ff8a112b8f.png" width="716" height="332" class="img_ev3q"></p><h2 class="anchor anchorWithStickyNavbar_LWe7" id="设计">设计<a href="#设计" class="hash-link" aria-label="Direct link to heading" title="Direct link to heading"></a></h2><h3 class="anchor anchorWithStickyNavbar_LWe7" id="eventmesh-stream-组件">EventMesh-Stream 组件<a href="#eventmesh-stream-组件" class="hash-link" aria-label="Direct link to heading" title="Direct link to heading"></a></h3><ul><li>Event（事件）</li><li>Event Channel（事件通道）</li><li>Event EndPoint（事件端点）</li><li>Event Pipes & Filters（事件管道和过滤器）</li><li>Event Routes（事件路由器）</li><li>Event Converter（事件转换器）</li></ul><h4 class="anchor anchorWithStickyNavbar_LWe7" id="event事件">Event（事件）<a href="#event事件" class="hash-link" aria-label="Direct link to heading" title="Direct link to heading"></a></h4><blockquote><p>事件是系统中传输数据的最小单位。它的结构分为标题、正文和附件。</p></blockquote><h4 class="anchor anchorWithStickyNavbar_LWe7" id="event-channel事件通道">Event Channel（事件通道）<a href="#event-channel事件通道" class="hash-link" aria-label="Direct link to heading" title="Direct link to heading"></a></h4><blockquote><p>事件通道是系统中的逻辑通道，我们是通过 Spring Cloud Stream 编程模型实现的，它具有围绕消息通道的抽象功能（截至目前用的是 Spring <code>MessageChannel</code>）。</p></blockquote><h4 class="anchor anchorWithStickyNavbar_LWe7" id="event-endpoint事件端点">Event EndPoint（事件端点）<a href="#event-endpoint事件端点" class="hash-link" aria-label="Direct link to heading" title="Direct link to heading"></a></h4><blockquote><p>事件端点是应用程序和消息传递系统之间的接口。我们可以定义两种类型的端点</p></blockquote><ul><li>消费者端点 - 出现在路由开始并从传入通道读取传入事件。</li><li>生产者端点 - 出现在路由的末尾并将传入事件写入传出通道。</li></ul><h4 class="anchor anchorWithStickyNavbar_LWe7" id="event-pipes--filters事件管道和过滤器">Event Pipes & Filters（事件管道和过滤器）<a href="#event-pipes--filters事件管道和过滤器" class="hash-link" aria-label="Direct link to heading" title="Direct link to heading"></a></h4><blockquote><p>我们可以通过创建过滤器链（Apache Camel <code>Processor</code>）来构建路由，其中一个过滤器的输出被用于管道中下一个过滤器的输入。管道的主要优点是可以创建复杂的事件处理逻辑。</p></blockquote><h4 class="anchor anchorWithStickyNavbar_LWe7" id="event-routes事件路由器">Event Routes（事件路由器）<a href="#event-routes事件路由器" class="hash-link" aria-label="Direct link to heading" title="Direct link to heading"></a></h4><blockquote><p>事件路由器是消费者的一种过滤器，并根据决策标准将它们重定向到适当的目标端点。</p></blockquote><h4 class="anchor anchorWithStickyNavbar_LWe7" id="event-converter事件转换器">Event Converter（事件转换器）<a href="#event-converter事件转换器" class="hash-link" aria-label="Direct link to heading" title="Direct link to heading"></a></h4><blockquote><p>事件转换器用于修改事件内容，将其转换为不同的格式（换而言之 cloudevents -> Event (Camel) -> Binder Message(Spring Message)，反之亦然）。</p></blockquote><h2 class="anchor anchorWithStickyNavbar_LWe7" id="eventmesh-stream-组件接口">EventMesh-Stream 组件接口<a href="#eventmesh-stream-组件接口" class="hash-link" aria-label="Direct link to heading" title="Direct link to heading"></a></h2><h3 class="anchor anchorWithStickyNavbar_LWe7" id="component组件">Component（组件）<a href="#component组件" class="hash-link" aria-label="Direct link to heading" title="Direct link to heading"></a></h3><p>Component 接口是主要的入口点，您可以使用 Component 对象作为工厂来创建 EndPoint 对象。</p><p><img loading="lazy" alt="Stream Component Interface" src="/zh/assets/images/stream-component-interface-ec9641e0807d88d099af905130cbbd1b.png" width="491" height="231" class="img_ev3q"></p><h3 class="anchor anchorWithStickyNavbar_LWe7" id="endpoint端点">EndPoint（端点）<a href="#endpoint端点" class="hash-link" aria-label="Direct link to heading" title="Direct link to heading"></a></h3><p>EndPoint 作为创建消费者、生产者和事件对象的工厂。</p><ul><li><code>createConsumer()</code> — 创建消费者端点，该端点表示路由开始的源端点。</li><li><code>createProducer()</code> — 创建生产者端点，该端点表示路由末端的目标端点。</li></ul><p><img loading="lazy" alt="Stream Component Routes" src="data:image/png;base64,iVBORw0KGgoAAAANSUhEUgAAAlQAAABwCAYAAADYOu4gAAAGTHRFWHRteGZpbGUAJTNDbXhmaWxlJTIwaG9zdCUzRCUyMmFwcC5kaWFncmFtcy5uZXQlMjIlMjBtb2RpZmllZCUzRCUyMjIwMjEtMDctMjVUMTUlM0EzNCUzQTQ1LjI4NVolMjIlMjBhZ2VudCUzRCUyMjUuMCUyMChXaW5kb3dzJTIwTlQlMjAxMC4wJTNCJTIwV2luNjQlM0IlMjB4NjQpJTIwQXBwbGVXZWJLaXQlMkY1MzcuMzYlMjAoS0hUTUwlMkMlMjBsaWtlJTIwR2Vja28pJTIwQ2hyb21lJTJGOTEuMC40NDcyLjE2NCUyMFNhZmFyaSUyRjUzNy4zNiUyMiUyMGV0YWclM0QlMjJLTnZsbmNFLTZoU3RFZDAtcDZ6OCUyMiUyMHZlcnNpb24lM0QlMjIxNC45LjAlMjIlMjB0eXBlJTNEJTIyZGV2aWNlJTIyJTNFJTNDZGlhZ3JhbSUyMGlkJTNEJTIyejI5M3Y0dkRUYnQzc1VEbDFvQTglMjIlMjBuYW1lJTNEJTIyUGFnZS0xJTIyJTNFN1ZuYlV0c3dFUDJhUE1MWVZoTENJNFJRT3FVem1ZRXA5SWtSOWliV1ZMWXlzbkxqNjd1eTVhc1Nra0lhMHRDbmVJJTJGa3RmYWMxV1dWRnVsSGl5JTJCU1RzTHZJZ0RlOHB4ZzBTSlhMYzl6WGFlSFB4cFpaa2k3NDJUQVdMTEFkQ3FCTyUyRllDQnN5N1RWa0FTYTJqRW9Jck5xbUR2b2hqOEZVTm8xS0tlYjNiU1BENlZ5ZDBEQlp3NTFOdW93OHNVR0dHOXZJb05INERiQnlxSW1EVEV0Rzhzd0dTa0FaaVhvSElvRVg2VWdpVlBVV0xQbkJOWHM1TDl0NzFtdFppWUJKaXRjMEw0SDBsUDlydSUyQlQyOERPJTJCJTJGUGMxdmJ1T0hFJTJCTmxSdm5VQkh3bnB0SUh4QVp4TUJRTWZXZWpWOHVja2hsSXhaQ2hXJTJGb01mQ2dTcHBpSXNlbFpLQ1dpRnJuTU8xeHdOdFlOU2t3UURWWEUwWER4RWFtWWFHZlJZcXl6NW5URXhkd1BxVlNuSWo3UmxENUpHQUVHaGdNaGwyYUk2QlFXYTJOM0MwWXhGVUZFb09RU3UlMkJRdmRJMElKZ3VMOUpxWG1yWU5GRmJrekRGcXNtaGNlQzZKeGdmRDlSJTJGdzNyWjR0MmlHT0xqUUNZeVd6Mm1TTUw5T1l2WUNCRmIlMkJiaVNsRW5SblJkQTVKb0ZUeFdaMTk2dVlNRjh3MlZKdzdqUTQ5ODVQTzNVblNacHJaWlpkcjNQVmxNOTJwYWdjZzdKY3BlSVVvYjlkcjQ2bDExQUtINUpFU0lUZFk1Z2ozdG1CelpIdXE1emJFJTJCWWY1SndjR3VkbnIzSWVId1BuN1VQanZHZHhmcDh1WmtlMkIzZDZCOGI3JTJCZkh2d1YxdlozdHd0eW5mM3ZmZ1BGJTJCMkZDd1dzYzdjZ0NZaEJFYXZpblFhSDFLbFFNWXA0amxFendvbHhhJTJGaXBJJTJCMFhxS1Fjdm1JaHBNYlA3V0JzUnZ6YWxGdHZGcFdyU0ZJaG1HRHpNRUZVNDltQVBxNTRncXQwcE0ybGhXajZXZmJ2RU51c3VQOHhsMDIwMjdUenZCUmVkeHVuaVc3alVWaDJ5d3V5cyUyRm1JclN2SExZTHJ2ODVmSmhySjNGM3RuWmF4N3o5cjUzayUyRlp2ZEFTNWVINW9nM3U0U3hLcTk5cDhnTzdpUiUyQkN3clE2Y3BQSEhlS3J4MUtDWjczbyUyRnNpdzFMOXFKU3dESXd2UzJ0YWo0UG1ZSzdDVTJuNlJ3cmlYcXptQ3JPWXVnWHQ3T2x2dSUyQjdyR2pYZVhQekNWVEpBTElpQXp4bnZkanZLaVpjJTJCN1ppTUlNVmxSdkdyQnFWV0xwZjl3VVhzdHp5UjR6ekJrUk5LZWVqV3oxWHJCb3ZZa0dnUDdOU0ZDbW1jWkFlSW5ZbFFXUE5LaTdwTnRSemYwJTJCQ1QxRFFXYVQzR214dWZTUWhHeHk5ZWVGQnMlMkZ4VEklMkJ0ZSUyRmpWRUJyOEIlM0MlMkZkaWFncmFtJTNFJTNDJTJGbXhmaWxlJTNFiT4mFAAAGh5JREFUeF7tnWuoF0Ufx39WHtHSIC0L6Zi+MchLiqmkUpkkQV6K0MDLiw54zzpleeuoebCyi6akaWWEJuhBvPXCDNNCDZU45g0SQjPyRaFBGoqW+vCb55n/M2fc/e/sfy8zu/tdiOr8Z+fy+c7Mfvc3s7vNrl+/fp1wgAAIgAAIgAAIgAAIVEygGQxVxexwIgiAAAiAAAiAAAgIAjBU6AggAAIgAAIgAAIgEJEADFVEgDgdBEAABEAABEAABGCo0AdAAARAAARAAARAICIBGKqIAHE6CIAACIAACIAACMBQoQ/kksCJEydo1KhRdPjw4SbtGzJkCK1bt47atm0bW7vPnTtHU6dOpfnz51OXLl1iyxcZgQAIgAAIZIcADFV2tEJNQxBgQzVt2jRatmxZ4iYHhiqEMEgKAiAAAjklAEOVU2GL3qxyhurSpUtUW1tLY8eOpf79+wtU9fX11LlzZxo9ejTt27ePBgwYIP4+YcIEWrJkifhvPqdDhw40d+5c8f8LFiyg6dOni7+vWrWKevToQRs2bEjcwBVdW7QfBEAABFwkAEPloiqoU2QCQREqXvY7efIk1dXVkRph4oJlZKu6urpkoqRx4t/ZYDU2NtKUKVOEgWrXrh2W/CIrhgxAAARAINsEYKiyrZ9TtW/WrJm1+ugv/PfbQ8VRJTZRHIXiqBQbq59++onWrl0rjNKmTZtoz5494r9btmwp0vFvb775Js2ePZsGDhwooliqCYOhsiY7CgYBEAABZwjAUDkjRfYrwobqiSeeIP73+++/Tw888EBijTp+/Di98sorIv8dO3aQl6Eqt4dKNUQNDQ2l5T42WGPGjGlSb97Ivnr1amHA5DIhDFVi0iJjEAABEMgkARiqTMrmZqXZSLGxWbx4sTA7/G/eXxT3IfNn0/byyy8LAxfWUHGd2CC1b9+efv75Z6qpqRF7n9SlQLXe+r4rGKq4VUV+IAACIJBtAjBU2dbPqdqrxoYjSNLsxBWtUqNSap6VGiq5+VxuPOclPn3vFZuuM2fOlJb8EKFyqsuhMiAAAiDgDAEYKmekyH5FvIyNHk2qtJXl8vEzVF7voVKfxOMoE++HYpPE/5aH+pSffG9Vq1atmjwZqEao5Ob1/fv34ym/SgXGeSAAAiCQcQIwVBkX0KXqexkbrl+UaJVfVEptt1+5LrFBXUAABEAABPJNAIYq3/qm2rogYxM2WmWaPqjcVCHEUBgvZ44fP55at24dQ27IAgRAAARAIA0CMFRpUC5IGSbGxiRaJaNScoN70NOCJuVmSQLey3X16lWxsZ9f1QBjlSX1UFcQAIGiEoChKqryCbQ7jLHxiz6ZRqXyvOS3dOlSmjlzJl27dk08wchPSsJYJdBhkSUIgAAIxEgAhipGmEXPKoyhYlZqtGrSpEn00UcflV67EBSVyrOh4rbxx5v//PNP0cyqqioYq6IPLrQfBEDAeQIwVM5LlJ0KhjVUsmUclfryyy9p6NCh4lULYQ+bb2gPW9co6Zs3b07Dhg2jjRs3RskG54IACIAACCRAAIYqAahFzbJSQxWVl61yo9a73Pn8ORt+NQMiVElSRt4gAAIgEB8BGKr4WBY+J1vGxla5SQnOe6hmzZolNqZjD1VSlJEvCIAACMRLAIYqXp6Fzs2WsbFVblJi4ym/pMgiXxAAARBIjgAMVXJsC5ezLWNjq9ykBMZ7qJIii3xBAARAIDkCMFTJsS1czraMja1yCycwGgwCIAACIOBLAIYKnSM2AraMja1yYwOHjEAABEAABDJPAIYq8xK60wBbxsZWue6QR01AAARAAARsE4Chsq1Ajsq3ZWxslZsj6dAUEAABEACBiARgqCICxOn/J2DL2NgqF9qDAAiAAAiAgCQAQ4W+EBsBm28s5w8p4wABEAABEAABWwRgqGyRR7kgAAIgAAIgAAK5IQBDlRsp0RAQAAEQAAEQAAFbBGCobJFHuSAAAiAAAiAAArkhAEOVGynREBAAARAAARAAAVsEYKhskUe5IAACIAACIAACuSEAQ5UbKdEQEAABEAABEAABWwRgqGyRR7kgAAIgAAIgAAK5IQBDlRsp0RAQAAEQAAEQAAFbBGCobJFHuSAAAiAAAiAAArkhAEOVGynREBAAARAAARAAAVsEYKhskUe5IAACIAACIAACuSEAQ5UbKdEQEAABEAABEAABWwRgqGyRR7kgAAIgAAIgAAK5IQBDlRsp0RAQAAEQAAEQAAFbBGCobJFHuSAAAiAAAiAAArkhAEOVGynREBAAARAAARAAAVsEYKhskUe5IAACIAACIAACuSEAQ5UbKdEQEAABEAABEAABWwRgqGyRR7kgAAIgAAIgAAK5IQBDFYOUv/76K+3cuZP2799Px44do9OnT9PZs2fpypUrVFVVRe3ataOOHTtS165dqV+/fjR48GCqrq6OoWRkEYUAdItCL/5zoUf8TKPkCD2i0LN3LnSzxx6GKgL7zz77jNauXUtHjx6lIUOGUP/+/al79+7UqVMnYaJatGhBly9fFubq1KlTdOTIEdq3bx/t2LGDunXrRmPHjqXnn38+Qg1waiUEoFsl1JI7B3okx7aSnKFHJdTsnwPd7GsAQ1WBBitXrqRFixYJU8SGaMSIEaFz2bJlC/EAYDM2Y8YMmjhxYug8cEI4AtAtHK+kU0OPpAmHyx96hOPlSmro5ooSRDBUIbQ4dOgQ1dbWishTXV0dDRgwIMTZ3kn37t1L9fX1IpK1ZMkS6tmzZ+Q8kUFTAtDNrR4BPaCHWwSyWRuMI/d0g6Ey1ISjSTU1NbR8+XKaPHmy4VnmyVasWEFTpkyh1atXYxnQHFtgSugWiCjVBNAjVdyBhUGPQEROJoBuTsqCCJWJLAsXLqQ1a9aI/VJ9+vQxOaWiNAcPHhT7qsaNG0dz5sypKA+c9H8C0M2t3gA9oAfmteh9AOMoOsOkckCEKoAsd97NmzfT1q1bqUOHDknpUMr3zJkzNHz4cHr66adhqiLQhm4R4CVwKvRIAGqELKFHBHgWT4VuFuEbFA1DVQYSh1V58/muXbtSMVOyKmyqBg0aJDar4ylAg16sJYFu4ZkleQb0SJJu+LyhR3hmLpwB3VxQoXwdYKh8+PCGv169etGBAwcSXebzk4eX//r27UuNjY3YqB5iHEG3ELBSSAo9UoAcogjoEQKWQ0mhm0NilKkKDJUPnEcffZRGjhyZyAZ0067BG9UbGhro22+/NT2l8Omgm1tdAHpAD50A5rXwfQLjKDwzG2fAUHlQ5/d68L4pfgGn7YNfGMr7qfCeqmAloFswozRTQI80aQeXBT2CGbmYArq5qIp3nWCoPLjwm875ib443jMVtSvwe6r4yT9+0zqO8gSgm1s9BHpADz8CmNfM+wbGkTkr2ylhqDQFeOMfv8V827ZttrUplT9s2DDxNnZsUPeXBLo5011FRaAH9AgigHktiBDGUTAht1LAUGl6PPbYY/Tiiy9W9DmZpKRlg7d06VLavXt3UkVkPl/o5paE0AN6BBHAvBZEiAjjKJiRSylgqBQ1+Cvd/GQff8zYtYM/tsxP/FVXV7tWNev1gW7WJWhSAegBPUwJYF7zJ4VxZNqL3ElXKEN14cIFat26tS99Xqb45ptvaN26de4o9L+ajB49mh5//HEs+3koA93c6q7QA3qYEsC85k8K48i0F8WTLsgfmJRSGEPFL8vkR0+fffZZmj17tqexGj9+PD344INWX5XgJxo/avzjjz/Sxx9/bKJrbtL89ddf4uEA3j/20ksvUbNmzW5oG3RzS27oAT1MCRR1XmM+/F1Y/n6r34FxZNqLoqcz8QcmpRTGUDEMXo/es2cP3XLLLVRbW3uDsXr44YfpnXfeceLpPl08firmtddeo++//95E11yleeihh+jIkSPUqlUroRkbq+bNm5faCN3ckht6QA9TAkWd1y5dukS33347tWzZkubOnSvmtJtvvrkJNowj014UT7ogf2BSSqEMFb99nKFdvHiRqqqqRLRDNVb8rT5Ok8Y3+0zEUdOwg+YPM/O/i3Z89913NHToUOKQ7K233iomnpkzZ4pJiCck6OZWj4Ae0MOUQJHntbfeeovq6+vppptuEjf5s2bNEnNaixYtBD6MI9NeFE+6IH9gUkpZQ/XGG2+Y5JGpNLwuzZv95MHGio9x48bRmjVr6Pz586UO7VLDLl++TG3atCG+s7l27Rpdv35d/Fv9x6W/mdbRtM4ffPABnT59uiTJbbfdJtpeU1NDq1atclo3NoFXr16l+fPn07x5827oVjzO+Le8/M4XBJfHEfed119/nR555BGxDUA/+MsEbOLz8rvrevC8xvNb0Y5//vmHeFM+jxU+uF/yIW8W77jjjkyMozzpVs4ffPLJJ4FNhaFSDNWnn34qjIqrB0fU+G5G/hP0/5xOT5PVv23cuJF+++23JkaYDdWYMWPo888/d143rnheDJM+PnRDyH3O9XEEPdyZ5bi/8LKXyzeIJjd+Jmn0G82///6b/v333yZisAHmr2OsX7/e+XHEc1qejkQNVZ5AcVuCQnq4k3NT8WPHjlHv3r3FXSxHFDnaM23aNJozZw61bdtWRBRdjogU7Q7cdT0QoXJnnPOYZj3q6uqa3Cxm9cYv7A1sly5d6I8//hCC8NzGhovfg8hz29133415LcWuGuQPTKpSqD1UQZvOsGZt0mXST8NvVN6+fbswUlOnThWTTfv27UsVgW7pa1KuROgBPUwJFHkPFS8h8Y0hR7Z4+e+FF14Qc9udd94p8GEcmfaieNIF+QOTUgpjqEwei8RTFSZdJt00J06coCeffFK8g4vDy14PDEC3dDUJKg16BBFK93fokS5v09I4cs0P2vCrE9hI3XPPPU1OhW6mJKOnM/EHJqUUxlAxjKAXd+G9HyZdJv00vBm9Y8eOvgVDt/Q1KVci9IAepgSK/B6qt99+m/jFpvfee68nLowj014UT7ogf2BSSqEMVRAQvJk2iJCbv0M3t3SBHtDDlADelO5PCuPItBe5kw6GStEC305yp2OGqQl0C0Mr+bTQI3nGYUqAHmFouZMWurmjhWlNYKg0Uvi6t2nXcSsddIMeQQS2bNlCS5cupd27dwclzd3vGB/ZlBS6ZUs3GCpNLw6z8sS7bds2Z5Tkp9xGjBiBDyOXUQS6OdNdRUWgB/QIIoB5LYgQxlEwIbdSwFB56NGpUydau3atE9/0429djR07lk6dOuVWz3GwNtDNLVGgB/TwI4B5zbxvYByZs7KdEobKQ4GVK1fS5s2baceOHbb1oSFDhoi35k6cONF6XVyvAHRzSyHoAT38CGBeM+8bGEfmrGynhKHyUYC/8TVy5EiaPHmyNY34keKGhgbib4vhMCMA3cw4pZUKeqRF2qwc6GHGybVU0M01RbzrA0Plo9OhQ4eoV69edODAAerTp0/qavJr8Pv27UuNjY3Us2fP1MvPaoHQzS3loAf0UAlgXqusP2AcVcYt7bNgqMoQ5421ixYtol27dnm+oTspsfitrYMGDaIZM2ZgI3oFkKFbBdASPAV6JAi3gqyhRwXQHDgFujkgQkAVYKgCAC1cuFDsp9q6dWsqporN1PDhw8W+Kf4cAY7KCEC3yrgldRb0SIpsZflCj8q42T4LutlWoHz5MFQG+nAnXrNmjXjyL8nlPw6H8xN948aNg5ky0CUoCXQLIpTu79AjXd5BpUGPIEJu/g7d3NSFawVDZagNh1trampo+fLliWxU5w3o/JHM1atXY5nPUBOTZNDNhFJ6aaBHeqxNSoIeJpTcSwPd3NMEhiqkJrwxsLa2llq0aEF1dXWxvKeK38dSX19Ply9fpiVLlmADekhNTJJDNxNK6aWBHumxNikJephQci8NdHNPE0SoKtCE3wvCm9W7desmokn8FvOwB7+Nne8yjh49Kjaf4z1TYQmGTw/dwjNL8gzokSTd8HlDj/DMXDgDurmgwn/rAEMVQQs2RLyvik0Rv6iuf//+1L17d+I327Zr105EsjjydPbsWfGm8yNHjtC+ffvEC0PZjPF+KTZkONIlAN3S5R1UGvQIIpTu79AjXd5xlQbd4iJZeT4wVJWzK53JXwXfuXMn7d+/n44dO0anT58WJurKlStUVVUlzFXHjh2pa9eu1K9fPxo8eDBVV1fHUDKyiEIAukWhF/+50CN+plFyhB5R6Nk7F7rZYw9DZY89SgYBEAABEAABEMgJARiqnAiJZoAACIAACIAACNgjAENljz1KBgEQAAEQAAEQyAkBGKqcCIlmgAAIgAAIgAAI2CMAQ2WPPUoGARAAARAAARDICQEYqpwIiWaAAAiAAAiAAAjYIwBDZY89SgYBEAABEAABEMgJARiqnAiJZoAACIAACIAACNgjkDlDtW7dOhozZkyJ2BdffEGjR4+2R1Ar+cSJEzRq1Cg6fPhwk1/4Tepc97Zt2xrV9dKlS+K7gQMHDhTt4+/9zZ07N3Se/GZ2fps7fyewZcuWvmVz/p07d3aGpa4zV7xHjx60YcMG6tKlixHDLCVyjb/Orgh6yDG3atUq0fwJEyYEjhtbfawIethiG6Zcvc+o5ybdf/haM3/+fPrwww9vuK549Q+u24IFC8R3aE2Pc+fOiWsCn8MvqPa6tplcg03mt3LtMa2v7XSZMlTcSdgcSGMixeZPuLhiqrhTTJs2jZYtWxbpwu9lqLizqIOBOZw8eTLUAPHrcCYdPs3Oym3bs2dPkwuaqTlMs55xlCXNssnEFEd5leRRBD24jXzwXKKPv0qYJXlOEfRIkl8Secc195vWLchQ6fOnab5qOt1Q6dc2/n3q1KnC2EW90YWhqkShCOfwhcfLVKgdR43kyAuUnBzZePH39tROwJ+IYdf++++/i8/CcCSHX90vnbh6l8EX9AEDBpS9ew0aVJwH31HwsX79+huiLrL+zz33nEjz1FNPlSJUettVg8G/cURL3l3v3btXtFVN895779GFCxfo66+/FhE02bZNmzaVon6uXNS9LhjqgFuxYgUdP35cRKxknb20l91N/U2y0e8u/f6u9yPJWGXl1ze4XL2esk6y/A4dOog/uRQh1IdpEfQwaXOE6SvWU4ugR9BcGSvQGDLzmvvVSJEaYdfnhWeeeaY0f8u5n40Kz+Fe89T9998vrgv8XViv1Q+v/qE2kcv3uhbwKoZaHl8jfvnll1KESjdU+rW13DzI85tsJ895csWFr7+TJ08u254Y5Ekli0xFqKRYfqFUNYLFRolN0fLly6lXr16is/oZqilTppSWknTHLSM3vXv3LkWe+Dt8nB93Cj18amKo2JTxxVvWS+bjVf9XX33V11CpBpP/+8yZM8IQNjY2kmwTc5BLfmyomCGXo/LhQZuFCJU6SXBbZHt5EvDTntumRvJ0UyZNKnORzH744YdS5I/7w5w5c2jhwoX01Vdfef7dq69JTVVdsrTkamIu8qwHt9/rBi6VWdmgEK8LZt70kPO911xpgCj1JPrcz/XnPiRXVPzmazl/ycAAz9/yGiHnZq95iv9WbsmvXISK61LuWqBeS2RdeMlPN1Rqm7k++jVXnQdVQ8Vp9WtVufakLmaFBWbKUHEby+1z0E2B7MDTp08va6jUTu+3rKRPYH7p/PZQybVrfZCpF3uv+suohdceKmksZXRKGkZ1ueK+++5rYqjkwNTvLFw0VOpeOa63eiemX+xMtZfjRA1lq3eBzJDvyLyWUv2WWPW+oGrMkTTJvNwYdY2/l6Eqkh76OK1wfk3sNK89MnkbH+XmysTARsg46GZan+v95mJ1bpaRKL5x1+cpNjhh91DJKLw6f6rl6cEH9Te/PVReqyFsEvV5UDVUcm+wGsCAoYrQ+eI6VTdNUijOX3bgIEOlbtr2C5UGTWCyPUGDSr/46nVU669eZMvdLevmQN5dcwfWDZU0aFkwVEF3WHpbvLSXoWQ5IemGikPm6uG1fCgnDMlVhqrl3/U+o0fBTJbysmCoiqKHGq2Mui8krnnOy+DmXQ+/uTLMpuqk+Hvlq8/9XhvW5Y21Ot7L3dypS3v6PMWrJlEiVF7XgiADV25/sMk8KJf8vFaLYKhS7K3cOefNm0c1NTVNNr/pe4TUi5dfhErt+OqSmHTVXk/FmW4Ar9RQ8SQRFKHyi3To5qhchCqPhko1kPLhBD/tVUNlspnSb9Olvg9P7TNed2ZBD03kyVBlWQ916dj0idwUp8FSUSZ7ZPS50GRudGl8ZN1Q6Rr5rUb4zd9sOtjg+M1TUTalq/NNmAhVOUMVFKlXI1QwVDZmDa1MvYOqm3rZkATtoVL3Kr377rti35RuqHRDJC/MI0eObLJ+7Lc3JoqhUi/Ecl9OuT1UKh7TPVR5NVTl9lCp0T1Vn4aGBoGQ+45cquU9d7t27SptEFf3UPHyneSn/j1oD1XRIlQyOiyfyPXar6dyl5O0bT1cX+ZTx3tYQ5XF8ZEnQ3Xx4kWxF5aX7bxunlU9y+2hUuepoCW/sBFMaXL86uK1h0rtk2rd9P3B0sAhQuWAkdInEnUvh/5eDXWvkfoUlrq3afHixXTw4EERLtUNFZfl96SC+ne/90r57aGST3jo5emRL1l/zp//ueuuu3w3patc/J5Y84vg6XdFcknT5af8dAOpGxU/7cM+zSdD8HI5UC7t+f29XJ8xjTyZprM1HMNewPXlUbVfuapHuX2K5R4osKFJEfTIuqFS5wueyydNmkTbt28Xm7H5oRp1/lLHBN9Enz9/vvQQlT5e5FiS+csbGDWi6rVFhdPJfbdq+X4RMn6amdO3adOGhg8fLt5DFfRKINOn/LwiVJy/jOTLjfw2xlaUMjO3KT1KY3EuCIAACIAACLhMIGiVw+W6F71uMFRF7wFoPwiAAAiAgFUCenRUfRDGasVQeCgCMFShcCExCIAACIAACIAACNxIAIYKvQIEQAAEQAAEQAAEIhL4D1cdEWQnzIrwAAAAAElFTkSuQmCC" width="596" height="112" class="img_ev3q"></p><h4 class="anchor anchorWithStickyNavbar_LWe7" id="producer生产者">Producer（生产者）<a href="#producer生产者" class="hash-link" aria-label="Direct link to heading" title="Direct link to heading"></a></h4><p>用户可以创建以下类型的生产者</p><blockquote><p>同步生产者：处理线程阻塞，直到生产者完成事件处理。</p></blockquote><p><img loading="lazy" alt="Stream Sync Producer" src="data:image/png;base64,iVBORw0KGgoAAAANSUhEUgAAAXMAAABwCAYAAADsWZCIAAAGbnRFWHRteGZpbGUAJTNDbXhmaWxlJTIwaG9zdCUzRCUyMmFwcC5kaWFncmFtcy5uZXQlMjIlMjBtb2RpZmllZCUzRCUyMjIwMjEtMDctMjVUMTUlM0E0MyUzQTA0LjI4NlolMjIlMjBhZ2VudCUzRCUyMjUuMCUyMChXaW5kb3dzJTIwTlQlMjAxMC4wJTNCJTIwV2luNjQlM0IlMjB4NjQpJTIwQXBwbGVXZWJLaXQlMkY1MzcuMzYlMjAoS0hUTUwlMkMlMjBsaWtlJTIwR2Vja28pJTIwQ2hyb21lJTJGOTEuMC40NDcyLjE2NCUyMFNhZmFyaSUyRjUzNy4zNiUyMiUyMGV0YWclM0QlMjJwLTkzWWctTTI2TTR1M2hqWWxZSyUyMiUyMHZlcnNpb24lM0QlMjIxNC45LjAlMjIlMjB0eXBlJTNEJTIyZGV2aWNlJTIyJTNFJTNDZGlhZ3JhbSUyMGlkJTNEJTIyLXRBSFh4Y2RhV0RrOEN5Q1ZMYWslMjIlMjBuYW1lJTNEJTIyUGFnZS0xJTIyJTNFM1ZoTGM5b3dFUDQxSE1QZ0I4UTVFaURwSVpreXphR1BDeU5zWWF1VnRSNVpnTW12cjJSTGZnSWhLVFJ0RHBsNFA3MjgzN2U3V3ROekpuRjJ6MUVTUFVLQWFjOGVCRm5QbWZaczI3SUdudnlua0YyQnVNTkJBWVNjQkhwU0JUeVJaNnhCTTIxTkFwdzJKZ29BS2tqU0JIMWdEUHVpZ1NIT1lkdWN0Z0xhUERWQkllNEFUejZpWGZRckNVUlVvSjd4UXVHZk1Ba2pVVHFzUjJKa0ptc2dqVkFBMnhya3pIck9oQU9JNGluT0pwZ3E4Z3d2eGJxN0E2UGxpM0hNeENrTFZ1UGQlMkZIbjV3M3NNRnclMkYlMkIzTjNZWHo1UHI0YkZMaHRFMTlwaCUyRmJKaVp4akFnU1JFbThCRkJDRXdSR2NWZXN0aHpRS3NqaGxJcTVyekFKQkkwSkxnVHl6RVRxdUwxZ0lrRkltWTZ0SGlUSFhRUWQ4MGxNS2ElMkIlMkZpSVElMkZyOUJlSWhGa2ZtdWFVQ01uUXh4Rmp3blZ6SE1VV0NiSnJ2Z1hRTWhlVzhpbWI1b0psJTJCQmV0MmglMkZVNUJ4JTJCbktmQU8lMkZSdk1CWkh4JTJCSUNXbU00aEpZSUFrME5MRUFKaVNaNlpNS1lrVkFOQ2tWNW5Wd1plb2phTHMxRGxhSDlGWWV0SGlJcyUyQnNDc1Z3QXVPVjFoU3JZalZXcWhOY1haY2pTNTdab0dyUTE3bnZIV3Q3VzJWUVFhS2FzbGpzTFB6N2U3ak8xajclMkJFUFE3ZGolMkZHTjJqbDR0S0tqajhLaXVxZlNxRGlERVFTRW15VUd1UTFvRGlsZlRwbHJZMDQ0V3Z0d2tRSmpDZmJTU2hhYVBrJTJGQm52N3JESnV6ZnM4Rzd2NGQyOUZPJTJGZUNjV2NCV04xSzByTHB5aE5pZCUyQmtYcnJPZDk5MEpjJTJCTjc4cm9ENDA1emVxRDA1MjJUcSUyRmdMMVptYTdDZjlScXJ3ejJzR3V6a0NxNVBtS3ZncUlrNmFvbDYwMUtydUlIMHF2cDEyOXFvYkhRT2JWUVEwZGtvVjc1MCUyQiUyQjNCWUJxb28xbG9FazFlUFhrZlZBJTJCRmJVUUVma3BRZnQxdVpTSTJoMkV0S0dGNFV2WmRnJTJGTmtsZXUxZVBPNjFjelpvNzk5cWF5eXJJOUJaTmxTdnh1UnpobnFVMFpFV1o3a2M2MDZTYXNxVHNwNGZXMTZzYnUwRGxEJTJCZDJxVE8yZ3BPbnBqYlhLdVd4dTFOYjkwYmVvMlpQOUZTcFdFbTlvMGV1JTJCVU91SDd6UkJKNGc2TmIyeDI4NTNHYVZKeHElMkZlV1o0VFNENThTeWFtTW5MdDdqUGpDc3IxTSUyRnZVVEZwNUJBNnV0d2MxcEdqZ1gwNkRiN3VhZFprY0k2Yk5vTmJwNUZ6d0JLciUyRjduQ2tEcHZSWkVVcGJrT2x6ZmF6NjJEMjZ4Q1FJOGslMkZ4ZlluUiUyRkR3JTJGZ3dST3F3NVp3NjRFN25uU1FKclZMeVJGJTJCYWwlMkJaM0ptdndFJTNEJTNDJTJGZGlhZ3JhbSUzRSUzQyUyRm14ZmlsZSUzReLzi6YAAB6PSURBVHhe7V1pkFRVlv5yqb2gqEVKFgvpZZBmDcARKUCjB6FHlJiObgeU5oehtvsGOK3Y2Io22NEitiJqq+MPFEWijekWGBkZtVEUN1pFGgmdVlGoKskqas31LRPnFq9IkqrK9zLvWzLr3LAiMfO+c+/97nlfnjzv3HN8uq7r4MYIMAKMACOQ0wj4mMxzev948owAI8AICASYzFkRGAFGgBHIAwSYzPNgE3kJjAAjwAgwmbMOMAKMACOQBwgwmefBJvISGAFGgBFgMmcd8BwCBw8exMKFC/Hxxx+fNLd58+bhueeeQ3V1tbQ5Nzc344YbbsDdd9+NMWPGSJPLghgBpxFgMncacR4vLQJE5jfddBMefvhh2wmWyTztdnCHHEGAyTxHNmogTbM/Mo9EIrj11luxZMkS1NfXC1juvfdefO9738PixYuxe/duzJw5U7x/9dVXY926deLfdM2IESNw1113if9ftWoVli9fLt5/4oknMGnSJGzevNn2L4+BtI+8VmcRYDJ3Fm8ezQQC6SxzcrX84x//wMqVK5FsWZNow6Kvq6vrIXCDtOlzIve9e/fi+uuvF+RdU1PDbhYTe8JdvI8Ak7n39yirGfp8vqyuz+biTA8X9+UzJ2uaCJysb7LGidQ/++wzbNy4UZD0Sy+9hDfffFP8u6SkRPSjz1avXo0VK1Zg1qxZwnpP/gJgMs9mh/laLyHAZO6l3bBhLkTmc+fOBb2uXbsW48aNs2GUbpH79+/H0qVLxVg7duxANmTen888mYxffPHFHhcLkfsvfvGLk9ZHD02ffvppQf6Ga4bJ3DYVYMEuIsBk7iL4TgxNxEqk+uCDD2LZsmWC0IlwZbdU+ca4mYyTzs1CMomca2tr8cUXX+CKK64Qvu5k90vyuKl+dibzTHaFr/E6AkzmXt+hLOeXTKrJlrMsK70vmXaTufGg03jISW6V1C8BIvzDhw/3uFnYMs9SmfhyTyPAZO7p7cl+cr2RqiwrvT852ZJ5b3HmyREnZF2T/5sIml6NlhzNYsSll5aWnhQBk2yZGw9K9+zZw9Es2asbS3ARASZzF8F3Yui+SDUbK93MtdmQuRO48BiMQL4hwGSebzuasp50pGrVSjfbP924eQ47L48RcBwBJnPHIXd2QDOkasbSNtMneWVmxnUWCR6NEchvBJjM83t/RZig2RDBvqxu4316pROTZpqVcc3I4z6MACPQPwJM5nmuIVZJNdkCv/baa7Fhw4aMYtStjpvn28DLYwRsR8BRMm9oaMD7778vsuFRGNmXX34Jeq+lpQVdXV1QFAXBYBBlZWWoqqrCsGHDMHr0aBFDTJEMZ599tniPm3kEMiVVssJffvllLFiwwLQ1PtDcLKzP5vWQe9qPgO1kvnPnTmzbtg30euTIEZxzzjmYPHkyxo4dK4h6+PDhIqUpETgRORE6ETuFj1F/IvwDBw7go48+wrvvviv6z5kzB/Pnzxev3NL89LLgZpGJZaZfIjLnYIcs1mc7UGWZMhCwhczJ6n7mmWewadMmQb4XX3wxKOZ32rRpWc/5gw8+EEfFyWoksr/ssstw+eWXc7a7PpB1i1TdGjdrBetFAOuzHaiyTNkISCXzd955B3/4wx/w6quv4sorrxR5MiZMmCB7zj3y9u3bh2effRZPPfUULrjgAtx8880499xzbRsvFwW7RapujStzj1ifZaLJsuxGQAqZk+VCR6d37dol8n5Q5RZymTjVyDWzfv16kX9k9uzZIrMeV43pRt8tUnVrXBk6x/osA0WW4TQCWZM5kTilJqWyW3feeafT8z9lvN/+9rdiLlSEgEh9oDe3SNWtcbPdb9bnbBHk691CIGMypwT/N954o/CJ/+53vxNpSL3SqHDBr371K+FTf+SRRzBlyhSvTM3xebhFqm6NmynArM+ZIsfXeQWBjMicfNRXXXUVHnvsMVxzzTVeWcsp83j88cdBsdJPPvmk8OEPxOYWqbo1biZ7zPqcCWp8jdcQsEzmd9xxB7Zu3SqiVWREp9gNCEW/ULTLRRddhDVr1tg9nOfku0Wqbo1rdQNYn60ixv29ioAlMqciAHRQ4vnnn0dFRYVX13TKvNra2nDppZeKA0dUdWYgNbdI1a1xrewt67MVtLiv1xEwTeYUZqiqqiDyXG1E6IFAQIQzDpRGpOpWM5sTxo35sT67gXr+j+nm/WaKzMmCCYfDOU3khhoRoVOxgoFmoef/bWR+hazP5rHintYQIDJ3q+ZuWjInnyLlUtm+fbu1VXm494UXXihyvQxEH7qHt8WRqbE+OwLzgB3EcC9mkmnUCmip8mncfsmcnvLTic633norp3zk6UAhH/rMmTPFidGBGuWSDqN8/Jz1OR931VtrSn5WZLUGgJmV9Fdzt08yp7jbqVOniiyHuRC1YgaI5D4U5UJZGD/88MMBHYduFbdc7e+0Pr/xxhv461//agqu8847D+eff76pvn11Yn3OCj5pF/f24F+Wld6fnH4t8/r6elEs18tx5NnuAMWhb9y4EVQEmFt+I+C0PtMp5HvuuccUqL/5zW/EqeVsG+tztghmf31fUVzZWOlmru2TzOlI8yeffIItW7ZkvzqPS7jkkkswceJEPvrv8X3KZnpu6LNB5masbrLKs7XMDXxYn7PRlPTXrl27Fr/85S8xaNCgXjunC8m1aqWb7d8rmVOSofHjx4viEV46op8e5sx60NF/Ssr16aefcnKuzCD09FVu6bNB5rKsbrMgsz6bRSqzfiUlJSJEe9myZVixYsUppJ6OzGlUM5a2mT7JK+iVzCn+lgpHeCFpVmZwW7+KknNRAYyBFH9uHaXcvMItfXaLzGmXWJ/t01UKCLn99tuhaZrISEo1cZNJ3QyZG7Pry+o2a433S+aUv3nhwoU4dOiQfWh4VHJdXR02b97M+dA9uj+ZTMtNfXaTzAkr1udMNMbcNVQZjUpdUissLDyJ1AcPHmy6gHqqlZ5tzd2TolkWLVqE6dOn45ZbbjG3Kht6xRu3ItFxCL7i7yM45EcIlpwGf7DYhpFOFvnQQw9hz549eOGFF2wfiwdwBgE39dkKmdODUhkPQJ1BlUfpDYGCggJRL/dPf/qTJTJPttKzrbnbQ+bkW5wxYwaampocLSxxAhgdWrwZyuGnoXQ1Qwl3IhFVgcLhKDp9GopqJiJYfBp8gSKquCBdo6jARW1tLd5++232nUtH13mBbuuzFTK3Ax3WZztQ7ZZZU1MjahTLsMxlzfIknzn5gSiXBuUmt6fp0DUF8dB7QMFpKCgfAV+wBD6fv3s4XYPa+jbUY7ughFu7yTzcCS0eQ9GQQUhEwvAXnYlA5RSUDJ+BYNlQ+PxyqxlRDnQC5f7777cHApbqGAL263P/S3GbzGl2rM/y1Y185nSKmB6CZuszlzm7k8icfGzbtm2zqWanDl2JINa4HcrRd6BEO6H5qxCsmIjiYfUoKK2EnghBbXkVWrQJaqQDSqQTSiQMXdPg92tQwhFoig41rqNw1L+hatIi+AuKZOIBqik6f/78AfnMQCqQHhBmrz6nX6AXyJz1Of0+We0hI5rF6phm+veQ+c6dO/HrX/9a+IzlNyLyTsS/+2+ox/ZCjUV6/rREHL6CMgwaNR5FFXXQtSjUaBvinc1ItIegxroQKChFNNQALaFBS+jQfINRXb8cpcPtKRRNzwzuu+8+zJkzRz4ULNERBOzVZ3NL8AKZ00xZn83tl9le2caZmx3Har8eMqfwGvIDyQ9H1KEnjkE99r9Q2/cfJ/GoeCX3ib+wCIXlAUCLo6h6KgLFg4QFr8c7EOs4hnDoOygd7VAjcahE5nEVgWGzcPrsaxAsGWx1vab6U1hXKBTCunXrTPXnTt5DwD59Nr9Wr5A567P5PZPR00pooozxDBk9ZD5hwgRbKgfpugql7V0ozf8Dn6pAjccFiavxGAKFxQgEY9CVMDQF8AfL4S8dgURbIxKdROARqHFVWORqQoUW15CIAyN/uhbFQ39wwtcuExEARmUi+onKLTcRsEufraDhFTJnfbaya9n3dZXMjxw5otOJT+PpbPbLOVmCFjuCxOH/RKLt/6AmAtD1AgRLKxDQ26AlItAVHZqidf8J4tahEXmLf2vdhB5XxWu8M4rBExegtv5SBMtq4PMXyJ6ukEdxpHQilCoTccstBKgSlp36bBYNr5A567PZHZPTz1Uy//Of/6xTgh678pXrWgKxpj1o/3gDtHgEOvwYNGoMfGoImhKHLsg7mczVHkucCFxNkEWvQokkoMYU+AIBDJ89DYU1Z8JXNgFF1ZPgLxgEnz8gZzcAUL5zSjBGcaPccguBv/zlL7BTn82i4SUyZ302u2vZ93OVzFetWqVHIhGsXr06+5X0JkFXEG89gPa//R7tR1qgtMcQKCpB9VnD4fdHocWVbktc6XankDWuqxTGCCiROJRoAkr0eJ/jpF8ytBK1U78PXU0g1qUirozEyHkrpc2fjufSU+uVK+XJlDY5FtQvApRUy1Z9Nom/l8ic9dnkpkno5iqZL168WJ83b55Id2tH0xOtiB3aiK5vdyMRVhDvTCDalkDZ6SNRXqmJiJVutwoROqBEgcLBfnEuKNoWh89XiHhnGNGWzhMWvAoUVw0W14SPdkDRSjD9969Jmz6lxd2xYwfnapGGqHOCKBeLnfpsdiVeInPWZ7O7ln0/V2uAzpgxQ6eDQlR5R3rTdagd+xD5v0cRa28TZC7+Ijoq6kYi4GuHGosej1QBju4Loeu7TgQKfKg6qxJVZ1VDiemIdwIdX4WghOPHLfhu/3q3e0aHXjAI0x94Xdr0qbISHbjgPOfSIJUmKF1oGOUtt02fLazCS2TO+mxh43K4q2/06NE6xeXake5WxJc3bkG88TXEuxI9ZA5fCQadXgY90QE1TgeCdDR8QFEsUQQK/fAX+FFQVoDqcXRStAjRYzHEOzWEG1q6H4YaRG4TmVMaUYozp1du3kIg3aEN0mO79NkKEl4ic9ZnKzuXu319FRUV+tdff21DjU8daud+KEeeQby9CfGu41Z5WEF53Rj4lQZosSgSYRWh/S2ItUYQKArAX+hHoCAAf9CP0tOHomb8KESbj6Lz20a0H+omf7vJnGqEjho1Cq2trbm7s3k683QpSIcMGQJ79NkaoF4ic9Zna3uXq719wWBQPAANBuXkOdGUCLRYCInQW/ArX0OJt0ALh0RYYSIcB3xlKKsuhJboElEqsdYEjn3eAvh1QeKBwm5C9wf8KBpSjSE/PAPR0Hfo/LbhZDInUqdwRj0IrawWM+79L2l7QEmKyAJMJBLSZLIgeQj0l4K0qqpKPACVpc+9zdpMObjXX39d1AB1ujhFb/NlfZane16WROkHdUqwJauFP1+DWPNXCBYWIlhSjmDpIHFASInH0fbtNwgWFCCAFugKRapo6GqIId4R7rbIDau80C9CDYMllSiqLEO8vRVdh4+i40iXODykKoBeOgzV5/wMtZN/jILyIQhIztPi5oMMWXsxkORkm4LUClZWUtZ6gcxpbW5FWVjBlftmh4B0yzz6+Z1AolEkyFLVAvgKq1FQWgFN6YQeb4YeC0OlcERFFT70SCgqIlfIT25Y5WSh61ohSoYOhxqPItbagmMHGxBri4uHniiqxMgFK1A1dkZ2q+/jarZkbIFVmtD+UpCyZX4qzKzP0lTP04Kk+8w79/0H9FijSGlLzV80CIXlxdDjrcItoh8/2UlkrsV1kbPcd9zFYvjLKbWtv3A4AkWFiHe0oKvxO7R81iiscopHLx/3rzjjJzegoGyILeCyj9EWWKUITZeClH3mp8LM+ixF9TwvRHo0S+v7t0DtaoJ+nMzp6H5ZDUWunErmdLS/oKwCauwYgkXdUSw+fxH8ZRMQLCoHlA5EWxrQ+ME+REId3aGIviKc8dO7MWRMvfjpaEfjp/92oCpHJkezWMeR9dk6Zrl4hU92nHlo13WIt3/XY5mTP7vijApA6YXMVR/8haUIlg6BluhA8dBx8AdLAB/V1SMuD6Hpgw/R2dgkQhKJzP2n/Qg/WHgfCgefZhveHJdrG7RZC+Y4c+sQsj5bxywXr/DJPgF67KP16Prmb1C6WkBHOouGVKL6h1WA2iaiV3Q6ti+Sa3VnQtT1AIqryTeeQEHFKBQNHiLiz+PtYTT//QDC3zV2+9gTGpSEjlH/vhaDzpwMf9CeJFu0iXxiLhdVuXvOfAL01L1jfXZOn+3yFphZgU92bhZyr1DYYbTpU3R8sRNa5AiqR2rQOpoQ69KAwWcg4O8QSba6feA6NM0HXaPY8jIRwdLV8I0oG6dEux94ihS4xw8InX7hClSN+zH8wUIz68uoD+eyyAg2T1zEuVlO3QbWZ+dUk8h87ty5wgVMvyLHjRtn2+D79+/H0qVLxViUfsRnZ9ZEqvlJDz6Vo9uROLoTsY44YhEfyk8fAS3SCC1Gx/P1HrIWSbZ6HpDSlwKR+InPidADZUNR97N7UTbyR7aBxFnmbIPWdsGcNfFUiFmfbVe7ngGMENAHH3wQy5YtA71SsRTZLVW+KE5hdz5zimpROr9C2967oUQiInoFgTKU1xSJikLJlrcZMicXTeXZizDiX65AoLBENkZCHucztwVWR4RyPvNTYWZ9dkT1xCDJ8fzJlrMsK70vmbZXGqLFUX6W2KFNaD/4CiLNMURbY1BUP6r+aTSKy+gQUKwXy1wVaW+J3EH/9RSuUFFQOxF1F9+GktNG2VJtiCuzOKf4do3ElYZOIMv6bJeW9S63t8NZsqz0/uQ4UAMU0DoPIvz5eoQbDiPSEkW0OYrIsRhOm3wWSqpi0JPIXImoQLASut6OYLEPSkxDZ0MHfOSKiasoOmM66uYvR8GgGluInLaHayY6q/x2jMY1QE+gyvpsh4b1LbOvk7bZWOlmru0hc7uqmetaHImmrYh98xIioXAPmdPJ0NrJw+APRIVfXCTOQiUq//l2UQ5OV8OINL2HyLfvoePQAUSPtqN0VD3O+MlSBEoG20bktEVczdxZ5bdjNLv02cpc7Uy01dHRgT/+8Y/CJ5uusT6nQ0ju5+nSJli10s327yFzWk5dXR22bdsG+okqrYnIljYoxz5B+Otd6Px6H7oamlExZiyKy9qhK9Hj0SwFKB51Ccp/uOBE+Tddh6bGkOhsRue3f0flmFnwB4vIKSVteqmCqIjz/PnzcejQIdvGYMHOIGCLPluYuh1kTiROFcHI/xoIBERCsf4a67OFDZPUNR2Z0zBmLG0zfZKnfBKZ33777ZRxSyT2l990UeJNjbSg6+s98Ef3CfeLqsVEdSEd5aicfj+C5UNtJet066KCFATK/fffn64rf+5xBOzV5/SLl0nmBomvW7dO3KNE5GvWrMHNN9/c70RYn9Pvk+weZsjcGLMvq9usNd4nmR88eBAzZsxAU1OTrelDaQJ6IgI1EkKs8T3EQ/sRqPg+Bo9bLBtXS/IoGVFtbS3efvttjBkzxtK13Nl7CDipz72tXgaZp5J4PB4XQ1F0SigU6hd01md3dNIKmada6ddeey02bNiQUYz6SZY5CV60aJHwGd9yyy3uIOHiqA899BD27NmDF154wcVZ8NAyEXBTn2WQ+c9//nNQ3Dzn1ZepFfbLyiSlOFnjL7/8MhYsWJBRXPopZP7OO+9g4cKFA9JnTD7WzZs349xzz7V/t3kERxBwU59lkHlfljml+W1ubu4XQ9ZnR1TslEGsWuayZnkKmZNgym0xduxY3HnnnbLG8bwcCt86cOAAnn32Wc/PlSdoDQG39FkGmRsrteozZ322piMye3uKzMnXOH78eNCrHUWeZQInQxalByUf+aeffsq+chmAekyGW/osk8xTSb2/aBbWZ3cV0FNkTlBQsqJPPvkEW7ZscRcZB0a/5JJLMHHiRKxcudKB0XgINxBwQ58NMj///PNBf/218847L22f5Ov7izNnfXZDw06M6Tkyp6nV19djyZIluOaaa9xFx8bRH3/8cZHudvfu3TaOwqK9gIDT+myQuZm1y6oTyvpsBm17+3iSzPfu3YupU6fi/fffx7Rp0+xFwAXplLPi7LPPxocffogpU6a4MAMe0kkEnNbnN954A/Rnppmx3tPJYX1Oh5Azn3uSzGnpTz31FKjmIlUqqaiocAYNB0ahmogzZ84Uhy6uvPJKB0bkIbyAAOuzF3Yhv+fgWTIn2O+44w58/PHH2L59e97sAuV3njRpkjhFx21gIcD6PLD22+nVeprMCYwrrrgC4XAYzz//vNPYSB/v0ksvRWlpKZ5++mnpsllgbiDA+pwb+5SLs/Q8mROoFK+rqmpOEzoROeW14HjyXLxN5M6Z9VkuniytGwFXa4DqFs6ekkVDlVzIQs8lHzr5yInIhw0bxhY533U9CLA+szLkEwI+K2Ru+NC3bt2KZ555JieiXIxKKxdddBH7yPNJcyWthXzorM+SwGQxriJgmcxpthQVcNVVV+Gxxx7zdBw6xd1SJrInn3ySo1ZcVTNvD8767O394dmZQyAjMifRFLd74403Yvjw4SIHupeO/tORZsrlfOTIETzyyCMcR25OFwZ0L9bnAb39ebH4jMncWD0dlV61ahXoxJsXknNRkiGay1133cVH9PNCRZ1dBOuzs3jzaPIQyJrMaSqUzIhugl27dmHp0qW44YYbbC9wkQwBJeJfv349KCfw7NmzBYlzgQl5SjLQJLE+D7Qdz4/1SiFzAwrKH00nRl999VXho6bwL6k1RVMwpxqHFGZIPs8LLrhAnOjkfOT5oZheWAXrsxd2gedgFgGpZG4MSpYNRbts2rRJ+NQvvvhizJs3T0r0C0Wn7NixQ1TlIJ/4ZZddhssvv5wtcbM7zv0sI8D6bBkyvsAFBGwh8+R17Ny5E9u2bQO9Evmec845mDx5siiAMXr0aEH2VNOwrKxMuGbIZdLV1SUqqVD/L7/8UhSO+Oijj/Duu++K/nPmzMH8+fPFKzdGwEkEWJ+dRJvHsoKA7WSePBk6cERZGCnXC1k7RNT0XktLiyBwInIidCJ2Ko1Fh3yI8Mn/TblUKMshvceNEfACAqzPXtgFnoOBgKNkzrAzAowAI8AI2IMAk7k9uLJURoARYAQcRYDJ3FG4eTBGgBFgBOxBgMncHlxZKiPACDACjiLAZO4o3DwYI8AIMAL2IMBkbg+uLJURYAQYAUcRYDJ3FG4ejBFgBBgBexBgMrcHV5bKCDACjICjCJgi8+eee07kWUludIhn8+bNfIze0e3iwWQjQAniKMNmcqPUE6TzdDI500bXv/nmm1i3bh1KSkoyFcPXMQKmETBN5qmKuXv3bmzcuJGV1TTU3NGLCBCZU6NMm0YjIqac+MnvWZ07k7lVxLh/tghkTOZ0HJ/yhlPq2Q0bNmD//v3CUqcshosXLxYpcQ2Lx3jPmGzyZ2+99Rbq6+sRiURw66234oknnhDd+nrfkJXaP3kM+qKZOXOmkHP11Vf3fOHQuKnzzBZAvj63EeiNzA1DZfXq1VixYgVaW1uFbpNOTpkypVc9JRQMvaNfrXPnzkV7e7vQvQceeEAUb6H7wtDbJUuWCL2nZuV+oDGofkBTUxOmT5/OxlRuq5/U2WdM5smWBynr4cOHexSLPiOrnV5DoRAWLlyIRx99VChvstWT+oVgWEiksNdff724gShLomElUfItKoBBBSheeeWVXt9PHs+48UaMGCGsLLppkucpFUkWlpMI9EbmxnvLly8XxG3oj0G8hg5RdSJDT+kzQ88NvaP30pG51fuB9NsYk3P256TK2TZp02Se6jNP9ium3hD0/4YlYtwA9GrcHMlWCb1PJE1WCxFuspVO/b766qtef/L29VM41f1D/0/zof70C8L4wrANURacUwj05jM3fs3RQojMZ82a1atVbVjZ9PmZZ555ktsxWQ/7sswN0rdyPxj3U7Y+/ZzaJJ6sKQRMk3l/D3OSyTtZwYmgqRnEe911151E2sYMDTKnPOXJrTeXjeF+6evnaaqvMtX6T/6SMYUQd8prBHqzzI0Fp7pEUo0OQweN+rfJ94gZMj/rrLMs3w+pXxp5vTm8OEsISCfzZAU3yDz1Z2tvlgiVmiMffH8/Helm6q1f8vv0MzT5wWyqZc5kbkk/8r6zFTJPJfdMLPPkL4T+LPO+7gcOPMh7lcx4gbaQeX8+8+Sbh6zmm266CQ8//DBefPHFHhcIvW/4H1977bUel02yz5xcJgYxJ7+fzmfOZJ6xruTlhVbI3DBUevOZ19TU9FjZvfnMk6+hh/PGL0yr9wPNgaPI8lIVs16ULWSe6gJJjjSxGrWS6oIxboK+3qex+4tmYTLPWmfySoBVMu9Lf1P1jqKyvvjiC9xzzz0Ih8OC6MmNeNttt4koF+PXqdX7gS3zvFI/qYsxReZSR2RhjAAjwAgwAtIRYDKXDikLZAQYAUbAeQSYzJ3HnEdkBBgBRkA6Akzm0iFlgYwAI8AIOI/A/wOxTwp5TbVvDQAAAABJRU5ErkJggg==" width="371" height="112" class="img_ev3q"></p><p>未来将会实现的生产者类型：</p><ul><li>异步生产者 - 生产者在子线程中处理事件。</li></ul><h4 class="anchor anchorWithStickyNavbar_LWe7" id="consumer消费者">Consumer（消费者）<a href="#consumer消费者" class="hash-link" aria-label="Direct link to heading" title="Direct link to heading"></a></h4><p>用户可以创建以下类型的消费者</p><blockquote><p>事件驱动的消费者：当消息绑定器调用消费者中的方法时，开始处理传入请求。</p></blockquote><p><img loading="lazy" alt="Stream Event-Driven Consumer" src="/zh/assets/images/stream-event-driven-consumer-a629cc38b5a439f4423c277c92bdecf5.png" width="462" height="92" class="img_ev3q"></p><p>未来将会实现的消费者类型：</p><ul><li>定时轮训消费者</li><li>自定义轮询消费者</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/eventmesh-site/edit/master/versioned_docs/version-v1.5.0/design-document/02-stream.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="/zh/docs/v1.5.0/design-document/spi"><div class="pagination-nav__sublabel">Previous</div><div class="pagination-nav__label">EventMesh SPI</div></a><a class="pagination-nav__link pagination-nav__link--next" href="/zh/docs/v1.5.0/sdk-java/intro"><div class="pagination-nav__sublabel">Next</div><div class="pagination-nav__label">安装 SDK</div></a></nav></div></div><div class="col col--3"><div class="tableOfContents_bqdL thin-scrollbar theme-doc-toc-desktop"><ul class="table-of-contents table-of-contents__left-border"><li><a href="#事件流概述" class="table-of-contents__link toc-highlight">事件流概述</a></li><li><a href="#要求" class="table-of-contents__link toc-highlight">要求</a><ul><li><a href="#功能要求" class="table-of-contents__link toc-highlight">功能要求</a></li></ul></li><li><a href="#设计细节" class="table-of-contents__link toc-highlight">设计细节</a></li><li><a href="#架构" class="table-of-contents__link toc-highlight">架构</a></li><li><a href="#设计" class="table-of-contents__link toc-highlight">设计</a><ul><li><a href="#eventmesh-stream-组件" class="table-of-contents__link toc-highlight">EventMesh-Stream 组件</a></li></ul></li><li><a href="#eventmesh-stream-组件接口" class="table-of-contents__link toc-highlight">EventMesh-Stream 组件接口</a><ul><li><a href="#component组件" class="table-of-contents__link toc-highlight">Component（组件）</a></li><li><a href="#endpoint端点" class="table-of-contents__link toc-highlight">EndPoint（端点）</a></li></ul></li></ul></div></div></div></div></main></div></div><footer class="footer"><div class="container"><div class="row footer__links"><div class="col footer__col"><img src="images/asf_logo.svg"></div><div class="col footer__col"></div><div class="col footer__col"><div class="footer__title">EventMesh</div><ul class="footer__items"><li class="footer__item"><a class="footer__link-item" href="/zh/docs/introduction">文档</a></li><li class="footer__item"><a class="footer__link-item" href="/zh/events/release-notes/v1.10.0">动态</a></li><li class="footer__item"><a href="https://github.com/apache/eventmesh/releases" target="_blank" rel="noopener noreferrer" class="footer__link-item"><span>更新日志</span></a></li></ul></div><div class="col footer__col"><div class="footer__title">社区</div><ul class="footer__items"><li class="footer__item"><a href="https://github.com/apache/eventmesh" target="_blank" rel="noopener noreferrer" class="footer__link-item"><span>GitHub</span></a></li><li class="footer__item"><a href="https://github.com/apache/eventmesh/issues" target="_blank" rel="noopener noreferrer" class="footer__link-item"><span>Issue Tracker</span></a></li><li class="footer__item"><a href="https://github.com/apache/eventmesh/pulls" target="_blank" rel="noopener noreferrer" class="footer__link-item"><span>Pull Requests</span></a></li></ul></div><div class="col footer__col"><div class="footer__title">Apache Software Foundation</div><ul class="footer__items"><li class="footer__item"><a href="https://www.apache.org/" target="_blank" rel="noopener noreferrer" class="footer__link-item"><span>Foundation</span></a></li><li class="footer__item"><a href="https://www.apache.org/licenses/" target="_blank" rel="noopener noreferrer" class="footer__link-item"><span>License</span></a></li><li class="footer__item"><a href="https://www.apache.org/foundation/sponsorship.html" target="_blank" rel="noopener noreferrer" class="footer__link-item"><span>Sponsorship</span></a></li><li class="footer__item"><a href="http://www.apache.org/foundation/thanks.html" target="_blank" rel="noopener noreferrer" class="footer__link-item"><span>Thanks</span></a></li><li class="footer__item"><a href="https://www.apache.org/security/" target="_blank" rel="noopener noreferrer" class="footer__link-item"><span>Security</span></a></li><li class="footer__item"><a href="https://www.apache.org/events/current-event" target="_blank" rel="noopener noreferrer" class="footer__link-item"><span>动态</span></a></li><li class="footer__item"><a href="https://privacy.apache.org/policies/privacy-policy-public.html" target="_blank" rel="noopener noreferrer" class="footer__link-item"><span>Privacy</span></a></li></ul></div></div><div class="footer__bottom text--center"><div class="footer__copyright">Copyright © 2024 The Apache Software Foundation. Apache EventMesh, EventMesh, Apache, the Apache feather logo, and the Apache EventMesh logo are trademarks of The Apache Software Foundation.</div></div></div></footer></div> | |
| <script src="/zh/assets/js/runtime~main.fa98e277.js"></script> | |
| <script src="/zh/assets/js/main.9ebd247a.js"></script> | |
| </body> | |
| </html> |