This is an automated email from the ASF dual-hosted git repository.
urfree pushed a commit to branch main
in repository https://gitbox.apache.org/repos/asf/pulsar-site.git
The following commit(s) were added to refs/heads/main by this push:
new ddbd6d47253 Docs sync done from apache/pulsar(#f9b0912)
ddbd6d47253 is described below
commit ddbd6d472533940f8b65d7e89d5de77eea39e06e
Author: Pulsar Site Updater <[email protected]>
AuthorDate: Thu Jun 9 06:05:34 2022 +0000
Docs sync done from apache/pulsar(#f9b0912)
---
site2/website-next/docs/functions-cli.md | 379 +++++++++++++++----------------
1 file changed, 186 insertions(+), 193 deletions(-)
diff --git a/site2/website-next/docs/functions-cli.md
b/site2/website-next/docs/functions-cli.md
index 6a589ec3e98..f36e47f33de 100644
--- a/site2/website-next/docs/functions-cli.md
+++ b/site2/website-next/docs/functions-cli.md
@@ -1,197 +1,190 @@
---
id: functions-cli
-title: Pulsar Functions command line tool
-sidebar_label: "Reference: CLI"
+title: Pulsar Functions CLI and YAML configs
+sidebar_label: "CLI and YAML configs"
---
-The following tables list Pulsar Functions command-line tools. You can learn
Pulsar Functions modes, commands, and parameters.
-
-## localrun
-
-Run Pulsar Functions locally, rather than deploying it to the Pulsar cluster.
-
-Name | Description | Default
----|---|---
-auto-ack | Whether or not the framework acknowledges messages automatically. |
true |
-broker-service-url | The URL for the Pulsar broker. | |
-classname | The class name of a Pulsar Function.| |
-client-auth-params | Client authentication parameter. | |
-client-auth-plugin | Client authentication plugin using which function-process
can connect to broker. | |
-CPU | The CPU in cores that need to be allocated per function instance
(applicable only to docker runtime).| |
-custom-schema-inputs | The map of input topics to Schema class names (as a
JSON string). | |
-custom-serde-inputs | The map of input topics to SerDe class names (as a JSON
string). | |
-dead-letter-topic | The topic where all messages that were not processed
successfully are sent. This parameter is not supported in Python Functions. | |
-disk | The disk in bytes that need to be allocated per function instance
(applicable only to docker runtime). | |
-fqfn | The Fully Qualified Function Name (FQFN) for the function. | |
-function-config-file | The path to a YAML config file specifying the
configuration of a Pulsar Function. | |
-go | Path to the main Go executable binary for the function (if the function
is written in Go). It also supports URL path [http/https/file (file protocol
assumes that file already exists on worker host)/function (package URL from
packages management service)] from which worker can download the package. | |
-hostname-verification-enabled | Enable hostname verification. | false
-inputs | The input topic or topics of a Pulsar Function (multiple topics can
be specified as a comma-separated list). | |
-jar | Path to the jar file for the function (if the function is written in
Java). It also supports URL path [http/https/file (file protocol assumes that
file already exists on worker host)/function (package URL from packages
management service)] from which worker can download the package. | |
-instance-id-offset | Start the instanceIds from this offset. | 0
-log-topic | The topic to which the logs a Pulsar Function are produced. | |
-max-message-retries | How many times should we try to process a message before
giving up. | |
-name | The name of a Pulsar Function. | |
-namespace | The namespace of a Pulsar Function. | |
-output | The output topic of a Pulsar Function (If none is specified, no
output is written). | |
-output-serde-classname | The SerDe class to be used for messages output by the
function. | |
-parallelism | The parallelism factor of a Pulsar Function (i.e. the number of
function instances to run). | |
-processing-guarantees | The processing guarantees (delivery semantics) applied
to the function. Available values: [ATLEAST_ONCE, ATMOST_ONCE,
EFFECTIVELY_ONCE]. | ATLEAST_ONCE
-py | Path to the main Python file/Python Wheel file for the function (if the
function is written in Python). It also supports URL path [http/https/file
(file protocol assumes that file already exists on worker host)/function
(package URL from packages management service)] from which worker can download
the package. | |
-ram | The ram in bytes that need to be allocated per function instance
(applicable only to process/docker runtime). | |
-retain-ordering | Function consumes and processes messages in order. | |
-schema-type | The builtin schema type or custom schema class name to be used
for messages output by the function. | |
-sliding-interval-count | The number of messages after which the window slides.
| |
-sliding-interval-duration-ms | The time duration after which the window
slides. | |
-subs-name | Pulsar source subscription name if user wants a specific
subscription-name for the input-topic consumer. | |
-tenant | The tenant of a Pulsar Function. | |
-timeout-ms | The message timeout in milliseconds. | |
-tls-allow-insecure | Allow insecure tls connection. | false
-tls-trust-cert-path | tls trust cert file path. | |
-topics-pattern | The topic pattern to consume from list of topics under a
namespace that match the pattern. [--input] and [--topic-pattern] are mutually
exclusive. Add SerDe class name for a pattern in --custom-serde-inputs (only
supported in Java Function). | |
-use-tls | Use tls connection. | false
-user-config | User-defined config key/values. | |
-window-length-count | The number of messages per window. | |
-window-length-duration-ms | The time duration of the window in milliseconds. |
|
-
-
-## create
-
-Create and deploy a Pulsar Function in cluster mode.
-
-Name | Description | Default
----|---|---
-auto-ack | Whether or not the framework acknowledges messages automatically. |
true |
-classname | The class name of a Pulsar Function. | |
-CPU | The CPU in cores that need to be allocated per function instance
(applicable only to docker runtime).| |
-custom-runtime-options | A string that encodes options to customize the
runtime, see docs for configured runtime for details | |
-custom-schema-inputs | The map of input topics to Schema class names (as a
JSON string). | |
-custom-serde-inputs | The map of input topics to SerDe class names (as a JSON
string). | |
-dead-letter-topic | The topic where all messages that were not processed
successfully are sent. This parameter is not supported in Python Functions. | |
-disk | The disk in bytes that need to be allocated per function instance
(applicable only to docker runtime). | |
-fqfn | The Fully Qualified Function Name (FQFN) for the function. | |
-function-config-file | The path to a YAML config file specifying the
configuration of a Pulsar Function. | |
-go | Path to the main Go executable binary for the function (if the function
is written in Go). It also supports URL path [http/https/file (file protocol
assumes that file already exists on worker host)/function (package URL from
packages management service)] from which worker can download the package. | |
-inputs | The input topic or topics of a Pulsar Function (multiple topics can
be specified as a comma-separated list). | |
-jar | Path to the jar file for the function (if the function is written in
Java). It also supports URL path [http/https/file (file protocol assumes that
file already exists on worker host)/function (package URL from packages
management service)] from which worker can download the package. | |
-log-topic | The topic to which the logs of a Pulsar Function are produced. | |
-max-message-retries | How many times should we try to process a message before
giving up. | |
-name | The name of a Pulsar Function. | |
-namespace | The namespace of a Pulsar Function. | |
-output | The output topic of a Pulsar Function (If none is specified, no
output is written). | |
-output-serde-classname | The SerDe class to be used for messages output by the
function. | |
-parallelism | The parallelism factor of a Pulsar Function (i.e. the number of
function instances to run). | |
-processing-guarantees | The processing guarantees (delivery semantics) applied
to the function. Available values: [ATLEAST_ONCE, ATMOST_ONCE,
EFFECTIVELY_ONCE]. | ATLEAST_ONCE
-py | Path to the main Python file/Python Wheel file for the function (if the
function is written in Python). It also supports URL path [http/https/file
(file protocol assumes that file already exists on worker host)/function
(package URL from packages management service)] from which worker can download
the package. | |
-ram | The ram in bytes that need to be allocated per function instance
(applicable only to process/docker runtime). | |
-retain-ordering | Function consumes and processes messages in order. | |
-schema-type | The builtin schema type or custom schema class name to be used
for messages output by the function. | |
-sliding-interval-count | The number of messages after which the window slides.
| |
-sliding-interval-duration-ms | The time duration after which the window
slides. | |
-subs-name | Pulsar source subscription name if user wants a specific
subscription-name for the input-topic consumer. | |
-tenant | The tenant of a Pulsar Function. | |
-timeout-ms | The message timeout in milliseconds. | |
-topics-pattern | The topic pattern to consume from list of topics under a
namespace that match the pattern. [--input] and [--topic-pattern] are mutually
exclusive. Add SerDe class name for a pattern in --custom-serde-inputs (only
supported in Java Function). | |
-user-config | User-defined config key/values. | |
-window-length-count | The number of messages per window. | |
-window-length-duration-ms | The time duration of the window in milliseconds. |
|
-
-## delete
-
-Delete a Pulsar Function that is running on a Pulsar cluster.
-
-Name | Description | Default
----|---|---
-fqfn | The Fully Qualified Function Name (FQFN) for the function. | |
-name | The name of a Pulsar Function. | |
-namespace | The namespace of a Pulsar Function. | |
-tenant | The tenant of a Pulsar Function. | |
-
-## update
-
-Update a Pulsar Function that has been deployed to a Pulsar cluster.
-
-Name | Description | Default
----|---|---
-auto-ack | Whether or not the framework acknowledges messages automatically. |
true |
-classname | The class name of a Pulsar Function. | |
-CPU | The CPU in cores that need to be allocated per function instance
(applicable only to docker runtime). | |
-custom-runtime-options | A string that encodes options to customize the
runtime, see docs for configured runtime for details | |
-custom-schema-inputs | The map of input topics to Schema class names (as a
JSON string). | |
-custom-serde-inputs | The map of input topics to SerDe class names (as a JSON
string). | |
-dead-letter-topic | The topic where all messages that were not processed
successfully are sent. This parameter is not supported in Python Functions. | |
-disk | The disk in bytes that need to be allocated per function instance
(applicable only to docker runtime). | |
-fqfn | The Fully Qualified Function Name (FQFN) for the function. | |
-function-config-file | The path to a YAML config file specifying the
configuration of a Pulsar Function. | |
-go | Path to the main Go executable binary for the function (if the function
is written in Go). It also supports URL path [http/https/file (file protocol
assumes that file already exists on worker host)/function (package URL from
packages management service)] from which worker can download the package. | |
-inputs | The input topic or topics of a Pulsar Function (multiple topics can
be specified as a comma-separated list). | |
-jar | Path to the jar file for the function (if the function is written in
Java). It also supports URL path [http/https/file (file protocol assumes that
file already exists on worker host)/function (package URL from packages
management service)] from which worker can download the package. | |
-log-topic | The topic to which the logs of a Pulsar Function are produced. | |
-max-message-retries | How many times should we try to process a message before
giving up. | |
-name | The name of a Pulsar Function. | |
-namespace | The namespace of a Pulsar Function. | |
-output | The output topic of a Pulsar Function (If none is specified, no
output is written). | |
-output-serde-classname | The SerDe class to be used for messages output by the
function. | |
-parallelism | The parallelism factor of a Pulsar Function (i.e. the number of
function instances to run). | |
-processing-guarantees | The processing guarantees (delivery semantics) applied
to the function. Available values: [ATLEAST_ONCE, ATMOST_ONCE,
EFFECTIVELY_ONCE]. | ATLEAST_ONCE
-py | Path to the main Python file/Python Wheel file for the function (if the
function is written in Python). It also supports URL path [http/https/file
(file protocol assumes that file already exists on worker host)/function
(package URL from packages management service)] from which worker can download
the package. | |
-ram | The ram in bytes that need to be allocated per function instance
(applicable only to process/docker runtime). | |
-retain-ordering | Function consumes and processes messages in order. | |
-schema-type | The builtin schema type or custom schema class name to be used
for messages output by the function. | |
-sliding-interval-count | The number of messages after which the window slides.
| |
-sliding-interval-duration-ms | The time duration after which the window
slides. | |
-subs-name | Pulsar source subscription name if user wants a specific
subscription-name for the input-topic consumer. | |
-tenant | The tenant of a Pulsar Function. | |
-timeout-ms | The message timeout in milliseconds. | |
-topics-pattern | The topic pattern to consume from list of topics under a
namespace that match the pattern. [--input] and [--topic-pattern] are mutually
exclusive. Add SerDe class name for a pattern in --custom-serde-inputs (only
supported in Java Function). | |
-update-auth-data | Whether or not to update the auth data. | false
-user-config | User-defined config key/values. | |
-window-length-count | The number of messages per window. | |
-window-length-duration-ms | The time duration of the window in milliseconds. |
|
-
-## get
-
-Fetch information about a Pulsar Function.
-
-Name | Description | Default
----|---|---
-fqfn | The Fully Qualified Function Name (FQFN) for the function. | |
-name | The name of a Pulsar Function. | |
-namespace | The namespace of a Pulsar Function. | |
-tenant | The tenant of a Pulsar Function. | |
-
-## restart
-
-Restart function instance.
-
-Name | Description | Default
----|---|---
-fqfn | The Fully Qualified Function Name (FQFN) for the function. | |
-instance-id | The function instanceId (restart all instances if instance-id is
not provided. | |
-name | The name of a Pulsar Function. | |
-namespace | The namespace of a Pulsar Function. | |
-tenant | The tenant of a Pulsar Function. | |
-
-## stop
-
-Stops function instance.
-
-Name | Description | Default
----|---|---
-fqfn | The Fully Qualified Function Name (FQFN) for the function. | |
-instance-id | The function instanceId (restart all instances if instance-id is
not provided. | |
-name | The name of a Pulsar Function. | |
-namespace | The namespace of a Pulsar Function. | |
-tenant | The tenant of a Pulsar Function. | |
-
-## start
-
-Starts a stopped function instance.
-
-Name | Description | Default
----|---|---
-fqfn | The Fully Qualified Function Name (FQFN) for the function. | |
-instance-id | The function instanceId (restart all instances if instance-id is
not provided. | |
-name | The name of a Pulsar Function. | |
-namespace | The namespace of a Pulsar Function. | |
-tenant | The tenant of a Pulsar Function. | |
+````mdx-code-block
+import Tabs from '@theme/Tabs';
+import TabItem from '@theme/TabItem';
+````
+
+
+## Pulsar admin CLI for Pulsar Functions
+
+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 [Pulsar admin CLI](/tools/pulsar-admin/).
+
+
+## YAML configurations for Pulsar Functions
+
+You can configure a function by using a predefined YAML file. The following
table outlines the required fields and arguments.
+
+| Field Name | Type | Related Command Argument
| Description|
+|----------------------|----------------------------|----------------------------|------------|
+| runtimeFlags | String | N/A
| Any flags that you want to pass to a runtime (for process & Kubernetes
runtime only). |
+| tenant | String | `--tenant`
| The tenant of a function.|
+| namespace | String | `--namespace`
| The namespace of a function.|
+| name | String | `--name`
| The name of a function.|
+| className | String | `--classname`
| The class name of a function. |
+| inputs | List`<String>` | `-i`, `--inputs`
| The input topics of a function. Multiple topics can be specified as a
comma-separated list. |
+| customSerdeInputs | Map`<String,String>` |
`--custom-serde-inputs` | The mapping from input topics to SerDe class
names. |
+| topicsPattern | String | `--topics-pattern`
| The topic pattern to consume from a list of topics under a namespace. <br
/>**Note:** `--input` and `--topic-pattern` are mutually exclusive. For Java
functions, you need to add the SerDe class name for a pattern in
`--custom-serde-inputs`. |
+| customSchemaInputs | Map`<String,String>` |
`--custom-schema-inputs` | The mapping from input topics to schema
properties. |
+| customSchemaOutputs | Map`<String,String>` |
`--custom-schema-outputs` | The mapping from output topics to schema
properties.|
+| inputSpecs | Map`<String,`[ConsumerConfig](#consumerconfig)`>` |
`--input-specs` | The mapping from inputs to custom configurations.|
+| output | String | `-o`, `--output`
| The output topic of a function. If none is specified, no output is written.
|
+| producerConfig | [ProducerConfig](#produceconfig) |
`--producer-config` | The custom configurations for producers. |
+| outputSchemaType | String | `-st`, `--schema-type`
| The built-in schema type or custom schema class name used for message
outputs. |
+| outputSerdeClassName | String |
`--output-serde-classname` | The SerDe class used for message outputs. |
+| logTopic | String | `--log-topic`
| The topic that the logs of a function are produced to. |
+| processingGuarantees | String | `--processing-guarantees` | The processing
guarantees (delivery semantics) applied to a function. Available values:
`ATLEAST_ONCE`, `ATMOST_ONCE`, `EFFECTIVELY_ONCE`.|
+| retainOrdering | Boolean | `--retain-ordering`
| Whether functions consume and process messages in order or not. |
+| retainKeyOrdering | Boolean | `--retain-key-ordering`
| Whether functions consume and process messages in key order or not. |
+| batchBuilder | String | `--batch-builder` | Use
`producerConfig.batchBuilder` instead. <br />**Note**: `batchBuilder` will be
deprecated in code soon. |
+| forwardSourceMessageProperty | Boolean |
`--forward-source-message-property` | Whether the properties of input messages
are forwarded to output topics or not during processing. When the value is set
to `false`, the forwarding is disabled. |
+| userConfig | Map`<String,Object>` | `--user-config`
| User-defined config key/values. |
+| secrets | Map`<String,Object>` | `--secrets` | The mapping from
secretName to objects that encapsulate how the secret is fetched by the
underlying secrets provider. |
+| runtime | String | N/A | The runtime of a
function. Available values: `java`,`python`, `go`. |
+| autoAck | Boolean | `--auto-ack` | Whether the framework
acknowledges messages automatically or not. |
+| maxMessageRetries | Int | `--max-message-retries` | The number of
retries to process a message before giving up. |
+| deadLetterTopic | String | `--dead-letter-topic` | The topic used
for storing messages that are not processed successfully. |
+| subName | String | `--subs-name` | The name of
Pulsar source subscription used for input-topic consumers if required.|
+| parallelism | Int | `--parallelism` | The parallelism
factor of a function, that is, the number of function instances to run. |
+| resources | [Resources](#resources) | N/A | N/A |
+| fqfn | String | `--fqfn` | The Fully
Qualified Function Name (FQFN) of a function. |
+| windowConfig | [WindowConfig](#windowconfig) | N/A | N/A |
+| timeoutMs | Long | `--timeout-ms` | The message
timeout (in milliseconds). |
+| jar | String | `--jar` | The 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). |
+| py | String | `--py` | The 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). |
+| go | String | `--go` | Path to 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). |
+| cleanupSubscription | Boolean | N/A | Whether the
subscriptions that a function creates or uses should be deleted or not when the
function is deleted. |
+| customRuntimeOptions | String | `--custom-runtime-options` | A string
that encodes options to customize the runtime. |
+| maxPendingAsyncRequests | Int | `--max-message-retries` | The max
number of pending async requests per instance to avoid a large number of
concurrent requests. |
+| exposePulsarAdminClientEnabled | Boolean | N/A | Whether the
Pulsar admin client is exposed to function context or not. By default, it is
disabled. |
+| subscriptionPosition | String | `--subs-position` | The position
of Pulsar source subscription used for consuming messages from a specified
location. The default value is `Latest`.|
+
+
+##### ConsumerConfig
+
+The following table outlines the nested fields and related arguments under the
`inputSpecs` field.
+
+| Field Name | Type | Related Command Argument
| Description|
+|----------------------|----------------------------|----------------------------|------------|
+| schemaType | String | N/A
| N/A |
+| serdeClassName | String | N/A
| N/A |
+| isRegexPattern | Boolean | N/A
| N/A |
+| schemaProperties | Map`<String,String>` | N/A
| N/A |
+| consumerProperties | Map`<String,String>` | N/A
| N/A |
+| receiverQueueSize | Int | N/A
| N/A |
+| cryptoConfig | [CryptoConfig](#cryptoconfig) | N/A
|Refer to
[code](https://github.com/apache/pulsar/blob/master/pulsar-client-admin-api/src/main/java/org/apache/pulsar/common/functions/CryptoConfig.java).
|
+| poolMessages | Boolean | N/A
| N/A |
+
+###### ProducerConfig
+
+The following table outlines the nested fields and related arguments under the
`producerConfig` field.
+
+| Field Name | Type | Related
Command Argument | Description |
+|------------------------------------|-------------------------------|--------------------------|---------------------------------|
+| maxPendingMessages | Int | N/A
| The max size of a queue that holds messages pending to
receive an acknowledgment from a broker. |
+| maxPendingMessagesAcrossPartitions | Int | N/A
| The number of `maxPendingMessages` across all partitions. |
+| useThreadLocalProducers | Boolean | N/A
| N/A |
+| cryptoConfig | [CryptoConfig](#cryptoconfig) | N/A
| Refer to
[code](https://github.com/apache/pulsar/blob/master/pulsar-client-admin-api/src/main/java/org/apache/pulsar/common/functions/CryptoConfig.java).|
+| batchBuilder | String |
`--batch-builder` | The type of batch construction method. Available
values: `DEFAULT` and `KEY_BASED`. The default value is `DEFAULT`. |
+
+###### Resources
+
+The following table outlines the nested fields and related arguments under the
`resources` field.
+
+| Field Name | Type | Related Command Argument | Description |
+|------------|--------|--------------------------|--------------|
+| cpu | double | `--cpu` | The CPU in cores that need
to be allocated per function instance (for Kubernetes runtime only). |
+| ram | Long | `--ram` | The RAM in bytes that need
to be allocated per function instance (for process/Kubernetes runtime only).|
+| disk | Long | `--disk` | The disk in bytes that need
to be allocated per function instance (for Kubernetes runtime only). |
+
+###### WindowConfig
+
+The following table outlines the nested fields and related arguments under the
`windowConfig` field.
+
+| Field Name | Type | Related Command Argument |
Description |
+|-------------------------------|--------|----------------------------------|-----------------------------------------------------|
+| windowLengthCount | Int | `--window-length-count` |
The number of messages per window. |
+| windowLengthDurationMs | Long | `--window-length-duration-ms` |
The time duration (in milliseconds) per window. |
+| slidingIntervalCount | Int | `--sliding-interval-count` |
The number of messages after which a window slides. |
+| slidingIntervalDurationMs | Long | `--sliding-interval-duration-ms` |
The time duration after which a window slides. |
+| lateDataTopic | String | N/A |
N/A |
+| maxLagMs | Long | N/A |
N/A |
+| watermarkEmitIntervalMs | Long | N/A |
N/A |
+| timestampExtractorClassName | String | N/A |
N/A |
+| actualWindowFunctionClassName | String | N/A |
N/A |
+
+###### CryptoConfig
+
+The following table outlines the nested fields and related arguments under the
`cryptoConfig` field.
+
+| Field Name | Type | Related Command
Argument | Description |
+|-----------------------------|-----------------------------|--------------------------|---------------|
+| cryptoKeyReaderClassName | String | N/A
| Refer to
[code](https://github.com/apache/pulsar/blob/master/pulsar-client-admin-api/src/main/java/org/apache/pulsar/common/functions/CryptoConfig.java).
|
+| cryptoKeyReaderConfig | Map`<String, Object>` | N/A
| N/A |
+| encryptionKeys | String[] | N/A
| N/A |
+| producerCryptoFailureAction | ProducerCryptoFailureAction | N/A
| N/A |
+| consumerCryptoFailureAction | ConsumerCryptoFailureAction | N/A
| N/A |
+
+
+### Example
+
+The following example shows how to configure a function using YAML or JSON.
+
+````mdx-code-block
+<Tabs
+ defaultValue="YAML"
+ values={[{"label":"YAML","value":"YAML"},{"label":"JSON","value":"JSON"}]}>
+
+<TabItem value="YAML">
+
+```yaml
+tenant: "public"
+namespace: "default"
+name: "config-file-function"
+inputs:
+ - "persistent://public/default/config-file-function-input-1"
+ - "persistent://public/default/config-file-function-input-2"
+output: "persistent://public/default/config-file-function-output"
+jar: "function.jar"
+parallelism: 1
+resources:
+ cpu: 8
+ ram: 8589934592
+autoAck: true
+userConfig:
+ foo: "bar"
+```
+
+</TabItem>
+<TabItem value="JSON">
+
+```json
+{
+ "tenant": "public",
+ "namespace": "default",
+ "name": "config-file-function",
+ "inputs": [
+ "persistent://public/default/config-file-function-input-1",
+ "persistent://public/default/config-file-function-input-2"
+ ],
+ "output": "persistent://public/default/config-file-function-output",
+ "jar": "function.jar",
+ "parallelism": 1,
+ "resources": {
+ "cpu": 8,
+ "ram": 8589934592
+ },
+ "autoAck": true,
+ "userConfig": {
+ "foo": "bar"
+ }
+}
+```
+
+</TabItem>
+</Tabs>
+````
