diff --git a/docs/connectors/io-crd-config/sink-crd-config.md b/docs/connectors/io-crd-config/sink-crd-config.md index d7d94508..a9095b19 100644 --- a/docs/connectors/io-crd-config/sink-crd-config.md +++ b/docs/connectors/io-crd-config/sink-crd-config.md @@ -15,6 +15,7 @@ This table lists sink configurations. | `classname` | The class name of a sink connector. | | `tenant` | The tenant of a sink connector. | | `namespace` | The Pulsar namespace of a sink connector. | +| `ClusterName` | The Pulsar cluster of a sink connector. | | `Replicas`| The number of instances that you want to run this sink connector. By default, the `Replicas` is set to `1`. | | `MaxReplicas`| The maximum number of Pulsar instances that you want to run for this sink connector. When the value of the `maxReplicas` parameter is greater than the value of `replicas`, it indicates that the sink controller automatically scales the sink connector based on the CPU usage. By default, `maxReplicas` is set to 0, which indicates that auto-scaling is disabled. | | `SinkConfig` | The sink connector configurations in YAML format.| diff --git a/docs/connectors/io-crd-config/source-crd-config.md b/docs/connectors/io-crd-config/source-crd-config.md index eff7da57..778fd591 100644 --- a/docs/connectors/io-crd-config/source-crd-config.md +++ b/docs/connectors/io-crd-config/source-crd-config.md @@ -15,6 +15,7 @@ This table lists source configurations. | `classname` | The class name of a source connector. | | `tenant` | The tenant of a source connector. | | `namespace` | The Pulsar namespace of a source connector. | +| `ClusterName` | The Pulsar cluster of a source connector. | | `Replicas`| The number of instances that you want to run this source connector. | | `MaxReplicas`| The maximum number of Pulsar instances that you want to run for this source connector. When the value of the `maxReplicas` parameter is greater than the value of `replicas`, it indicates that the source controller automatically scales the source connector based on the CPU usage. By default, `maxReplicas` is set to 0, which indicates that auto-scaling is disabled. | | `SourceConfig` | The source connector configurations in YAML format. | diff --git a/docs/connectors/run-connector.md b/docs/connectors/run-connector.md index d60e9702..805fe54e 100644 --- a/docs/connectors/run-connector.md +++ b/docs/connectors/run-connector.md @@ -42,11 +42,11 @@ For Pulsar built-in connectors and StreamNative-managed connectors, you can crea pulsarConfig: "test-sink" resources: limits: - cpu: "0.2" - memory: 1.1G + cpu: "0.2" + memory: 1.1G requests: - cpu: "0.1" - memory: 1G + cpu: "0.1" + memory: 1G java: extraDependenciesDir: random-dir/ jar: connectors/pulsar-io-elastic-search-2.7.1.nar # the NAR location in image @@ -217,7 +217,7 @@ For self-built connectors, you can create them based on how you package them. image: streamnative/pulsar-functions-java-runner:2.7.1 # using java function runner className: org.example.MySink forwardSourceMessageProperty: true - MaxPendingAsyncRequests: 1000 + maxPendingAsyncRequests: 1000 replicas: 1 maxReplicas: 1 input: @@ -245,7 +245,7 @@ For self-built connectors, you can create them based on how you package them. spec: image: myorg/pulsar-io-my-sink:2.7.1 # using self built image forwardSourceMessageProperty: true - MaxPendingAsyncRequests: 1000 + maxPendingAsyncRequests: 1000 replicas: 1 maxReplicas: 1 input: diff --git a/docs/functions/function-crd.md b/docs/functions/function-crd.md index 6b6e96a1..f4945397 100644 --- a/docs/functions/function-crd.md +++ b/docs/functions/function-crd.md @@ -16,6 +16,7 @@ This table lists Pulsar Function configurations. | `classname` | The class name of a Pulsar Function. | | `tenant` | The tenant of a Pulsar Function. | | `namespace` | The Pulsar namespace of a Pulsar Function. | +| `ClusterName` | The Pulsar cluster of a Pulsar Function. | | `Replicas`| The number of instances that you want to run this Pulsar Function. By default, the `Replicas` is set to `1`. | | `MaxReplicas`| The maximum number of Pulsar instances that you want to run for this Pulsar Function. When the value of the `maxReplicas` parameter is greater than the value of `replicas`, it indicates that the Functions controller automatically scales the Pulsar Functions based on the CPU usage. By default, `maxReplicas` is set to 0, which indicates that auto-scaling is disabled. | | `Timeout` | The message timeout in milliseconds. | diff --git a/docs/functions/function-debug.md b/docs/functions/function-debug.md index 8101968e..152c10cd 100644 --- a/docs/functions/function-debug.md +++ b/docs/functions/function-debug.md @@ -63,7 +63,7 @@ As shown in the example above, you can get the logger via `context.getLogger()` spec: className: exclamation_function.ExclamationFunction forwardSourceMessageProperty: true - MaxPendingAsyncRequests: 1000 + maxPendingAsyncRequests: 1000 replicas: 1 maxReplicas: 5 logTopic: persistent://public/default/logging-function-logs diff --git a/docs/functions/run-function/run-go-function.md b/docs/functions/run-function/run-go-function.md index 2bc4d1dd..7d24824e 100644 --- a/docs/functions/run-function/run-go-function.md +++ b/docs/functions/run-function/run-go-function.md @@ -144,7 +144,7 @@ After packaging your Pulsar Go Functions, you can submit your Go Functions to a image: streamnative/pulsar-functions-go-runner:2.7.1 # using go function runner className: exclamation_function.ExclamationFunction forwardSourceMessageProperty: true - MaxPendingAsyncRequests: 1000 + maxPendingAsyncRequests: 1000 replicas: 1 maxReplicas: 5 logTopic: persistent://public/default/logging-function-logs @@ -177,7 +177,7 @@ After packaging your Pulsar Go Functions, you can submit your Go Functions to a image: streamnative/example-function-image:latest # using function image here className: exclamation_function.ExclamationFunction forwardSourceMessageProperty: true - MaxPendingAsyncRequests: 1000 + maxPendingAsyncRequests: 1000 replicas: 1 maxReplicas: 5 logTopic: persistent://public/default/logging-function-logs diff --git a/docs/functions/run-function/run-java-function.md b/docs/functions/run-function/run-java-function.md index 61d0fa31..0534f32a 100644 --- a/docs/functions/run-function/run-java-function.md +++ b/docs/functions/run-function/run-java-function.md @@ -174,7 +174,7 @@ After packaging your Pulsar Functions, you can submit your Pulsar Functions to a image: streamnative/pulsar-functions-java-runner:2.7.1 # using java function runner className: exclamation_function.ExclamationFunction forwardSourceMessageProperty: true - MaxPendingAsyncRequests: 1000 + maxPendingAsyncRequests: 1000 replicas: 1 maxReplicas: 5 logTopic: persistent://public/default/logging-function-logs @@ -205,7 +205,7 @@ After packaging your Pulsar Functions, you can submit your Pulsar Functions to a image: streamnative/example-function-image:latest # using function image here className: exclamation_function.ExclamationFunction forwardSourceMessageProperty: true - MaxPendingAsyncRequests: 1000 + maxPendingAsyncRequests: 1000 replicas: 1 maxReplicas: 5 logTopic: persistent://public/default/logging-function-logs diff --git a/docs/functions/run-function/run-python-function.md b/docs/functions/run-function/run-python-function.md index 4e641922..36872bc3 100644 --- a/docs/functions/run-function/run-python-function.md +++ b/docs/functions/run-function/run-python-function.md @@ -137,7 +137,7 @@ After packaging your Pulsar Functions, you can submit your Pulsar Functions to a image: streamnative/pulsar-functions-python-runner:2.7.1 # using python function runner className: exclamation_function.ExclamationFunction forwardSourceMessageProperty: true - MaxPendingAsyncRequests: 1000 + maxPendingAsyncRequests: 1000 replicas: 1 maxReplicas: 5 logTopic: persistent://public/default/logging-function-logs @@ -170,7 +170,7 @@ After packaging your Pulsar Functions, you can submit your Pulsar Functions to a image: streamnative/example-function-image:latest # using function image here className: exclamation_function.ExclamationFunction forwardSourceMessageProperty: true - MaxPendingAsyncRequests: 1000 + maxPendingAsyncRequests: 1000 replicas: 1 maxReplicas: 5 logTopic: persistent://public/default/logging-function-logs diff --git a/docs/scaling.md b/docs/scaling.md index 0df7a5aa..71b140b4 100644 --- a/docs/scaling.md +++ b/docs/scaling.md @@ -81,7 +81,7 @@ These examples describe how to auto-scale the number of Pods running Pulsar Func spec: className: org.apache.pulsar.functions.api.examples.ExclamationFunction forwardSourceMessageProperty: true - MaxPendingAsyncRequests: 1000 + maxPendingAsyncRequests: 1000 replicas: 1 maxReplicas: 8 logTopic: persistent://public/default/logging-function-logs @@ -114,7 +114,7 @@ These examples describe how to auto-scale the number of Pods running Pulsar Func spec: className: org.apache.pulsar.functions.api.examples.ExclamationFunction forwardSourceMessageProperty: true - MaxPendingAsyncRequests: 1000 + maxPendingAsyncRequests: 1000 replicas: 1 maxReplicas: 4 logTopic: persistent://public/default/logging-function-logs @@ -151,7 +151,7 @@ These examples describe how to auto-scale the number of Pods running Pulsar Func spec: className: org.apache.pulsar.functions.api.examples.ExclamationFunction forwardSourceMessageProperty: true - MaxPendingAsyncRequests: 1000 + maxPendingAsyncRequests: 1000 replicas: 1 maxReplicas: 4 logTopic: persistent://public/default/logging-function-logs diff --git a/versioned_docs/version-0.1.4/connectors/io-crd-config/sink-crd-config.md b/versioned_docs/version-0.1.4/connectors/io-crd-config/sink-crd-config.md index 2998bb5d..e65900e6 100644 --- a/versioned_docs/version-0.1.4/connectors/io-crd-config/sink-crd-config.md +++ b/versioned_docs/version-0.1.4/connectors/io-crd-config/sink-crd-config.md @@ -14,6 +14,7 @@ This table lists sink configurations. | `name` | The name of a sink connector. | | `classname` | The class name of a sink connector. | | `tenant` | The tenant of a sink connector. | +| `ClusterName` | The Pulsar cluster of a sink connector. | | `Replicas`| The number of instances that you want to run this sink connector. By default, the `Replicas` is set to `1`. | | `MaxReplicas`| The maximum number of Pulsar instances that you want to run for this sink connector. When the value of the `maxReplicas` parameter is greater than the value of `replicas`, it indicates that the sink controller automatically scales the sink connector based on the CPU usage. By default, `maxReplicas` is set to 0, which indicates that auto-scaling is disabled. | | `SinkConfig` | The map to a ConfigMap specifying the configuration of a sink connector. | diff --git a/versioned_docs/version-0.1.4/connectors/io-crd-config/source-crd-config.md b/versioned_docs/version-0.1.4/connectors/io-crd-config/source-crd-config.md index c8e0422d..44beabb8 100644 --- a/versioned_docs/version-0.1.4/connectors/io-crd-config/source-crd-config.md +++ b/versioned_docs/version-0.1.4/connectors/io-crd-config/source-crd-config.md @@ -14,6 +14,7 @@ This table lists source configurations. | `name` | The name of a source connector. | | `classname` | The class name of a source connector. | | `tenant` | The tenant of a source connector. | +| `ClusterName` | The Pulsar cluster of a source connector. | | `Replicas`| The number of instances that you want to run this source connector. By default, the `Replicas` is set to `1`. | | `MaxReplicas`| The maximum number of Pulsar instances that you want to run for this source connector. When the value of the `maxReplicas` parameter is greater than the value of `replicas`, it indicates that the source controller automatically scales the source connector based on the CPU usage. By default, `maxReplicas` is set to 0, which indicates that auto-scaling is disabled. | | `SourceConfig` | The map to a ConfigMap specifying the configuration of a source connector. | diff --git a/versioned_docs/version-0.1.4/connectors/run-connector.md b/versioned_docs/version-0.1.4/connectors/run-connector.md index acdf6f42..072e3170 100644 --- a/versioned_docs/version-0.1.4/connectors/run-connector.md +++ b/versioned_docs/version-0.1.4/connectors/run-connector.md @@ -42,11 +42,11 @@ For Pulsar built-in connectors and StreamNative-managed connectors, you can crea pulsarConfig: "test-sink" resources: limits: - cpu: "0.2" - memory: 1.1G + cpu: "0.2" + memory: 1.1G requests: - cpu: "0.1" - memory: 1G + cpu: "0.1" + memory: 1G java: jar: connectors/pulsar-io-elastic-search-2.7.1.nar # the NAR location in image jarLocation: "" # leave empty since we will not download package from Pulsar Packages @@ -212,7 +212,7 @@ For self-built connectors, you can create them based on how you package them. image: streamnative/pulsar-functions-java-runner:2.7.1 # using java function runner className: org.example.MySink forwardSourceMessageProperty: true - MaxPendingAsyncRequests: 1000 + maxPendingAsyncRequests: 1000 replicas: 1 maxReplicas: 1 input: @@ -239,7 +239,7 @@ For self-built connectors, you can create them based on how you package them. spec: image: myorg/pulsar-io-my-sink:2.7.1 # using self built image forwardSourceMessageProperty: true - MaxPendingAsyncRequests: 1000 + maxPendingAsyncRequests: 1000 replicas: 1 maxReplicas: 1 input: diff --git a/versioned_docs/version-0.1.4/functions/function-crd.md b/versioned_docs/version-0.1.4/functions/function-crd.md index af2e7e3f..281b363a 100644 --- a/versioned_docs/version-0.1.4/functions/function-crd.md +++ b/versioned_docs/version-0.1.4/functions/function-crd.md @@ -16,6 +16,7 @@ This table lists Pulsar Function configurations. | `classname` | The class name of a Pulsar Function. | | `tenant` | The tenant of a Pulsar Function. | | `namespace` | The namespace of a Pulsar Function. | +| `ClusterName` | The Pulsar cluster of a Pulsar Function. | | `Replicas`| The number of instances that you want to run this Pulsar Function. By default, the `Replicas` is set to `1`. | | `MaxReplicas`| The maximum number of Pulsar instances that you want to run for this Pulsar Function. When the value of the `maxReplicas` parameter is greater than the value of `replicas`, it indicates that the Functions controller automatically scales the Pulsar Functions based on the CPU usage. By default, `maxReplicas` is set to 0, which indicates that auto-scaling is disabled. | | `Timeout` | The message timeout in milliseconds. | diff --git a/versioned_docs/version-0.1.4/functions/function-debug.md b/versioned_docs/version-0.1.4/functions/function-debug.md index de2be26f..e33219b2 100644 --- a/versioned_docs/version-0.1.4/functions/function-debug.md +++ b/versioned_docs/version-0.1.4/functions/function-debug.md @@ -63,7 +63,7 @@ As shown in the example above, you can get the logger via `context.getLogger()` spec: className: exclamation_function.ExclamationFunction forwardSourceMessageProperty: true - MaxPendingAsyncRequests: 1000 + maxPendingAsyncRequests: 1000 replicas: 1 maxReplicas: 5 logTopic: persistent://public/default/logging-function-logs diff --git a/versioned_docs/version-0.1.4/functions/run-function/run-go-function.md b/versioned_docs/version-0.1.4/functions/run-function/run-go-function.md index 8009313a..a36eb4bc 100644 --- a/versioned_docs/version-0.1.4/functions/run-function/run-go-function.md +++ b/versioned_docs/version-0.1.4/functions/run-function/run-go-function.md @@ -140,7 +140,7 @@ After packaging your Pulsar Go Functions, you can submit your Go Functions to a image: streamnative/pulsar-functions-go-runner:2.7.1 # using go function runner className: exclamation_function.ExclamationFunction forwardSourceMessageProperty: true - MaxPendingAsyncRequests: 1000 + maxPendingAsyncRequests: 1000 replicas: 1 maxReplicas: 5 logTopic: persistent://public/default/logging-function-logs @@ -173,7 +173,7 @@ After packaging your Pulsar Go Functions, you can submit your Go Functions to a image: streamnative/example-function-image:latest # using function image here className: exclamation_function.ExclamationFunction forwardSourceMessageProperty: true - MaxPendingAsyncRequests: 1000 + maxPendingAsyncRequests: 1000 replicas: 1 maxReplicas: 5 logTopic: persistent://public/default/logging-function-logs diff --git a/versioned_docs/version-0.1.4/functions/run-function/run-java-function.md b/versioned_docs/version-0.1.4/functions/run-function/run-java-function.md index 83611a51..783546be 100644 --- a/versioned_docs/version-0.1.4/functions/run-function/run-java-function.md +++ b/versioned_docs/version-0.1.4/functions/run-function/run-java-function.md @@ -170,7 +170,7 @@ After packaging your Pulsar Functions, you can submit your Pulsar Functions to a image: streamnative/pulsar-functions-java-runner:2.7.1 # using java function runner className: exclamation_function.ExclamationFunction forwardSourceMessageProperty: true - MaxPendingAsyncRequests: 1000 + maxPendingAsyncRequests: 1000 replicas: 1 maxReplicas: 5 logTopic: persistent://public/default/logging-function-logs @@ -200,7 +200,7 @@ After packaging your Pulsar Functions, you can submit your Pulsar Functions to a image: streamnative/example-function-image:latest # using function image here className: exclamation_function.ExclamationFunction forwardSourceMessageProperty: true - MaxPendingAsyncRequests: 1000 + maxPendingAsyncRequests: 1000 replicas: 1 maxReplicas: 5 logTopic: persistent://public/default/logging-function-logs diff --git a/versioned_docs/version-0.1.4/functions/run-function/run-python-function.md b/versioned_docs/version-0.1.4/functions/run-function/run-python-function.md index 9d729c35..881ea041 100644 --- a/versioned_docs/version-0.1.4/functions/run-function/run-python-function.md +++ b/versioned_docs/version-0.1.4/functions/run-function/run-python-function.md @@ -133,7 +133,7 @@ After packaging your Pulsar Functions, you can submit your Pulsar Functions to a image: streamnative/pulsar-functions-python-runner:2.7.1 # using python function runner className: exclamation_function.ExclamationFunction forwardSourceMessageProperty: true - MaxPendingAsyncRequests: 1000 + maxPendingAsyncRequests: 1000 replicas: 1 maxReplicas: 5 logTopic: persistent://public/default/logging-function-logs @@ -166,7 +166,7 @@ After packaging your Pulsar Functions, you can submit your Pulsar Functions to a image: streamnative/example-function-image:latest # using function image here className: exclamation_function.ExclamationFunction forwardSourceMessageProperty: true - MaxPendingAsyncRequests: 1000 + maxPendingAsyncRequests: 1000 replicas: 1 maxReplicas: 5 logTopic: persistent://public/default/logging-function-logs diff --git a/versioned_docs/version-0.1.4/scaling.md b/versioned_docs/version-0.1.4/scaling.md index 8a63255d..cc90ec44 100644 --- a/versioned_docs/version-0.1.4/scaling.md +++ b/versioned_docs/version-0.1.4/scaling.md @@ -47,7 +47,7 @@ This example shows how to auto-scale the number of Pods running Pulsar Functions spec: className: org.apache.pulsar.functions.api.examples.ExclamationFunction forwardSourceMessageProperty: true - MaxPendingAsyncRequests: 1000 + maxPendingAsyncRequests: 1000 replicas: 1 maxReplicas: 8 logTopic: persistent://public/default/logging-function-logs @@ -84,8 +84,6 @@ This example shows how to auto-scale the number of Pods for running a Pulsar sou className: org.apache.pulsar.io.debezium.mongodb.DebeziumMongoDbSource replicas: 1 maxReplicas: 5 - replicas: 1 - maxReplicas: 1 output: producerConf: maxPendingMessages: 1000 diff --git a/versioned_docs/version-0.1.5/connectors/io-crd-config/sink-crd-config.md b/versioned_docs/version-0.1.5/connectors/io-crd-config/sink-crd-config.md index f0e3549e..58789088 100644 --- a/versioned_docs/version-0.1.5/connectors/io-crd-config/sink-crd-config.md +++ b/versioned_docs/version-0.1.5/connectors/io-crd-config/sink-crd-config.md @@ -14,6 +14,7 @@ This table lists sink configurations. | `name` | The name of a sink connector. | | `classname` | The class name of a sink connector. | | `tenant` | The tenant of a sink connector. | +| `ClusterName` | The Pulsar cluster of a sink connector. | | `Replicas`| The number of instances that you want to run this sink connector. By default, the `Replicas` is set to `1`. | | `MaxReplicas`| The maximum number of Pulsar instances that you want to run for this sink connector. When the value of the `maxReplicas` parameter is greater than the value of `replicas`, it indicates that the sink controller automatically scales the sink connector based on the CPU usage. By default, `maxReplicas` is set to 0, which indicates that auto-scaling is disabled. | | `SinkConfig` | The map to a ConfigMap specifying the configuration of a sink connector. | diff --git a/versioned_docs/version-0.1.5/connectors/io-crd-config/source-crd-config.md b/versioned_docs/version-0.1.5/connectors/io-crd-config/source-crd-config.md index 5065bbaf..e62fac40 100644 --- a/versioned_docs/version-0.1.5/connectors/io-crd-config/source-crd-config.md +++ b/versioned_docs/version-0.1.5/connectors/io-crd-config/source-crd-config.md @@ -14,6 +14,7 @@ This table lists source configurations. | `name` | The name of a source connector. | | `classname` | The class name of a source connector. | | `tenant` | The tenant of a source connector. | +| `ClusterName` | The Pulsar cluster of a source connector. | | `Replicas`| The number of instances that you want to run this source connector. By default, the `Replicas` is set to `1`. | | `MaxReplicas`| The maximum number of Pulsar instances that you want to run for this source connector. When the value of the `maxReplicas` parameter is greater than the value of `replicas`, it indicates that the source controller automatically scales the source connector based on the CPU usage. By default, `maxReplicas` is set to 0, which indicates that auto-scaling is disabled. | | `SourceConfig` | The map to a ConfigMap specifying the configuration of a source connector. | diff --git a/versioned_docs/version-0.1.5/connectors/run-connector.md b/versioned_docs/version-0.1.5/connectors/run-connector.md index 10982eac..6b539c66 100644 --- a/versioned_docs/version-0.1.5/connectors/run-connector.md +++ b/versioned_docs/version-0.1.5/connectors/run-connector.md @@ -42,11 +42,11 @@ For Pulsar built-in connectors and StreamNative-managed connectors, you can crea pulsarConfig: "test-sink" resources: limits: - cpu: "0.2" - memory: 1.1G + cpu: "0.2" + memory: 1.1G requests: - cpu: "0.1" - memory: 1G + cpu: "0.1" + memory: 1G java: extraDependenciesDir: random-dir/ jar: connectors/pulsar-io-elastic-search-2.7.1.nar # the NAR location in image @@ -213,7 +213,7 @@ For self-built connectors, you can create them based on how you package them. image: streamnative/pulsar-functions-java-runner:2.7.1 # using java function runner className: org.example.MySink forwardSourceMessageProperty: true - MaxPendingAsyncRequests: 1000 + maxPendingAsyncRequests: 1000 replicas: 1 maxReplicas: 1 input: @@ -241,7 +241,7 @@ For self-built connectors, you can create them based on how you package them. spec: image: myorg/pulsar-io-my-sink:2.7.1 # using self built image forwardSourceMessageProperty: true - MaxPendingAsyncRequests: 1000 + maxPendingAsyncRequests: 1000 replicas: 1 maxReplicas: 1 input: diff --git a/versioned_docs/version-0.1.5/functions/function-crd.md b/versioned_docs/version-0.1.5/functions/function-crd.md index 0e53d38f..d83ecc68 100644 --- a/versioned_docs/version-0.1.5/functions/function-crd.md +++ b/versioned_docs/version-0.1.5/functions/function-crd.md @@ -16,6 +16,7 @@ This table lists Pulsar Function configurations. | `classname` | The class name of a Pulsar Function. | | `tenant` | The tenant of a Pulsar Function. | | `namespace` | The namespace of a Pulsar Function. | +| `ClusterName` | The Pulsar cluster of a Pulsar Function. | | `Replicas`| The number of instances that you want to run this Pulsar Function. By default, the `Replicas` is set to `1`. | | `MaxReplicas`| The maximum number of Pulsar instances that you want to run for this Pulsar Function. When the value of the `maxReplicas` parameter is greater than the value of `replicas`, it indicates that the Functions controller automatically scales the Pulsar Functions based on the CPU usage. By default, `maxReplicas` is set to 0, which indicates that auto-scaling is disabled. | | `Timeout` | The message timeout in milliseconds. | diff --git a/versioned_docs/version-0.1.5/functions/function-debug.md b/versioned_docs/version-0.1.5/functions/function-debug.md index de2be26f..e33219b2 100644 --- a/versioned_docs/version-0.1.5/functions/function-debug.md +++ b/versioned_docs/version-0.1.5/functions/function-debug.md @@ -63,7 +63,7 @@ As shown in the example above, you can get the logger via `context.getLogger()` spec: className: exclamation_function.ExclamationFunction forwardSourceMessageProperty: true - MaxPendingAsyncRequests: 1000 + maxPendingAsyncRequests: 1000 replicas: 1 maxReplicas: 5 logTopic: persistent://public/default/logging-function-logs diff --git a/versioned_docs/version-0.1.5/functions/run-function/run-go-function.md b/versioned_docs/version-0.1.5/functions/run-function/run-go-function.md index 8009313a..a36eb4bc 100644 --- a/versioned_docs/version-0.1.5/functions/run-function/run-go-function.md +++ b/versioned_docs/version-0.1.5/functions/run-function/run-go-function.md @@ -140,7 +140,7 @@ After packaging your Pulsar Go Functions, you can submit your Go Functions to a image: streamnative/pulsar-functions-go-runner:2.7.1 # using go function runner className: exclamation_function.ExclamationFunction forwardSourceMessageProperty: true - MaxPendingAsyncRequests: 1000 + maxPendingAsyncRequests: 1000 replicas: 1 maxReplicas: 5 logTopic: persistent://public/default/logging-function-logs @@ -173,7 +173,7 @@ After packaging your Pulsar Go Functions, you can submit your Go Functions to a image: streamnative/example-function-image:latest # using function image here className: exclamation_function.ExclamationFunction forwardSourceMessageProperty: true - MaxPendingAsyncRequests: 1000 + maxPendingAsyncRequests: 1000 replicas: 1 maxReplicas: 5 logTopic: persistent://public/default/logging-function-logs diff --git a/versioned_docs/version-0.1.5/functions/run-function/run-java-function.md b/versioned_docs/version-0.1.5/functions/run-function/run-java-function.md index 81e9f5e2..17a9376b 100644 --- a/versioned_docs/version-0.1.5/functions/run-function/run-java-function.md +++ b/versioned_docs/version-0.1.5/functions/run-function/run-java-function.md @@ -170,7 +170,7 @@ After packaging your Pulsar Functions, you can submit your Pulsar Functions to a image: streamnative/pulsar-functions-java-runner:2.7.1 # using java function runner className: exclamation_function.ExclamationFunction forwardSourceMessageProperty: true - MaxPendingAsyncRequests: 1000 + maxPendingAsyncRequests: 1000 replicas: 1 maxReplicas: 5 logTopic: persistent://public/default/logging-function-logs @@ -201,7 +201,7 @@ After packaging your Pulsar Functions, you can submit your Pulsar Functions to a image: streamnative/example-function-image:latest # using function image here className: exclamation_function.ExclamationFunction forwardSourceMessageProperty: true - MaxPendingAsyncRequests: 1000 + maxPendingAsyncRequests: 1000 replicas: 1 maxReplicas: 5 logTopic: persistent://public/default/logging-function-logs diff --git a/versioned_docs/version-0.1.5/functions/run-function/run-python-function.md b/versioned_docs/version-0.1.5/functions/run-function/run-python-function.md index 9d729c35..881ea041 100644 --- a/versioned_docs/version-0.1.5/functions/run-function/run-python-function.md +++ b/versioned_docs/version-0.1.5/functions/run-function/run-python-function.md @@ -133,7 +133,7 @@ After packaging your Pulsar Functions, you can submit your Pulsar Functions to a image: streamnative/pulsar-functions-python-runner:2.7.1 # using python function runner className: exclamation_function.ExclamationFunction forwardSourceMessageProperty: true - MaxPendingAsyncRequests: 1000 + maxPendingAsyncRequests: 1000 replicas: 1 maxReplicas: 5 logTopic: persistent://public/default/logging-function-logs @@ -166,7 +166,7 @@ After packaging your Pulsar Functions, you can submit your Pulsar Functions to a image: streamnative/example-function-image:latest # using function image here className: exclamation_function.ExclamationFunction forwardSourceMessageProperty: true - MaxPendingAsyncRequests: 1000 + maxPendingAsyncRequests: 1000 replicas: 1 maxReplicas: 5 logTopic: persistent://public/default/logging-function-logs diff --git a/versioned_docs/version-0.1.5/scaling.md b/versioned_docs/version-0.1.5/scaling.md index 8a63255d..cc90ec44 100644 --- a/versioned_docs/version-0.1.5/scaling.md +++ b/versioned_docs/version-0.1.5/scaling.md @@ -47,7 +47,7 @@ This example shows how to auto-scale the number of Pods running Pulsar Functions spec: className: org.apache.pulsar.functions.api.examples.ExclamationFunction forwardSourceMessageProperty: true - MaxPendingAsyncRequests: 1000 + maxPendingAsyncRequests: 1000 replicas: 1 maxReplicas: 8 logTopic: persistent://public/default/logging-function-logs @@ -84,8 +84,6 @@ This example shows how to auto-scale the number of Pods for running a Pulsar sou className: org.apache.pulsar.io.debezium.mongodb.DebeziumMongoDbSource replicas: 1 maxReplicas: 5 - replicas: 1 - maxReplicas: 1 output: producerConf: maxPendingMessages: 1000 diff --git a/versioned_docs/version-0.1.6/connectors/io-crd-config/sink-crd-config.md b/versioned_docs/version-0.1.6/connectors/io-crd-config/sink-crd-config.md index 67853542..e08d1853 100644 --- a/versioned_docs/version-0.1.6/connectors/io-crd-config/sink-crd-config.md +++ b/versioned_docs/version-0.1.6/connectors/io-crd-config/sink-crd-config.md @@ -14,6 +14,7 @@ This table lists sink configurations. | `name` | The name of a sink connector. | | `classname` | The class name of a sink connector. | | `tenant` | The tenant of a sink connector. | +| `ClusterName` | The Pulsar cluster of a sink connector. | | `Replicas`| The number of instances that you want to run this sink connector. By default, the `Replicas` is set to `1`. | | `MaxReplicas`| The maximum number of Pulsar instances that you want to run for this sink connector. When the value of the `maxReplicas` parameter is greater than the value of `replicas`, it indicates that the sink controller automatically scales the sink connector based on the CPU usage. By default, `maxReplicas` is set to 0, which indicates that auto-scaling is disabled. | | `SinkConfig` | The map to a ConfigMap specifying the configuration of a sink connector. | diff --git a/versioned_docs/version-0.1.6/connectors/io-crd-config/source-crd-config.md b/versioned_docs/version-0.1.6/connectors/io-crd-config/source-crd-config.md index 891be031..ae2a44bb 100644 --- a/versioned_docs/version-0.1.6/connectors/io-crd-config/source-crd-config.md +++ b/versioned_docs/version-0.1.6/connectors/io-crd-config/source-crd-config.md @@ -14,6 +14,7 @@ This table lists source configurations. | `name` | The name of a source connector. | | `classname` | The class name of a source connector. | | `tenant` | The tenant of a source connector. | +| `ClusterName` | The Pulsar cluster of a source connector. | | `Replicas`| The number of instances that you want to run this source connector. | | `MaxReplicas`| The maximum number of Pulsar instances that you want to run for this source connector. When the value of the `maxReplicas` parameter is greater than the value of `replicas`, it indicates that the source controller automatically scales the source connector based on the CPU usage. By default, `maxReplicas` is set to 0, which indicates that auto-scaling is disabled. | | `SourceConfig` | The map to a ConfigMap specifying the configuration of a source connector. | diff --git a/versioned_docs/version-0.1.6/connectors/run-connector.md b/versioned_docs/version-0.1.6/connectors/run-connector.md index 10982eac..6b539c66 100644 --- a/versioned_docs/version-0.1.6/connectors/run-connector.md +++ b/versioned_docs/version-0.1.6/connectors/run-connector.md @@ -42,11 +42,11 @@ For Pulsar built-in connectors and StreamNative-managed connectors, you can crea pulsarConfig: "test-sink" resources: limits: - cpu: "0.2" - memory: 1.1G + cpu: "0.2" + memory: 1.1G requests: - cpu: "0.1" - memory: 1G + cpu: "0.1" + memory: 1G java: extraDependenciesDir: random-dir/ jar: connectors/pulsar-io-elastic-search-2.7.1.nar # the NAR location in image @@ -213,7 +213,7 @@ For self-built connectors, you can create them based on how you package them. image: streamnative/pulsar-functions-java-runner:2.7.1 # using java function runner className: org.example.MySink forwardSourceMessageProperty: true - MaxPendingAsyncRequests: 1000 + maxPendingAsyncRequests: 1000 replicas: 1 maxReplicas: 1 input: @@ -241,7 +241,7 @@ For self-built connectors, you can create them based on how you package them. spec: image: myorg/pulsar-io-my-sink:2.7.1 # using self built image forwardSourceMessageProperty: true - MaxPendingAsyncRequests: 1000 + maxPendingAsyncRequests: 1000 replicas: 1 maxReplicas: 1 input: diff --git a/versioned_docs/version-0.1.6/functions/function-crd.md b/versioned_docs/version-0.1.6/functions/function-crd.md index 5b4f5a94..e9d1083a 100644 --- a/versioned_docs/version-0.1.6/functions/function-crd.md +++ b/versioned_docs/version-0.1.6/functions/function-crd.md @@ -16,6 +16,7 @@ This table lists Pulsar Function configurations. | `classname` | The class name of a Pulsar Function. | | `tenant` | The tenant of a Pulsar Function. | | `namespace` | The namespace of a Pulsar Function. | +| `ClusterName` | The Pulsar cluster of a Pulsar Function. | | `Replicas`| The number of instances that you want to run this Pulsar Function. By default, the `Replicas` is set to `1`. | | `MaxReplicas`| The maximum number of Pulsar instances that you want to run for this Pulsar Function. When the value of the `maxReplicas` parameter is greater than the value of `replicas`, it indicates that the Functions controller automatically scales the Pulsar Functions based on the CPU usage. By default, `maxReplicas` is set to 0, which indicates that auto-scaling is disabled. | | `Timeout` | The message timeout in milliseconds. | diff --git a/versioned_docs/version-0.1.6/functions/function-debug.md b/versioned_docs/version-0.1.6/functions/function-debug.md index de2be26f..e33219b2 100644 --- a/versioned_docs/version-0.1.6/functions/function-debug.md +++ b/versioned_docs/version-0.1.6/functions/function-debug.md @@ -63,7 +63,7 @@ As shown in the example above, you can get the logger via `context.getLogger()` spec: className: exclamation_function.ExclamationFunction forwardSourceMessageProperty: true - MaxPendingAsyncRequests: 1000 + maxPendingAsyncRequests: 1000 replicas: 1 maxReplicas: 5 logTopic: persistent://public/default/logging-function-logs diff --git a/versioned_docs/version-0.1.6/functions/run-function/run-go-function.md b/versioned_docs/version-0.1.6/functions/run-function/run-go-function.md index 8009313a..a36eb4bc 100644 --- a/versioned_docs/version-0.1.6/functions/run-function/run-go-function.md +++ b/versioned_docs/version-0.1.6/functions/run-function/run-go-function.md @@ -140,7 +140,7 @@ After packaging your Pulsar Go Functions, you can submit your Go Functions to a image: streamnative/pulsar-functions-go-runner:2.7.1 # using go function runner className: exclamation_function.ExclamationFunction forwardSourceMessageProperty: true - MaxPendingAsyncRequests: 1000 + maxPendingAsyncRequests: 1000 replicas: 1 maxReplicas: 5 logTopic: persistent://public/default/logging-function-logs @@ -173,7 +173,7 @@ After packaging your Pulsar Go Functions, you can submit your Go Functions to a image: streamnative/example-function-image:latest # using function image here className: exclamation_function.ExclamationFunction forwardSourceMessageProperty: true - MaxPendingAsyncRequests: 1000 + maxPendingAsyncRequests: 1000 replicas: 1 maxReplicas: 5 logTopic: persistent://public/default/logging-function-logs diff --git a/versioned_docs/version-0.1.6/functions/run-function/run-java-function.md b/versioned_docs/version-0.1.6/functions/run-function/run-java-function.md index 81e9f5e2..17a9376b 100644 --- a/versioned_docs/version-0.1.6/functions/run-function/run-java-function.md +++ b/versioned_docs/version-0.1.6/functions/run-function/run-java-function.md @@ -170,7 +170,7 @@ After packaging your Pulsar Functions, you can submit your Pulsar Functions to a image: streamnative/pulsar-functions-java-runner:2.7.1 # using java function runner className: exclamation_function.ExclamationFunction forwardSourceMessageProperty: true - MaxPendingAsyncRequests: 1000 + maxPendingAsyncRequests: 1000 replicas: 1 maxReplicas: 5 logTopic: persistent://public/default/logging-function-logs @@ -201,7 +201,7 @@ After packaging your Pulsar Functions, you can submit your Pulsar Functions to a image: streamnative/example-function-image:latest # using function image here className: exclamation_function.ExclamationFunction forwardSourceMessageProperty: true - MaxPendingAsyncRequests: 1000 + maxPendingAsyncRequests: 1000 replicas: 1 maxReplicas: 5 logTopic: persistent://public/default/logging-function-logs diff --git a/versioned_docs/version-0.1.6/functions/run-function/run-python-function.md b/versioned_docs/version-0.1.6/functions/run-function/run-python-function.md index 9d729c35..881ea041 100644 --- a/versioned_docs/version-0.1.6/functions/run-function/run-python-function.md +++ b/versioned_docs/version-0.1.6/functions/run-function/run-python-function.md @@ -133,7 +133,7 @@ After packaging your Pulsar Functions, you can submit your Pulsar Functions to a image: streamnative/pulsar-functions-python-runner:2.7.1 # using python function runner className: exclamation_function.ExclamationFunction forwardSourceMessageProperty: true - MaxPendingAsyncRequests: 1000 + maxPendingAsyncRequests: 1000 replicas: 1 maxReplicas: 5 logTopic: persistent://public/default/logging-function-logs @@ -166,7 +166,7 @@ After packaging your Pulsar Functions, you can submit your Pulsar Functions to a image: streamnative/example-function-image:latest # using function image here className: exclamation_function.ExclamationFunction forwardSourceMessageProperty: true - MaxPendingAsyncRequests: 1000 + maxPendingAsyncRequests: 1000 replicas: 1 maxReplicas: 5 logTopic: persistent://public/default/logging-function-logs diff --git a/versioned_docs/version-0.1.6/scaling.md b/versioned_docs/version-0.1.6/scaling.md index 8a63255d..cc90ec44 100644 --- a/versioned_docs/version-0.1.6/scaling.md +++ b/versioned_docs/version-0.1.6/scaling.md @@ -47,7 +47,7 @@ This example shows how to auto-scale the number of Pods running Pulsar Functions spec: className: org.apache.pulsar.functions.api.examples.ExclamationFunction forwardSourceMessageProperty: true - MaxPendingAsyncRequests: 1000 + maxPendingAsyncRequests: 1000 replicas: 1 maxReplicas: 8 logTopic: persistent://public/default/logging-function-logs @@ -84,8 +84,6 @@ This example shows how to auto-scale the number of Pods for running a Pulsar sou className: org.apache.pulsar.io.debezium.mongodb.DebeziumMongoDbSource replicas: 1 maxReplicas: 5 - replicas: 1 - maxReplicas: 1 output: producerConf: maxPendingMessages: 1000 diff --git a/versioned_docs/version-0.1.7/connectors/io-crd-config/sink-crd-config.md b/versioned_docs/version-0.1.7/connectors/io-crd-config/sink-crd-config.md index d7d94508..a9095b19 100644 --- a/versioned_docs/version-0.1.7/connectors/io-crd-config/sink-crd-config.md +++ b/versioned_docs/version-0.1.7/connectors/io-crd-config/sink-crd-config.md @@ -15,6 +15,7 @@ This table lists sink configurations. | `classname` | The class name of a sink connector. | | `tenant` | The tenant of a sink connector. | | `namespace` | The Pulsar namespace of a sink connector. | +| `ClusterName` | The Pulsar cluster of a sink connector. | | `Replicas`| The number of instances that you want to run this sink connector. By default, the `Replicas` is set to `1`. | | `MaxReplicas`| The maximum number of Pulsar instances that you want to run for this sink connector. When the value of the `maxReplicas` parameter is greater than the value of `replicas`, it indicates that the sink controller automatically scales the sink connector based on the CPU usage. By default, `maxReplicas` is set to 0, which indicates that auto-scaling is disabled. | | `SinkConfig` | The sink connector configurations in YAML format.| diff --git a/versioned_docs/version-0.1.7/connectors/io-crd-config/source-crd-config.md b/versioned_docs/version-0.1.7/connectors/io-crd-config/source-crd-config.md index eff7da57..778fd591 100644 --- a/versioned_docs/version-0.1.7/connectors/io-crd-config/source-crd-config.md +++ b/versioned_docs/version-0.1.7/connectors/io-crd-config/source-crd-config.md @@ -15,6 +15,7 @@ This table lists source configurations. | `classname` | The class name of a source connector. | | `tenant` | The tenant of a source connector. | | `namespace` | The Pulsar namespace of a source connector. | +| `ClusterName` | The Pulsar cluster of a source connector. | | `Replicas`| The number of instances that you want to run this source connector. | | `MaxReplicas`| The maximum number of Pulsar instances that you want to run for this source connector. When the value of the `maxReplicas` parameter is greater than the value of `replicas`, it indicates that the source controller automatically scales the source connector based on the CPU usage. By default, `maxReplicas` is set to 0, which indicates that auto-scaling is disabled. | | `SourceConfig` | The source connector configurations in YAML format. | diff --git a/versioned_docs/version-0.1.7/connectors/run-connector.md b/versioned_docs/version-0.1.7/connectors/run-connector.md index d60e9702..805fe54e 100644 --- a/versioned_docs/version-0.1.7/connectors/run-connector.md +++ b/versioned_docs/version-0.1.7/connectors/run-connector.md @@ -42,11 +42,11 @@ For Pulsar built-in connectors and StreamNative-managed connectors, you can crea pulsarConfig: "test-sink" resources: limits: - cpu: "0.2" - memory: 1.1G + cpu: "0.2" + memory: 1.1G requests: - cpu: "0.1" - memory: 1G + cpu: "0.1" + memory: 1G java: extraDependenciesDir: random-dir/ jar: connectors/pulsar-io-elastic-search-2.7.1.nar # the NAR location in image @@ -217,7 +217,7 @@ For self-built connectors, you can create them based on how you package them. image: streamnative/pulsar-functions-java-runner:2.7.1 # using java function runner className: org.example.MySink forwardSourceMessageProperty: true - MaxPendingAsyncRequests: 1000 + maxPendingAsyncRequests: 1000 replicas: 1 maxReplicas: 1 input: @@ -245,7 +245,7 @@ For self-built connectors, you can create them based on how you package them. spec: image: myorg/pulsar-io-my-sink:2.7.1 # using self built image forwardSourceMessageProperty: true - MaxPendingAsyncRequests: 1000 + maxPendingAsyncRequests: 1000 replicas: 1 maxReplicas: 1 input: diff --git a/versioned_docs/version-0.1.7/functions/function-crd.md b/versioned_docs/version-0.1.7/functions/function-crd.md index 6b6e96a1..f4945397 100644 --- a/versioned_docs/version-0.1.7/functions/function-crd.md +++ b/versioned_docs/version-0.1.7/functions/function-crd.md @@ -16,6 +16,7 @@ This table lists Pulsar Function configurations. | `classname` | The class name of a Pulsar Function. | | `tenant` | The tenant of a Pulsar Function. | | `namespace` | The Pulsar namespace of a Pulsar Function. | +| `ClusterName` | The Pulsar cluster of a Pulsar Function. | | `Replicas`| The number of instances that you want to run this Pulsar Function. By default, the `Replicas` is set to `1`. | | `MaxReplicas`| The maximum number of Pulsar instances that you want to run for this Pulsar Function. When the value of the `maxReplicas` parameter is greater than the value of `replicas`, it indicates that the Functions controller automatically scales the Pulsar Functions based on the CPU usage. By default, `maxReplicas` is set to 0, which indicates that auto-scaling is disabled. | | `Timeout` | The message timeout in milliseconds. | diff --git a/versioned_docs/version-0.1.7/functions/function-debug.md b/versioned_docs/version-0.1.7/functions/function-debug.md index 8101968e..152c10cd 100644 --- a/versioned_docs/version-0.1.7/functions/function-debug.md +++ b/versioned_docs/version-0.1.7/functions/function-debug.md @@ -63,7 +63,7 @@ As shown in the example above, you can get the logger via `context.getLogger()` spec: className: exclamation_function.ExclamationFunction forwardSourceMessageProperty: true - MaxPendingAsyncRequests: 1000 + maxPendingAsyncRequests: 1000 replicas: 1 maxReplicas: 5 logTopic: persistent://public/default/logging-function-logs diff --git a/versioned_docs/version-0.1.7/functions/run-function/run-go-function.md b/versioned_docs/version-0.1.7/functions/run-function/run-go-function.md index 2bc4d1dd..7d24824e 100644 --- a/versioned_docs/version-0.1.7/functions/run-function/run-go-function.md +++ b/versioned_docs/version-0.1.7/functions/run-function/run-go-function.md @@ -144,7 +144,7 @@ After packaging your Pulsar Go Functions, you can submit your Go Functions to a image: streamnative/pulsar-functions-go-runner:2.7.1 # using go function runner className: exclamation_function.ExclamationFunction forwardSourceMessageProperty: true - MaxPendingAsyncRequests: 1000 + maxPendingAsyncRequests: 1000 replicas: 1 maxReplicas: 5 logTopic: persistent://public/default/logging-function-logs @@ -177,7 +177,7 @@ After packaging your Pulsar Go Functions, you can submit your Go Functions to a image: streamnative/example-function-image:latest # using function image here className: exclamation_function.ExclamationFunction forwardSourceMessageProperty: true - MaxPendingAsyncRequests: 1000 + maxPendingAsyncRequests: 1000 replicas: 1 maxReplicas: 5 logTopic: persistent://public/default/logging-function-logs diff --git a/versioned_docs/version-0.1.7/functions/run-function/run-java-function.md b/versioned_docs/version-0.1.7/functions/run-function/run-java-function.md index 61d0fa31..0534f32a 100644 --- a/versioned_docs/version-0.1.7/functions/run-function/run-java-function.md +++ b/versioned_docs/version-0.1.7/functions/run-function/run-java-function.md @@ -174,7 +174,7 @@ After packaging your Pulsar Functions, you can submit your Pulsar Functions to a image: streamnative/pulsar-functions-java-runner:2.7.1 # using java function runner className: exclamation_function.ExclamationFunction forwardSourceMessageProperty: true - MaxPendingAsyncRequests: 1000 + maxPendingAsyncRequests: 1000 replicas: 1 maxReplicas: 5 logTopic: persistent://public/default/logging-function-logs @@ -205,7 +205,7 @@ After packaging your Pulsar Functions, you can submit your Pulsar Functions to a image: streamnative/example-function-image:latest # using function image here className: exclamation_function.ExclamationFunction forwardSourceMessageProperty: true - MaxPendingAsyncRequests: 1000 + maxPendingAsyncRequests: 1000 replicas: 1 maxReplicas: 5 logTopic: persistent://public/default/logging-function-logs diff --git a/versioned_docs/version-0.1.7/functions/run-function/run-python-function.md b/versioned_docs/version-0.1.7/functions/run-function/run-python-function.md index 4e641922..36872bc3 100644 --- a/versioned_docs/version-0.1.7/functions/run-function/run-python-function.md +++ b/versioned_docs/version-0.1.7/functions/run-function/run-python-function.md @@ -137,7 +137,7 @@ After packaging your Pulsar Functions, you can submit your Pulsar Functions to a image: streamnative/pulsar-functions-python-runner:2.7.1 # using python function runner className: exclamation_function.ExclamationFunction forwardSourceMessageProperty: true - MaxPendingAsyncRequests: 1000 + maxPendingAsyncRequests: 1000 replicas: 1 maxReplicas: 5 logTopic: persistent://public/default/logging-function-logs @@ -170,7 +170,7 @@ After packaging your Pulsar Functions, you can submit your Pulsar Functions to a image: streamnative/example-function-image:latest # using function image here className: exclamation_function.ExclamationFunction forwardSourceMessageProperty: true - MaxPendingAsyncRequests: 1000 + maxPendingAsyncRequests: 1000 replicas: 1 maxReplicas: 5 logTopic: persistent://public/default/logging-function-logs diff --git a/versioned_docs/version-0.1.7/scaling.md b/versioned_docs/version-0.1.7/scaling.md index 0df7a5aa..71b140b4 100644 --- a/versioned_docs/version-0.1.7/scaling.md +++ b/versioned_docs/version-0.1.7/scaling.md @@ -81,7 +81,7 @@ These examples describe how to auto-scale the number of Pods running Pulsar Func spec: className: org.apache.pulsar.functions.api.examples.ExclamationFunction forwardSourceMessageProperty: true - MaxPendingAsyncRequests: 1000 + maxPendingAsyncRequests: 1000 replicas: 1 maxReplicas: 8 logTopic: persistent://public/default/logging-function-logs @@ -114,7 +114,7 @@ These examples describe how to auto-scale the number of Pods running Pulsar Func spec: className: org.apache.pulsar.functions.api.examples.ExclamationFunction forwardSourceMessageProperty: true - MaxPendingAsyncRequests: 1000 + maxPendingAsyncRequests: 1000 replicas: 1 maxReplicas: 4 logTopic: persistent://public/default/logging-function-logs @@ -151,7 +151,7 @@ These examples describe how to auto-scale the number of Pods running Pulsar Func spec: className: org.apache.pulsar.functions.api.examples.ExclamationFunction forwardSourceMessageProperty: true - MaxPendingAsyncRequests: 1000 + maxPendingAsyncRequests: 1000 replicas: 1 maxReplicas: 4 logTopic: persistent://public/default/logging-function-logs