You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@pulsar.apache.org by rx...@apache.org on 2020/07/29 10:48:31 UTC
[pulsar] branch branch-2.6 updated (a1f56e3 -> b10585b)
This is an automated email from the ASF dual-hosted git repository.
rxl pushed a change to branch branch-2.6
in repository https://gitbox.apache.org/repos/asf/pulsar.git.
from a1f56e3 [doc] add cpp client document for oauth2 authentication
new 4c3c9cc [doc] Add pulsar-client-go oauth2 authentication document (#7648)
new d0b058f fix #7437 (#7687)
new b10585b [Doc] Add a note about --state-storage-service-url in localrun command of Function
The 3 revisions listed above as "new" are entirely new to this
repository and will be described in separate emails. The revisions
listed as "add" were already present in the repository and have only
been added to this reference.
Summary of changes:
.../org/apache/pulsar/client/admin/PulsarAdmin.java | 20 ++++++++------------
.../admin/internal/http/AsyncHttpConnector.java | 1 +
site2/docs/client-libraries-go.md | 19 +++++++++++++++++++
site2/docs/reference-pulsar-admin.md | 2 +-
site2/docs/security-oauth2.md | 19 +++++++++++++++++++
.../version-2.3.0/reference-pulsar-admin.md | 3 +--
.../version-2.3.1/reference-pulsar-admin.md | 3 +--
.../version-2.3.2/reference-pulsar-admin.md | 2 +-
.../version-2.4.0/reference-pulsar-admin.md | 2 +-
.../version-2.4.1/reference-pulsar-admin.md | 2 +-
.../version-2.4.2/reference-pulsar-admin.md | 2 +-
.../version-2.5.0/reference-pulsar-admin.md | 2 +-
.../version-2.5.1/reference-pulsar-admin.md | 2 +-
.../version-2.5.2/reference-pulsar-admin.md | 2 +-
14 files changed, 57 insertions(+), 24 deletions(-)
[pulsar] 01/03: [doc] Add pulsar-client-go oauth2 authentication
document (#7648)
Posted by rx...@apache.org.
This is an automated email from the ASF dual-hosted git repository.
rxl pushed a commit to branch branch-2.6
in repository https://gitbox.apache.org/repos/asf/pulsar.git
commit 4c3c9cc09598b58c9351d98d844f093c6be6a2a5
Author: Yong Zhang <zh...@gmail.com>
AuthorDate: Tue Jul 28 19:40:52 2020 +0800
[doc] Add pulsar-client-go oauth2 authentication document (#7648)
* [doc] Add pulsar-client-go oauth2 authentication document
---
*Motivation*
Add pulsar-client-go oauth2 authentication usage document.
* Address comments
(cherry picked from commit 24fa8cfcbe77faec66db66a478182709dad74bd8)
---
site2/docs/client-libraries-go.md | 19 +++++++++++++++++++
site2/docs/security-oauth2.md | 19 +++++++++++++++++++
2 files changed, 38 insertions(+)
diff --git a/site2/docs/client-libraries-go.md b/site2/docs/client-libraries-go.md
index 90cd346..83f8930 100644
--- a/site2/docs/client-libraries-go.md
+++ b/site2/docs/client-libraries-go.md
@@ -658,3 +658,22 @@ opts := pulsar.ClientOptions{
Authentication: NewAuthenticationTLS("my-cert.pem", "my-key.pem"),
}
```
+
+## OAuth2 authentication
+
+To use [OAuth2 authentication](security-oauth2.md), you'll need to configure your client to perform the following operations.
+This example shows how to configure OAuth2 authentication.
+
+```go
+oauth := pulsar.NewAuthenticationOAuth2(map[string]string{
+ "type": "client_credentials",
+ "issuerUrl": "https://dev-kt-aa9ne.us.auth0.com/oauth/token",
+ "audience": "https://dev-kt-aa9ne.us.auth0.com/api/v2/",
+ "privateKey": "/path/to/privateKey",
+ "clientId": "0Xx...Yyxeny",
+ })
+client, err := pulsar.NewClient(pulsar.ClientOptions{
+ URL: "puslar://my-cluster:6650",
+ Authentication: oauth,
+})
+```
diff --git a/site2/docs/security-oauth2.md b/site2/docs/security-oauth2.md
index c847112..41b660f 100644
--- a/site2/docs/security-oauth2.md
+++ b/site2/docs/security-oauth2.md
@@ -113,3 +113,22 @@ config.setAuth(pulsar::AuthOauth2::create(params));
pulsar::Client client("pulsar://broker.example.com:6650/", config);
```
+
+### Go client
+
+To enable OAuth2 authentication in Go client, you need to configure OAuth2 authentication.
+This example shows how to configure OAuth2 authentication in Go client.
+
+```go
+oauth := pulsar.NewAuthenticationOAuth2(map[string]string{
+ "type": "client_credentials",
+ "issuerUrl": "https://dev-kt-aa9ne.us.auth0.com/oauth/token",
+ "audience": "https://dev-kt-aa9ne.us.auth0.com/api/v2/",
+ "privateKey": "/path/to/privateKey",
+ "clientId": "0Xx...Yyxeny",
+ })
+client, err := pulsar.NewClient(pulsar.ClientOptions{
+ URL: "puslar://my-cluster:6650",
+ Authentication: oauth,
+})
+```
[pulsar] 02/03: fix #7437 (#7687)
Posted by rx...@apache.org.
This is an automated email from the ASF dual-hosted git repository.
rxl pushed a commit to branch branch-2.6
in repository https://gitbox.apache.org/repos/asf/pulsar.git
commit d0b058f0b361e0a6810f2d8e34c4049f3f077899
Author: rushsky518 <zh...@oppo.com>
AuthorDate: Wed Jul 29 14:34:10 2020 +0800
fix #7437 (#7687)
(cherry picked from commit f2532c858de72150453c1956753d71b1e6f4ab3a)
---
.../org/apache/pulsar/client/admin/PulsarAdmin.java | 20 ++++++++------------
.../admin/internal/http/AsyncHttpConnector.java | 1 +
2 files changed, 9 insertions(+), 12 deletions(-)
diff --git a/pulsar-client-admin/src/main/java/org/apache/pulsar/client/admin/PulsarAdmin.java b/pulsar-client-admin/src/main/java/org/apache/pulsar/client/admin/PulsarAdmin.java
index 561e72f..c997cd8 100644
--- a/pulsar-client-admin/src/main/java/org/apache/pulsar/client/admin/PulsarAdmin.java
+++ b/pulsar-client-admin/src/main/java/org/apache/pulsar/client/admin/PulsarAdmin.java
@@ -47,13 +47,13 @@ import org.apache.pulsar.client.admin.internal.SourcesImpl;
import org.apache.pulsar.client.admin.internal.TenantsImpl;
import org.apache.pulsar.client.admin.internal.TopicsImpl;
import org.apache.pulsar.client.admin.internal.WorkerImpl;
+import org.apache.pulsar.client.admin.internal.http.AsyncHttpConnector;
import org.apache.pulsar.client.admin.internal.http.AsyncHttpConnectorProvider;
import org.apache.pulsar.client.api.Authentication;
import org.apache.pulsar.client.api.AuthenticationFactory;
import org.apache.pulsar.client.api.PulsarClientException;
import org.apache.pulsar.client.impl.auth.AuthenticationDisabled;
import org.apache.pulsar.client.impl.conf.ClientConfigurationData;
-import org.asynchttpclient.AsyncHttpClient;
import org.glassfish.jersey.client.ClientConfig;
import org.glassfish.jersey.client.ClientProperties;
import org.glassfish.jersey.jackson.JacksonFeature;
@@ -86,7 +86,7 @@ public class PulsarAdmin implements Closeable {
private final ResourceQuotas resourceQuotas;
private final ClientConfigurationData clientConfigData;
private final Client client;
- private final AsyncHttpClient httpAsyncClient;
+ private final AsyncHttpConnector asyncHttpConnector;
private final String serviceUrl;
private final Lookup lookups;
private final Functions functions;
@@ -184,10 +184,10 @@ public class PulsarAdmin implements Closeable {
this.serviceUrl = serviceUrl;
root = client.target(serviceUrl);
- this.httpAsyncClient = asyncConnectorProvider.getConnector(
+ this.asyncHttpConnector = asyncConnectorProvider.getConnector(
Math.toIntExact(connectTimeoutUnit.toMillis(this.connectTimeout)),
Math.toIntExact(readTimeoutUnit.toMillis(this.readTimeout)),
- Math.toIntExact(requestTimeoutUnit.toMillis(this.requestTimeout))).getHttpClient();
+ Math.toIntExact(requestTimeoutUnit.toMillis(this.requestTimeout)));
long readTimeoutMs = readTimeoutUnit.toMillis(this.readTimeout);
this.clusters = new ClustersImpl(root, auth, readTimeoutMs);
@@ -201,9 +201,9 @@ public class PulsarAdmin implements Closeable {
this.nonPersistentTopics = new NonPersistentTopicsImpl(root, auth, readTimeoutMs);
this.resourceQuotas = new ResourceQuotasImpl(root, auth, readTimeoutMs);
this.lookups = new LookupImpl(root, auth, useTls, readTimeoutMs);
- this.functions = new FunctionsImpl(root, auth, httpAsyncClient, readTimeoutMs);
- this.sources = new SourcesImpl(root, auth, httpAsyncClient, readTimeoutMs);
- this.sinks = new SinksImpl(root, auth, httpAsyncClient, readTimeoutMs);
+ this.functions = new FunctionsImpl(root, auth, asyncHttpConnector.getHttpClient(), readTimeoutMs);
+ this.sources = new SourcesImpl(root, auth, asyncHttpConnector.getHttpClient(), readTimeoutMs);
+ this.sinks = new SinksImpl(root, auth, asyncHttpConnector.getHttpClient(), readTimeoutMs);
this.worker = new WorkerImpl(root, auth, readTimeoutMs);
this.schemas = new SchemasImpl(root, auth, readTimeoutMs);
this.bookies = new BookiesImpl(root, auth, readTimeoutMs);
@@ -433,10 +433,6 @@ public class PulsarAdmin implements Closeable {
}
client.close();
- try {
- httpAsyncClient.close();
- } catch (IOException e) {
- LOG.error("Failed to close http async client", e);
- }
+ asyncHttpConnector.close();
}
}
diff --git a/pulsar-client-admin/src/main/java/org/apache/pulsar/client/admin/internal/http/AsyncHttpConnector.java b/pulsar-client-admin/src/main/java/org/apache/pulsar/client/admin/internal/http/AsyncHttpConnector.java
index c0dc467..70373fb 100644
--- a/pulsar-client-admin/src/main/java/org/apache/pulsar/client/admin/internal/http/AsyncHttpConnector.java
+++ b/pulsar-client-admin/src/main/java/org/apache/pulsar/client/admin/internal/http/AsyncHttpConnector.java
@@ -310,6 +310,7 @@ public class AsyncHttpConnector implements Connector {
public void close() {
try {
httpClient.close();
+ delayer.shutdownNow();
} catch (IOException e) {
log.warn("Failed to close http client", e);
}
[pulsar] 03/03: [Doc] Add a note about --state-storage-service-url
in localrun command of Function
Posted by rx...@apache.org.
This is an automated email from the ASF dual-hosted git repository.
rxl pushed a commit to branch branch-2.6
in repository https://gitbox.apache.org/repos/asf/pulsar.git
commit b10585b8a302c52fd95a5bffb18138044040cdd7
Author: HuanliMeng <48...@users.noreply.github.com>
AuthorDate: Wed Jul 1 23:50:05 2020 +0800
[Doc] Add a note about --state-storage-service-url in localrun command of Function
Signed-off-by: xiaolong.ran <rx...@apache.org>
---
site2/docs/reference-pulsar-admin.md | 2 +-
site2/website/versioned_docs/version-2.3.0/reference-pulsar-admin.md | 3 +--
site2/website/versioned_docs/version-2.3.1/reference-pulsar-admin.md | 3 +--
site2/website/versioned_docs/version-2.3.2/reference-pulsar-admin.md | 2 +-
site2/website/versioned_docs/version-2.4.0/reference-pulsar-admin.md | 2 +-
site2/website/versioned_docs/version-2.4.1/reference-pulsar-admin.md | 2 +-
site2/website/versioned_docs/version-2.4.2/reference-pulsar-admin.md | 2 +-
site2/website/versioned_docs/version-2.5.0/reference-pulsar-admin.md | 2 +-
site2/website/versioned_docs/version-2.5.1/reference-pulsar-admin.md | 2 +-
site2/website/versioned_docs/version-2.5.2/reference-pulsar-admin.md | 2 +-
10 files changed, 10 insertions(+), 12 deletions(-)
diff --git a/site2/docs/reference-pulsar-admin.md b/site2/docs/reference-pulsar-admin.md
index 419b507..b37d84a 100644
--- a/site2/docs/reference-pulsar-admin.md
+++ b/site2/docs/reference-pulsar-admin.md
@@ -450,7 +450,7 @@ Options
|`--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||
-|`--state-storage-service-url`|The URL for the state storage service (by default Apache BookKeeper)||
+|`--state-storage-service-url`|The URL for the state storage service. By default, it it set to the service URL of the Apache BookKeeper. This service URL must be added manually when the Pulsar Function runs locally. ||
|`--tenant`|The function’s tenant||
|`--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 (supported for java fun only)||
|`--user-config`|User-defined config key/values||
diff --git a/site2/website/versioned_docs/version-2.3.0/reference-pulsar-admin.md b/site2/website/versioned_docs/version-2.3.0/reference-pulsar-admin.md
index 100af97..7b78821 100644
--- a/site2/website/versioned_docs/version-2.3.0/reference-pulsar-admin.md
+++ b/site2/website/versioned_docs/version-2.3.0/reference-pulsar-admin.md
@@ -425,8 +425,7 @@ Options
|`--schema-type`|Schema Type to be used for storing output messages||
|`--sliding-interval-count`|Number of messages after which the window ends||
|`--sliding-interval-duration-ms`|The time duration after which the window slides||
-|`--state-storage-service-url`|The service URL for the function’s state storage (if the function uses a storage system different from the Apache BookKeeper cluster used by Pulsar)||
-|`--subscription-type`|The subscription type used by the function when consuming messages on the input topic(s). Can be either SHARED or EXCLUSIVE|SHARED|
+|`--state-storage-service-url`|The service URL for the function’s state storage (if the function uses a storage system different from the Apache BookKeeper cluster used by Pulsar). This service URL must be added manually when the Pulsar Function runs locally.||
|`--tenant`|The function’s tenant||
|`--topics-pattern`|The topic pattern to consume from list of topics under a namespace that match the pattern||
|`--user-config`|A user-supplied config value, set as a key/value pair. You can set multiple user config values.||
diff --git a/site2/website/versioned_docs/version-2.3.1/reference-pulsar-admin.md b/site2/website/versioned_docs/version-2.3.1/reference-pulsar-admin.md
index 8fe1afd..9e82787 100644
--- a/site2/website/versioned_docs/version-2.3.1/reference-pulsar-admin.md
+++ b/site2/website/versioned_docs/version-2.3.1/reference-pulsar-admin.md
@@ -425,8 +425,7 @@ Options
|`--schema-type`|Schema Type to be used for storing output messages||
|`--sliding-interval-count`|Number of messages after which the window ends||
|`--sliding-interval-duration-ms`|The time duration after which the window slides||
-|`--state-storage-service-url`|The service URL for the function’s state storage (if the function uses a storage system different from the Apache BookKeeper cluster used by Pulsar)||
-|`--subscription-type`|The subscription type used by the function when consuming messages on the input topic(s). Can be either SHARED or EXCLUSIVE|SHARED|
+|`--state-storage-service-url`|The service URL for the function’s state storage (if the function uses a storage system different from the Apache BookKeeper cluster used by Pulsar). This service URL must be added manually when the Pulsar Function runs locally.||
|`--tenant`|The function’s tenant||
|`--topics-pattern`|The topic pattern to consume from list of topics under a namespace that match the pattern||
|`--user-config`|A user-supplied config value, set as a key/value pair. You can set multiple user config values.||
diff --git a/site2/website/versioned_docs/version-2.3.2/reference-pulsar-admin.md b/site2/website/versioned_docs/version-2.3.2/reference-pulsar-admin.md
index 50ac36c..6c2522a 100644
--- a/site2/website/versioned_docs/version-2.3.2/reference-pulsar-admin.md
+++ b/site2/website/versioned_docs/version-2.3.2/reference-pulsar-admin.md
@@ -430,7 +430,7 @@ Options
|`--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||
-|`--state-storage-service-url`|The URL for the state storage service (by default Apache BookKeeper)||
+|`--state-storage-service-url`|The URL for the state storage service. By default, it it set to the service URL of the Apache BookKeeper. This service URL must be added manually when the Pulsar Function runs locally.||
|`--tenant`|The function’s tenant||
|`--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 (supported for java fun only)||
|`--user-config`|User-defined config key/values||
diff --git a/site2/website/versioned_docs/version-2.4.0/reference-pulsar-admin.md b/site2/website/versioned_docs/version-2.4.0/reference-pulsar-admin.md
index 2e8fe15..c128519 100644
--- a/site2/website/versioned_docs/version-2.4.0/reference-pulsar-admin.md
+++ b/site2/website/versioned_docs/version-2.4.0/reference-pulsar-admin.md
@@ -430,7 +430,7 @@ Options
|`--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||
-|`--state-storage-service-url`|The URL for the state storage service (by default Apache BookKeeper)||
+|`--state-storage-service-url`|The URL for the state storage service. By default, it it set to the service URL of the Apache BookKeeper. This service URL must be added manually when the Pulsar Function runs locally.||
|`--tenant`|The function’s tenant||
|`--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 (supported for java fun only)||
|`--user-config`|User-defined config key/values||
diff --git a/site2/website/versioned_docs/version-2.4.1/reference-pulsar-admin.md b/site2/website/versioned_docs/version-2.4.1/reference-pulsar-admin.md
index 37a0099..1bbba00 100644
--- a/site2/website/versioned_docs/version-2.4.1/reference-pulsar-admin.md
+++ b/site2/website/versioned_docs/version-2.4.1/reference-pulsar-admin.md
@@ -434,7 +434,7 @@ Options
|`--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||
-|`--state-storage-service-url`|The URL for the state storage service (by default Apache BookKeeper)||
+|`--state-storage-service-url`|The URL for the state storage service. By default, it it set to the service URL of the Apache BookKeeper. This service URL must be added manually when the Pulsar Function runs locally.||
|`--tenant`|The function’s tenant||
|`--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 (supported for java fun only)||
|`--user-config`|User-defined config key/values||
diff --git a/site2/website/versioned_docs/version-2.4.2/reference-pulsar-admin.md b/site2/website/versioned_docs/version-2.4.2/reference-pulsar-admin.md
index 358d931..2b761dd 100644
--- a/site2/website/versioned_docs/version-2.4.2/reference-pulsar-admin.md
+++ b/site2/website/versioned_docs/version-2.4.2/reference-pulsar-admin.md
@@ -434,7 +434,7 @@ Options
|`--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||
-|`--state-storage-service-url`|The URL for the state storage service (by default Apache BookKeeper)||
+|`--state-storage-service-url`|The URL for the state storage service. By default, it it set to the service URL of the Apache BookKeeper. This service URL must be added manually when the Pulsar Function runs locally.||
|`--tenant`|The function’s tenant||
|`--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 (supported for java fun only)||
|`--user-config`|User-defined config key/values||
diff --git a/site2/website/versioned_docs/version-2.5.0/reference-pulsar-admin.md b/site2/website/versioned_docs/version-2.5.0/reference-pulsar-admin.md
index 422d8a5..d328503 100644
--- a/site2/website/versioned_docs/version-2.5.0/reference-pulsar-admin.md
+++ b/site2/website/versioned_docs/version-2.5.0/reference-pulsar-admin.md
@@ -451,7 +451,7 @@ Options
|`--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||
-|`--state-storage-service-url`|The URL for the state storage service (by default Apache BookKeeper)||
+|`--state-storage-service-url`|The URL for the state storage service. By default, it it set to the service URL of the Apache BookKeeper. This service URL must be added manually when the Pulsar Function runs locally.||
|`--tenant`|The function’s tenant||
|`--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 (supported for java fun only)||
|`--user-config`|User-defined config key/values||
diff --git a/site2/website/versioned_docs/version-2.5.1/reference-pulsar-admin.md b/site2/website/versioned_docs/version-2.5.1/reference-pulsar-admin.md
index 86e1b95..0c320ee 100644
--- a/site2/website/versioned_docs/version-2.5.1/reference-pulsar-admin.md
+++ b/site2/website/versioned_docs/version-2.5.1/reference-pulsar-admin.md
@@ -451,7 +451,7 @@ Options
|`--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||
-|`--state-storage-service-url`|The URL for the state storage service (by default Apache BookKeeper)||
+|`--state-storage-service-url`|The URL for the state storage service. By default, it it set to the service URL of the Apache BookKeeper. This service URL must be added manually when the Pulsar Function runs locally.||
|`--tenant`|The function’s tenant||
|`--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 (supported for java fun only)||
|`--user-config`|User-defined config key/values||
diff --git a/site2/website/versioned_docs/version-2.5.2/reference-pulsar-admin.md b/site2/website/versioned_docs/version-2.5.2/reference-pulsar-admin.md
index d9be03a..56b7fe9 100644
--- a/site2/website/versioned_docs/version-2.5.2/reference-pulsar-admin.md
+++ b/site2/website/versioned_docs/version-2.5.2/reference-pulsar-admin.md
@@ -451,7 +451,7 @@ Options
|`--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||
-|`--state-storage-service-url`|The URL for the state storage service (by default Apache BookKeeper)||
+|`--state-storage-service-url`|The URL for the state storage service. By default, it it set to the service URL of the Apache BookKeeper. This service URL must be added manually when the Pulsar Function runs locally.||
|`--tenant`|The function’s tenant||
|`--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 (supported for java fun only)||
|`--user-config`|User-defined config key/values||