| </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.2.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.2.x/">3.2.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.2.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.2.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.2.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.2.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"><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.2.x/functions-overview/">Pulsar Functions</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.2.x/functions-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.2.x/functions-concepts/">Concepts</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.2.x/functions-quickstart/">Get started</a></li><li class="theme-doc-sidebar-item-category theme-doc-sidebar-item-category-level-2 menu__list-item menu__list-item--collapsed"><div class="menu__list-item-collapsible"><a class="menu__link menu__link--sublist" aria-expanded="false" tabindex="0" href="/docs/3.2.x/functions-worker/">Set up function workers</a><button aria-label="Toggle the collapsible sidebar category 'Set up function workers'" type="button" class="clean-btn menu__caret"></button></div></li><li class="theme-doc-sidebar-item-category theme-doc-sidebar-item-category-level-2 menu__list-item menu__list-item--collapsed"><div class="menu__list-item-collapsible"><a class="menu__link menu__link--sublist" aria-expanded="false" tabindex="0" href="/docs/3.2.x/functions-runtime/">Configure function runtime</a><button aria-label="Toggle the collapsible sidebar category 'Configure function runtime'" type="button" class="clean-btn menu__caret"></button></div></li><li class="theme-doc-sidebar-item-category theme-doc-sidebar-item-category-level-2 menu__list-item menu__list-item--collapsed"><div class="menu__list-item-collapsible"><a class="menu__link menu__link--sublist" aria-expanded="false" tabindex="0" href="/docs/3.2.x/functions-deploy/">How-to: Deploy</a><button aria-label="Toggle the collapsible sidebar category 'How-to: Deploy'" type="button" class="clean-btn menu__caret"></button></div></li><li class="theme-doc-sidebar-item-category theme-doc-sidebar-item-category-level-2 menu__list-item menu__list-item--collapsed"><div class="menu__list-item-collapsible"><a class="menu__link menu__link--sublist" aria-expanded="false" tabindex="0" href="/docs/3.2.x/functions-develop/">How-to: Develop</a><button aria-label="Toggle the collapsible sidebar category 'How-to: Develop'" type="button" class="clean-btn menu__caret"></button></div></li><li class="theme-doc-sidebar-item-category theme-doc-sidebar-item-category-level-2 menu__list-item menu__list-item--collapsed"><div class="menu__list-item-collapsible"><a class="menu__link menu__link--sublist" aria-expanded="false" tabindex="0" href="/docs/3.2.x/functions-debug/">How-to: Debug</a><button aria-label="Toggle the collapsible sidebar category 'How-to: Debug'" type="button" class="clean-btn menu__caret"></button></div></li><li class="theme-doc-sidebar-item-category theme-doc-sidebar-item-category-level-2 menu__list-item menu__list-item--collapsed"><div class="menu__list-item-collapsible"><a class="menu__link menu__link--sublist" aria-expanded="false" tabindex="0" href="/docs/3.2.x/functions-package/">How-to: Package</a><button aria-label="Toggle the collapsible sidebar category 'How-to: Package'" type="button" class="clean-btn menu__caret"></button></div></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.2.x/functions-cli/">CLI and YAML configs</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.2.x/window-functions-context/">Window Functions: Context</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.2.x/io-overview/">Pulsar IO</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.2.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.2.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.2.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.2.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.2.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.2.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.2.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.2.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.2.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.2.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.2.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.2.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.2.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.2.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 Functions</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">CLI and YAML configs</span><meta itemprop="position" content="2"></li></ul></nav><span class="theme-doc-version-badge badge badge--secondary">Version: 3.2.x</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"><header><h1>Pulsar Functions CLI and YAML configs</h1></header><h2 class="anchor anchorWithStickyNavbar_LWe7" id="pulsar-admin-cli-for-pulsar-functions">Pulsar admin CLI for Pulsar Functions<a href="#pulsar-admin-cli-for-pulsar-functions" class="hash-link" aria-label="Direct link to Pulsar admin CLI for Pulsar Functions" title="Direct link to Pulsar admin CLI for Pulsar Functions"></a></h2><p>The Pulsar admin interface enables you to create and manage Pulsar Functions through CLI. For the latest and complete information, including commands, flags, and descriptions, refer to <a href="/reference/#/3.2.x/pulsar-admin/" target="_blank" rel="noopener noreferrer">Pulsar admin CLI</a>.</p><h2 class="anchor anchorWithStickyNavbar_LWe7" id="yaml-configurations-for-pulsar-functions">YAML configurations for Pulsar Functions<a href="#yaml-configurations-for-pulsar-functions" class="hash-link" aria-label="Direct link to YAML configurations for Pulsar Functions" title="Direct link to YAML configurations for Pulsar Functions"></a></h2><p>You can configure a function by using a predefined YAML file. The following table outlines the required fields and arguments.</p><table><thead><tr><th>Field Name</th><th>Type</th><th>Related Command Argument</th><th>Description</th></tr></thead><tbody><tr><td>runtimeFlags</td><td>String</td><td>N/A</td><td>Any flags that you want to pass to a runtime (for process & Kubernetes runtime only).</td></tr><tr><td>tenant</td><td>String</td><td><code>--tenant</code></td><td>The tenant of a function.</td></tr><tr><td>namespace</td><td>String</td><td><code>--namespace</code></td><td>The namespace of a function.</td></tr><tr><td>name</td><td>String</td><td><code>--name</code></td><td>The name of a function.</td></tr><tr><td>className</td><td>String</td><td><code>--classname</code></td><td>The class name of a function.</td></tr><tr><td>functionType</td><td>String</td><td><code>--function-type</code></td><td>The built-in function type.</td></tr><tr><td>inputs</td><td>List<String<!-- -->></td><td><code>-i</code>, <code>--inputs</code></td><td>The input topics of a function. Multiple topics can be specified as a comma-separated list.</td></tr><tr><td>customSerdeInputs</td><td>Map<String,String<!-- -->></td><td><code>--custom-serde-inputs</code></td><td>The mapping from input topics to SerDe class names.</td></tr><tr><td>topicsPattern</td><td>String</td><td><code>--topics-pattern</code></td><td>The topic pattern to consume from a list of topics under a namespace. <br><strong>Note:</strong> <code>--input</code> and <code>--topic-pattern</code> are mutually exclusive. For Java functions, you need to add the SerDe class name for a pattern in <code>--custom-serde-inputs</code>.</td></tr><tr><td>customSchemaInputs</td><td>Map<String,String<!-- -->></td><td><code>--custom-schema-inputs</code></td><td>The mapping from input topics to schema properties.</td></tr><tr><td>customSchemaOutputs</td><td>Map<String,String<!-- -->></td><td><code>--custom-schema-outputs</code></td><td>The mapping from output topics to schema properties.</td></tr><tr><td>inputSpecs</td><td>Map<String,<a href="#consumerconfig">ConsumerConfig</a>></td><td><code>--input-specs</code></td><td>The mapping from inputs to custom configurations.</td></tr><tr><td>output</td><td>String</td><td><code>-o</code>, <code>--output</code></td><td>The output topic of a function. If none is specified, no output is written.</td></tr><tr><td>producerConfig</td><td><a href="#producerconfig">ProducerConfig</a></td><td><code>--producer-config</code></td><td>The custom configurations for producers.</td></tr><tr><td>outputSchemaType</td><td>String</td><td><code>-st</code>, <code>--schema-type</code></td><td>The built-in schema type or custom schema class name used for message outputs.</td></tr><tr><td>outputSerdeClassName</td><td>String</td><td><code>--output-serde-classname</code></td><td>The SerDe class used for message outputs.</td></tr><tr><td>logTopic</td><td>String</td><td><code>--log-topic</code></td><td>The topic that the logs of a function are produced to.</td></tr><tr><td>processingGuarantees</td><td>String</td><td><code>--processing-guarantees</code></td><td>The processing guarantees (delivery semantics) applied to a function. Available values: <code>ATLEAST_ONCE</code>, <code>ATMOST_ONCE</code>, <code>EFFECTIVELY_ONCE</code>, <code>MANUAL</code>.</td></tr><tr><td>retainOrdering</td><td>Boolean</td><td><code>--retain-ordering</code></td><td>Whether functions consume and process messages in order or not.</td></tr><tr><td>retainKeyOrdering</td><td>Boolean</td><td><code>--retain-key-ordering</code></td><td>Whether functions consume and process messages in key order or not.</td></tr><tr><td>batchBuilder</td><td>String</td><td><code>--batch-builder</code></td><td>Use <code>producerConfig.batchBuilder</code> instead. <br><strong>Note</strong>: <code>batchBuilder</code> will be deprecated in code soon.</td></tr><tr><td>forwardSourceMessageProperty</td><td>Boolean</td><td><code>--forward-source-message-property</code></td><td>Whether the properties of input messages are forwarded to output topics or not during processing. When the value is set to <code>false</code>, the forwarding is disabled.</td></tr><tr><td>userConfig</td><td>Map<String,Object<!-- -->></td><td><code>--user-config</code></td><td>User-defined config key/values.</td></tr><tr><td>secrets</td><td>Map<String,Object<!-- -->></td><td><code>--secrets</code></td><td>The mapping from secretName to objects that encapsulate how the secret is fetched by the underlying secrets provider.</td></tr><tr><td>runtime</td><td>String</td><td>N/A</td><td>The runtime of a function. Available values: <code>java</code>,<code>python</code>, <code>go</code>.</td></tr><tr><td>autoAck</td><td>Boolean</td><td><code>--auto-ack</code></td><td>Whether the framework acknowledges messages automatically or not. <br><br><strong>Note</strong>: This configuration will be deprecated in future releases. If you specify a delivery semantic, the framework automatically acknowledges messages. If you do not want the framework to auto-ack messages, set the <code>processingGuarantees</code> to <code>MANUAL</code>.</td></tr><tr><td>maxMessageRetries</td><td>Int</td><td><code>--max-message-retries</code></td><td>The number of retries to process a message before giving up.</td></tr><tr><td>deadLetterTopic</td><td>String</td><td><code>--dead-letter-topic</code></td><td>The topic used for storing messages that are not processed successfully.</td></tr><tr><td>subName</td><td>String</td><td><code>--subs-name</code></td><td>The name of Pulsar source subscription used for input-topic consumers if required.</td></tr><tr><td>parallelism</td><td>Int</td><td><code>--parallelism</code></td><td>The parallelism factor of a function, that is, the number of function instances to run.</td></tr><tr><td>resources</td><td><a href="#resources">Resources</a></td><td>N/A</td><td>N/A</td></tr><tr><td>fqfn</td><td>String</td><td><code>--fqfn</code></td><td>The Fully Qualified Function Name (FQFN) of a function.</td></tr><tr><td>windowConfig</td><td><a href="#windowconfig">WindowConfig</a></td><td>N/A</td><td>N/A</td></tr><tr><td>timeoutMs</td><td>Long</td><td><code>--timeout-ms</code></td><td>The message timeout (in milliseconds).</td></tr><tr><td>jar</td><td>String</td><td><code>--jar</code></td><td>The absolute path of the JAR file for a function (written in Java). It also supports URL paths that workers can download the package from, including HTTP, HTTPS, file (file protocol assuming that file already exists on worker host), and function (package URL from packages management service).</td></tr><tr><td>py</td><td>String</td><td><code>--py</code></td><td>The absolute path of the main Python/Python wheel file for a function (written in Python). It also supports URL paths that workers can download the package from, including HTTP, HTTPS, file (file protocol assuming that file already exists on worker host), and function (package URL from packages management service).</td></tr><tr><td>go</td><td>String</td><td><code>--go</code></td><td>The absolute path of the main Go executable binary for the function (written in Go). It also supports URL paths that workers can download the package from, including HTTP, HTTPS, file (file protocol assuming that file already exists on worker host), and function (package URL from packages management service).</td></tr><tr><td>cleanupSubscription</td><td>Boolean</td><td><code>--cleanup-subscription</code></td><td>Whether the subscriptions that a function creates or uses should be deleted or not when the function is deleted. The default value is <code>true</code></td></tr><tr><td>customRuntimeOptions</td><td>String</td><td><code>--custom-runtime-options</code></td><td>A string that encodes options to customize the runtime.</td></tr><tr><td>maxPendingAsyncRequests</td><td>Int</td><td><code>--max-message-retries</code></td><td>The max number of pending async requests per instance to avoid a large number of concurrent requests.</td></tr><tr><td>exposePulsarAdminClientEnabled</td><td>Boolean</td><td>N/A</td><td>Whether the Pulsar admin client is exposed to function context or not. By default, it is disabled.</td></tr><tr><td>subscriptionPosition</td><td>String</td><td><code>--subs-position</code></td><td>The position of Pulsar source subscription used for consuming messages from a specified location. The default value is <code>Latest</code>.</td></tr><tr><td>skipToLatest</td><td>Boolean</td><td><code>--skip-to-latest</code></td><td>Whether the consumer should skip to the latest message once the function instance restarts.</td></tr></tbody></table><h5 class="anchor anchorWithStickyNavbar_LWe7" id="consumerconfig">ConsumerConfig<a href="#consumerconfig" class="hash-link" aria-label="Direct link to ConsumerConfig" title="Direct link to ConsumerConfig"></a></h5><p>The following table outlines the nested fields and related arguments under the <code>inputSpecs</code> field.</p><table><thead><tr><th>Field Name</th><th>Type</th><th>Related Command Argument</th><th>Description</th></tr></thead><tbody><tr><td>schemaType</td><td>String</td><td>N/A</td><td>N/A</td></tr><tr><td>serdeClassName</td><td>String</td><td>N/A</td><td>N/A</td></tr><tr><td>isRegexPattern</td><td>Boolean</td><td>N/A</td><td>N/A</td></tr><tr><td>schemaProperties</td><td>Map<String,String<!-- -->></td><td>N/A</td><td>N/A</td></tr><tr><td>consumerProperties</td><td>Map<String,String<!-- -->></td><td>N/A</td><td>N/A</td></tr><tr><td>receiverQueueSize</td><td>Int</td><td>N/A</td><td>N/A</td></tr><tr><td>cryptoConfig</td><td><a href="#cryptoconfig">CryptoConfig</a></td><td>N/A</td><td>Refer to <a href="https://github.com/apache/pulsar/blob/master/pulsar-client-admin-api/src/main/java/org/apache/pulsar/common/functions/CryptoConfig.java" target="_blank" rel="noopener noreferrer">code</a>.</td></tr><tr><td>poolMessages</td><td>Boolean</td><td>N/A</td><td>N/A</td></tr></tbody></table><h5 class="anchor anchorWithStickyNavbar_LWe7" id="producerconfig">ProducerConfig<a href="#producerconfig" class="hash-link" aria-label="Direct link to ProducerConfig" title="Direct link to ProducerConfig"></a></h5><p>The following table outlines the nested fields and related arguments under the <code>producerConfig</code> field.</p><table><thead><tr><th>Field Name</th><th>Type</th><th>Related Command Argument</th><th>Description</th></tr></thead><tbody><tr><td>maxPendingMessages</td><td>Int</td><td>N/A</td><td>The max size of a queue that holds messages pending to receive an acknowledgment from a broker.</td></tr><tr><td>maxPendingMessagesAcrossPartitions</td><td>Int</td><td>N/A</td><td>The number of <code>maxPendingMessages</code> across all partitions.</td></tr><tr><td>useThreadLocalProducers</td><td>Boolean</td><td>N/A</td><td>N/A</td></tr><tr><td>cryptoConfig</td><td><a href="#cryptoconfig">CryptoConfig</a></td><td>N/A</td><td>Refer to <a href="https://github.com/apache/pulsar/blob/master/pulsar-client-admin-api/src/main/java/org/apache/pulsar/common/functions/CryptoConfig.java" target="_blank" rel="noopener noreferrer">code</a>.</td></tr><tr><td>batchBuilder</td><td>String</td><td><code>--batch-builder</code></td><td>The type of batch construction method. Available values: <code>DEFAULT</code> and <code>KEY_BASED</code>. The default value is <code>DEFAULT</code>.</td></tr><tr><td>compressionType</td><td>String</td><td>N/A</td><td>Message data compression type used by a producer. The default value is <a href="https://github.com/lz4/lz4" target="_blank" rel="noopener noreferrer"><code>LZ4</code></a>. <br>Available options:<li><code>NONE</code> (no compression)</li><li><a href="https://zlib.net/" target="_blank" rel="noopener noreferrer"><code>ZLIB</code></a><br></li><li><a href="https://facebook.github.io/zstd/" target="_blank" rel="noopener noreferrer"><code>ZSTD</code></a></li><li><a href="https://google.github.io/snappy/" target="_blank" rel="noopener noreferrer"><code>SNAPPY</code></a></li></td></tr></tbody></table><h6 class="anchor anchorWithStickyNavbar_LWe7" id="resources">Resources<a href="#resources" class="hash-link" aria-label="Direct link to Resources" title="Direct link to Resources"></a></h6><p>The following table outlines the nested fields and related arguments under the <code>resources</code> field.</p><table><thead><tr><th>Field Name</th><th>Type</th><th>Related Command Argument</th><th>Description</th></tr></thead><tbody><tr><td>cpu</td><td>double</td><td><code>--cpu</code></td><td>The CPU in cores that need to be allocated per function instance (for Kubernetes runtime only).</td></tr><tr><td>ram</td><td>Long</td><td><code>--ram</code></td><td>The RAM in bytes that need to be allocated per function instance (for process/Kubernetes runtime only).</td></tr><tr><td>disk</td><td>Long</td><td><code>--disk</code></td><td>The disk in bytes that need to be allocated per function instance (for Kubernetes runtime only).</td></tr></tbody></table><h6 class="anchor anchorWithStickyNavbar_LWe7" id="windowconfig">WindowConfig<a href="#windowconfig" class="hash-link" aria-label="Direct link to WindowConfig" title="Direct link to WindowConfig"></a></h6><p>The following table outlines the nested fields and related arguments under the <code>windowConfig</code> field.</p><table><thead><tr><th>Field Name</th><th>Type</th><th>Related Command Argument</th><th>Description</th></tr></thead><tbody><tr><td>windowLengthCount</td><td>Int</td><td><code>--window-length-count</code></td><td>The number of messages per window.</td></tr><tr><td>windowLengthDurationMs</td><td>Long</td><td><code>--window-length-duration-ms</code></td><td>The time duration (in milliseconds) per window.</td></tr><tr><td>slidingIntervalCount</td><td>Int</td><td><code>--sliding-interval-count</code></td><td>The number of messages after which a window slides.</td></tr><tr><td>slidingIntervalDurationMs</td><td>Long</td><td><code>--sliding-interval-duration-ms</code></td><td>The time duration after which a window slides.</td></tr><tr><td>lateDataTopic</td><td>String</td><td>N/A</td><td>N/A</td></tr><tr><td>maxLagMs</td><td>Long</td><td>N/A</td><td>N/A</td></tr><tr><td>watermarkEmitIntervalMs</td><td>Long</td><td>N/A</td><td>N/A</td></tr><tr><td>timestampExtractorClassName</td><td>String</td><td>N/A</td><td>N/A</td></tr><tr><td>actualWindowFunctionClassName</td><td>String</td><td>N/A</td><td>N/A</td></tr></tbody></table><h6 class="anchor anchorWithStickyNavbar_LWe7" id="cryptoconfig">CryptoConfig<a href="#cryptoconfig" class="hash-link" aria-label="Direct link to CryptoConfig" title="Direct link to CryptoConfig"></a></h6><p>The following table outlines the nested fields and related arguments under the <code>cryptoConfig</code> field.</p><table><thead><tr><th>Field Name</th><th>Type</th><th>Related Command Argument</th><th>Description</th></tr></thead><tbody><tr><td>cryptoKeyReaderClassName</td><td>String</td><td>N/A</td><td>Refer to <a href="https://github.com/apache/pulsar/blob/master/pulsar-client-admin-api/src/main/java/org/apache/pulsar/common/functions/CryptoConfig.java" target="_blank" rel="noopener noreferrer">code</a>.</td></tr><tr><td>cryptoKeyReaderConfig</td><td>Map<String, Object<!-- -->></td><td>N/A</td><td>N/A</td></tr><tr><td>encryptionKeys</td><td>String[]</td><td>N/A</td><td>N/A</td></tr><tr><td>producerCryptoFailureAction</td><td>ProducerCryptoFailureAction</td><td>N/A</td><td>N/A</td></tr><tr><td>consumerCryptoFailureAction</td><td>ConsumerCryptoFailureAction</td><td>N/A</td><td>N/A</td></tr></tbody></table><h3 class="anchor anchorWithStickyNavbar_LWe7" id="example">Example<a href="#example" class="hash-link" aria-label="Direct link to Example" title="Direct link to Example"></a></h3><p>The following example shows how to configure a function using YAML or JSON.</p><div class="tabs-container tabList__CuJ"><ul role="tablist" aria-orientation="horizontal" class="tabs"><li role="tab" tabindex="0" aria-selected="true" class="tabs__item tabItem_LNqP tabs__item--active">YAML</li><li role="tab" tabindex="-1" aria-selected="false" class="tabs__item tabItem_LNqP">JSON</li></ul><div class="margin-top--md"><div role="tabpanel" class="tabItem_Ymn6"><div class="language-yaml codeBlockContainer_Ckt0 theme-code-block" style="--prism-color:#F8F8F2;--prism-background-color:#282A36"><div class="codeBlockContent_biex"><pre tabindex="0" class="prism-code language-yaml codeBlock_bY9V thin-scrollbar"><code class="codeBlockLines_e6Vv"><span class="token-line" style="color:#F8F8F2"><span class="token key atrule">tenant</span><span class="token punctuation" style="color:rgb(248, 248, 242)">:</span><span class="token plain"> </span><span class="token string" style="color:rgb(255, 121, 198)">"public"</span><span class="token plain"></span><br></span><span class="token-line" style="color:#F8F8F2"><span class="token plain"></span><span class="token key atrule">namespace</span><span class="token punctuation" style="color:rgb(248, 248, 242)">:</span><span class="token plain"> </span><span class="token string" style="color:rgb(255, 121, 198)">"default"</span><span class="token plain"></span><br></span><span class="token-line" style="color:#F8F8F2"><span class="token plain"></span><span class="token key atrule">name</span><span class="token punctuation" style="color:rgb(248, 248, 242)">:</span><span class="token plain"> </span><span class="token string" style="color:rgb(255, 121, 198)">"config-file-function"</span><span class="token plain"></span><br></span><span class="token-line" style="color:#F8F8F2"><span class="token plain"></span><span class="token key atrule">inputs</span><span class="token punctuation" style="color:rgb(248, 248, 242)">:</span><span class="token plain"></span><br></span><span class="token-line" style="color:#F8F8F2"><span class="token plain"> </span><span class="token punctuation" style="color:rgb(248, 248, 242)">-</span><span class="token plain"> </span><span class="token string" style="color:rgb(255, 121, 198)">"persistent://public/default/config-file-function-input-1"</span><span class="token plain"></span><br></span><span class="token-line" style="color:#F8F8F2"><span class="token plain"> </span><span class="token punctuation" style="color:rgb(248, 248, 242)">-</span><span class="token plain"> </span><span class="token string" style="color:rgb(255, 121, 198)">"persistent://public/default/config-file-function-input-2"</span><span class="token plain"></span><br></span><span class="token-line" style="color:#F8F8F2"><span class="token plain"></span><span class="token key atrule">output</span><span class="token punctuation" style="color:rgb(248, 248, 242)">:</span><span class="token plain"> </span><span class="token string" style="color:rgb(255, 121, 198)">"persistent://public/default/config-file-function-output"</span><span class="token plain"></span><br></span><span class="token-line" style="color:#F8F8F2"><span class="token plain"></span><span class="token key atrule">jar</span><span class="token punctuation" style="color:rgb(248, 248, 242)">:</span><span class="token plain"> </span><span class="token string" style="color:rgb(255, 121, 198)">"function.jar"</span><span class="token plain"></span><br></span><span class="token-line" style="color:#F8F8F2"><span class="token plain"></span><span class="token key atrule">parallelism</span><span class="token punctuation" style="color:rgb(248, 248, 242)">:</span><span class="token plain"> </span><span class="token number">1</span><span class="token plain"></span><br></span><span class="token-line" style="color:#F8F8F2"><span class="token plain"></span><span class="token key atrule">resources</span><span class="token punctuation" style="color:rgb(248, 248, 242)">:</span><span class="token plain"></span><br></span><span class="token-line" style="color:#F8F8F2"><span class="token plain"> </span><span class="token key atrule">cpu</span><span class="token punctuation" style="color:rgb(248, 248, 242)">:</span><span class="token plain"> </span><span class="token number">8</span><span class="token plain"></span><br></span><span class="token-line" style="color:#F8F8F2"><span class="token plain"> </span><span class="token key atrule">ram</span><span class="token punctuation" style="color:rgb(248, 248, 242)">:</span><span class="token plain"> </span><span class="token number">8589934592</span><span class="token plain"></span><br></span><span class="token-line" style="color:#F8F8F2"><span class="token plain"></span><span class="token key atrule">autoAck</span><span class="token punctuation" style="color:rgb(248, 248, 242)">:</span><span class="token plain"> </span><span class="token boolean important">true</span><span class="token plain"></span><br></span><span class="token-line" style="color:#F8F8F2"><span class="token plain"></span><span class="token key atrule">userConfig</span><span class="token punctuation" style="color:rgb(248, 248, 242)">:</span><span class="token plain"></span><br></span><span class="token-line" style="color:#F8F8F2"><span class="token plain"> </span><span class="token key atrule">foo</span><span class="token punctuation" style="color:rgb(248, 248, 242)">:</span><span class="token plain"> </span><span class="token string" style="color:rgb(255, 121, 198)">"bar"</span><br></span></code></pre><div class="buttonGroup__atx"><button type="button" aria-label="Copy code to clipboard" title="Copy" class="clean-btn"><span class="copyButtonIcons_eSgA" aria-hidden="true"><svg class="copyButtonIcon_y97N" viewBox="0 0 24 24"><path d="M19,21H8V7H19M19,5H8A2,2 0 0,0 6,7V21A2,2 0 0,0 8,23H19A2,2 0 0,0 21,21V7A2,2 0 0,0 19,5M16,1H4A2,2 0 0,0 2,3V17H4V3H16V1Z"></path></svg><svg class="copyButtonSuccessIcon_LjdS" viewBox="0 0 24 24"><path d="M21,7L9,19L3.5,13.5L4.91,12.09L9,16.17L19.59,5.59L21,7Z"></path></svg></span></button></div></div></div></div><div role="tabpanel" class="tabItem_Ymn6" hidden=""><div class="language-json codeBlockContainer_Ckt0 theme-code-block" style="--prism-color:#F8F8F2;--prism-background-color:#282A36"><div class="codeBlockContent_biex"><pre tabindex="0" class="prism-code language-json codeBlock_bY9V thin-scrollbar"><code class="codeBlockLines_e6Vv"><span class="token-line" style="color:#F8F8F2"><span class="token punctuation" style="color:rgb(248, 248, 242)">{</span><span class="token plain"></span><br></span><span class="token-line" style="color:#F8F8F2"><span class="token plain"> </span><span class="token property">"tenant"</span><span class="token operator">:</span><span class="token plain"> </span><span class="token string" style="color:rgb(255, 121, 198)">"public"</span><span class="token punctuation" style="color:rgb(248, 248, 242)">,</span><span class="token plain"></span><br></span><span class="token-line" style="color:#F8F8F2"><span class="token plain"> </span><span class="token property">"namespace"</span><span class="token operator">:</span><span class="token plain"> </span><span class="token string" style="color:rgb(255, 121, 198)">"default"</span><span class="token punctuation" style="color:rgb(248, 248, 242)">,</span><span class="token plain"></span><br></span><span class="token-line" style="color:#F8F8F2"><span class="token plain"> </span><span class="token property">"name"</span><span class="token operator">:</span><span class="token plain"> </span><span class="token string" style="color:rgb(255, 121, 198)">"config-file-function"</span><span class="token punctuation" style="color:rgb(248, 248, 242)">,</span><span class="token plain"></span><br></span><span class="token-line" style="color:#F8F8F2"><span class="token plain"> </span><span class="token property">"inputs"</span><span class="token operator">:</span><span class="token plain"> </span><span class="token punctuation" style="color:rgb(248, 248, 242)">[</span><span class="token plain"></span><br></span><span class="token-line" style="color:#F8F8F2"><span class="token plain"> </span><span class="token string" style="color:rgb(255, 121, 198)">"persistent://public/default/config-file-function-input-1"</span><span class="token punctuation" style="color:rgb(248, 248, 242)">,</span><span class="token plain"></span><br></span><span class="token-line" style="color:#F8F8F2"><span class="token plain"> </span><span class="token string" style="color:rgb(255, 121, 198)">"persistent://public/default/config-file-function-input-2"</span><span class="token plain"></span><br></span><span class="token-line" style="color:#F8F8F2"><span class="token plain"> </span><span class="token punctuation" style="color:rgb(248, 248, 242)">]</span><span class="token punctuation" style="color:rgb(248, 248, 242)">,</span><span class="token plain"></span><br></span><span class="token-line" style="color:#F8F8F2"><span class="token plain"> </span><span class="token property">"output"</span><span class="token operator">:</span><span class="token plain"> </span><span class="token string" style="color:rgb(255, 121, 198)">"persistent://public/default/config-file-function-output"</span><span class="token punctuation" style="color:rgb(248, 248, 242)">,</span><span class="token plain"></span><br></span><span class="token-line" style="color:#F8F8F2"><span class="token plain"> </span><span class="token property">"jar"</span><span class="token operator">:</span><span class="token plain"> </span><span class="token string" style="color:rgb(255, 121, 198)">"function.jar"</span><span class="token punctuation" style="color:rgb(248, 248, 242)">,</span><span class="token plain"></span><br></span><span class="token-line" style="color:#F8F8F2"><span class="token plain"> </span><span class="token property">"parallelism"</span><span class="token operator">:</span><span class="token plain"> </span><span class="token number">1</span><span class="token punctuation" style="color:rgb(248, 248, 242)">,</span><span class="token plain"></span><br></span><span class="token-line" style="color:#F8F8F2"><span class="token plain"> </span><span class="token property">"resources"</span><span class="token operator">:</span><span class="token plain"> </span><span class="token punctuation" style="color:rgb(248, 248, 242)">{</span><span class="token plain"></span><br></span><span class="token-line" style="color:#F8F8F2"><span class="token plain"> </span><span class="token property">"cpu"</span><span class="token operator">:</span><span class="token plain"> </span><span class="token number">8</span><span class="token punctuation" style="color:rgb(248, 248, 242)">,</span><span class="token plain"></span><br></span><span class="token-line" style="color:#F8F8F2"><span class="token plain"> </span><span class="token property">"ram"</span><span class="token operator">:</span><span class="token plain"> </span><span class="token number">8589934592</span><span class="token plain"></span><br></span><span class="token-line" style="color:#F8F8F2"><span class="token plain"> </span><span class="token punctuation" style="color:rgb(248, 248, 242)">}</span><span class="token punctuation" style="color:rgb(248, 248, 242)">,</span><span class="token plain"></span><br></span><span class="token-line" style="color:#F8F8F2"><span class="token plain"> </span><span class="token property">"autoAck"</span><span class="token operator">:</span><span class="token plain"> </span><span class="token boolean">true</span><span class="token punctuation" style="color:rgb(248, 248, 242)">,</span><span class="token plain"></span><br></span><span class="token-line" style="color:#F8F8F2"><span class="token plain"> </span><span class="token property">"userConfig"</span><span class="token operator">:</span><span class="token plain"> </span><span class="token punctuation" style="color:rgb(248, 248, 242)">{</span><span class="token plain"></span><br></span><span class="token-line" style="color:#F8F8F2"><span class="token plain"> </span><span class="token property">"foo"</span><span class="token operator">:</span><span class="token plain"> </span><span class="token string" style="color:rgb(255, 121, 198)">"bar"</span><span class="token plain"></span><br></span><span class="token-line" style="color:#F8F8F2"><span class="token plain"> </span><span class="token punctuation" style="color:rgb(248, 248, 242)">}</span><span class="token plain"></span><br></span><span class="token-line" style="color:#F8F8F2"><span class="token plain"></span><span class="token punctuation" style="color:rgb(248, 248, 242)">}</span><br></span></code></pre><div class="buttonGroup__atx"><button type="button" aria-label="Copy code to clipboard" title="Copy" class="clean-btn"><span class="copyButtonIcons_eSgA" aria-hidden="true"><svg class="copyButtonIcon_y97N" viewBox="0 0 24 24"><path d="M19,21H8V7H19M19,5H8A2,2 0 0,0 6,7V21A2,2 0 0,0 8,23H19A2,2 0 0,0 21,21V7A2,2 0 0,0 19,5M16,1H4A2,2 0 0,0 2,3V17H4V3H16V1Z"></path></svg><svg class="copyButtonSuccessIcon_LjdS" viewBox="0 0 24 24"><path d="M21,7L9,19L3.5,13.5L4.91,12.09L9,16.17L19.59,5.59L21,7Z"></path></svg></span></button></div></div></div></div></div></div></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.2.x/functions-cli.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.2.x/functions-package-go/"><div class="pagination-nav__sublabel">Previous</div><div class="pagination-nav__label">Package Go Functions</div></a><a class="pagination-nav__link pagination-nav__link--next" href="/docs/3.2.x/window-functions-context/"><div class="pagination-nav__sublabel">Next</div><div class="pagination-nav__label">Window Functions: Context</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="#pulsar-admin-cli-for-pulsar-functions" class="table-of-contents__link toc-highlight">Pulsar admin CLI for Pulsar Functions</a></li><li><a href="#yaml-configurations-for-pulsar-functions" class="table-of-contents__link toc-highlight">YAML configurations for Pulsar Functions</a><ul><li><a href="#example" class="table-of-contents__link toc-highlight">Example</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"> |
