* Update functions-worker.md

* Update functions-worker.md

* Update site2/docs/functions-worker.md
Co-authored-by: NJennifer Huang <47805623+Jennifer88huang@users.noreply.github.com>

Fixes #7676 

### Motivation

Currently, there is an error that gets schemaName by partitioned topic name.

### Modifications

Add partitioned check in method `topicName. getSchemaName()`.

Fixes #7719

### Motivation

Avoid ConcurrentModificationException of LocalBrokerData. The root cause is the `updateLocalBrokerData` method in the ModularLoadManagerImpl update the `lastStats` in the LocalBrokerData to a HashMap, it should be a concurrent map.

* Add window function context docs for repo
Signed-off-by: Nxiaolong.ran <rxl@apache.org>

* add sidebar for window function context
Signed-off-by: Nxiaolong.ran <rxl@apache.org>

### Motivation

Replay delayed messages in order.

### Verifying this change

A new unit test added.

* Added ability to specify producer config for functions and sources

* Fixed test

* Fix test

* Add generated function proto

* Add header

* Address comments
Co-authored-by: NSanjeev Kulkarni <sanjeevk@splunk.com>

* Added `zookeeper.snapshot.trust.empty=true` for ZK 3.5 upgrade

* Perform producer compression from IO threads
Co-authored-by: NSanjeev Kulkarni <sanjeevk@splunk.com>

* Extract config validation class into separate module

* fix tests

* adding example

* fixing
Co-authored-by: NJerry Peng <jerryp@splunk.com>

Co-authored-by: NJerry Peng <jerryp@splunk.com>

### Motivation
Some user may face the following `Temporary Redirect` issue when the request topic not owned by the current broker:
```
19:21:48.215 [pulsar-web-42-5] ERROR org.apache.pulsar.broker.admin.impl.PersistentTopicsBase - [admin] Failed to get list of subscriptions for persistent://default_tenant/default_namespace/default_topic-partition-0
javax.ws.rs.WebApplicationException: HTTP 307 Temporary Redirect
	at org.apache.pulsar.broker.web.PulsarWebResource.validateTopicOwnership(PulsarWebResource.java:599)
	at org.apache.pulsar.broker.admin.impl.PersistentTopicsBase.validateReadOperationOnTopic(PersistentTopicsBase.java:245) 
	at org.apache.pulsar.broker.admin.impl.PersistentTopicsBase.internalGetSubscriptionsForNonPartitionedTopic(PersistentTopicsBase.java:874) 
	at org.apache.pulsar.broker.admin.impl.PersistentTopicsBase.internalGetSubscriptions(PersistentTopicsBase.java:825) 
	at org.apache.pulsar.broker.admin.v2.PersistentTopics.getSubscriptions(PersistentTopics.java:461)

09:41:45.485 [pulsar-web-42-7] WARN  org.apache.pulsar.broker.admin.impl.PersistentTopicsBase - [admin] [persistent://public/default/test-partition-1] Failed to create subscription consumer-test at message id -1:-1:-1
javax.ws.rs.WebApplicationException: HTTP 307 Temporary Redirect
        at org.apache.pulsar.broker.web.PulsarWebResource.validateTopicOwnership(PulsarWebResource.java:599)
        at org.apache.pulsar.broker.admin.impl.PersistentTopicsBase.validateAdminAccessForSubscriber(PersistentTopicsBase.java:283)
        at org.apache.pulsar.broker.admin.impl.PersistentTopicsBase.internalCreateSubscriptionForNonPartitionedTopic(PersistentTopicsBase.java:1752)
        at org.apache.pulsar.broker.admin.impl.PersistentTopicsBase.internalCreateSubscription(PersistentTopicsBase.java:1673)
        at org.apache.pulsar.broker.admin.v2.PersistentTopics.createSubscription(PersistentTopics.java:816)
```
 As discussed in https://github.com/apache/pulsar/issues/7189, it is better to use debug level when this happens.

### Modifications

Change some `WebApplicationException` log level from error/warn to debug in `PersistentTopicsBase`.

### Motivation
 Currently, pulsar admin cli tool request timeout is 300 seconds, this pr is to make it configurable.

### Modifications
add option `request-timeout` to config pulsar admin cli tool request timeout, default is 300 seconds.
add unit test.

Fixes #7619

Motivation

When using nondurable consumer to consumer message and specify the initial position
from earliest, the consumer can not start consume from the earliest message.

* [pulsar-client] Remove UUID generation on sending message

* fix prod name

### Motivation
Support set backlog quota on topic level.
Based on the system topic function, refer to @codelipenghui  topic-level backlog quota based on zk implementation

###Modifications
Support get-backlog-quotas on topic level.
Support set-backlog-quota on topic level.
Support remove-backlog-quota on topic level.

Co-authored-by: NSanjeev Kulkarni <sanjeevk@splunk.com>

# Fixes #7693

Motivation
When trying to chase down a bug in my custom AuthenticationProvider I found that when attempting to consume a topic that I wasn't authorized on would fail to produce an unauthorized response while using the pulsar-client. I noticed that the canConsumeAsync within AuthorizationService canLookUpAsync doesn't pass along the AuthenticationDataSource when it should. My code relied on that to be passed down each time and thus my methods would never return.

# Modifications
I've added the AuthenticationDataSource to the canConsumeAsync method.

### Motivation

I was doing the kubernetes getting started tutorial, and got stuck when trying to connect to the pulsar-mini-proxy service. I realized I needed to run `minikube service pulsar-mini-proxy -n pulsar` in order to expose the service ports outside of minikube.

Environment: OSX Catalina 10.15.3 with minikube v1.12.1 using kubernetes 1.18.3 with docker driver

### Modifications

documentation update for kubernetes getting started tutorial
Co-authored-by: NHuanliMeng <48120384+Huanli-Meng@users.noreply.github.com>
Co-authored-by: NKristi Tsukida <ktsukida@quantcast.com>
Co-authored-by: NHuanliMeng <48120384+Huanli-Meng@users.noreply.github.com>

### Motivation

Fix deduplication cursor does not delete after disabling message deduplication. The issue occurs when enabling the message deduplication at the broker.conf and then disable it and restart the broker. The dedup cursor will not be deleted.

Co-authored-by: NJerry Peng <jerryp@splunk.com>

Co-authored-by: NSanjeev Kulkarni <sanjeevk@splunk.com>

### Motivation

kubectl 1.18.6 warns that not using the double dashes is deprecated. Adding the double dashes to the kubectl exec commands in the docs will remove this warning and future-proof the commands if kubectl drops support for running a command without the double dashes.

### Modifications

Documentation update

* Added ability to specify runtime for localrunner

* Address feedback
Co-authored-by: NSanjeev Kulkarni <sanjeevk@splunk.com>

Co-authored-by: NJerry Peng <jerryp@splunk.com>

### Motivation

Fix backward compatibility issues with batch index acknowledgment.

### Modifications

Disable batch index acknowledgment by default at the consumer side.

### Motivation

Add support to read credentials from file, make it align with java client. 

### Modifications

- Add support to read credentials from file, make it align with java client. 
- add a test for it.
Co-authored-by: Nxiaolong.ran <rxl@apache.org>

* Kevin Wilson changes to fix segment crashes in pulsar

* after merge with master, change following comments: ptr, unnecessary change

* add lock to avoid concurrent access

* Remove comments
Co-authored-by: NIsaiah Rairdon <isaiah.rairdon@microfocus.com>
Co-authored-by: NJia Zhai <zhaijia@apache.org>
Co-authored-by: NSijie Guo <sijie@apache.org>
Co-authored-by: Nxiaolong.ran <rxl@apache.org>

Fixes issue #7315
Co-authored-by: Nxiaolong.ran <rxl@apache.org>

* [doc] Add pulsar-client-go oauth2 authentication document
---

*Motivation*

Add pulsar-client-go oauth2 authentication usage document.

* Address comments

* Fix wrong required properties for HDFS2 sink

* Fix description of filenamePrefix

### Modifications

Correct `BrokerServiceUrlTls` when `tls` is not enabled.

### Motivation

Currently, CLI tools `pulsar-client` and `pulsar-perf` cann't specify required listener name when using `advertisedListeners`.

### Modifications

Add option `--listener-name` for `pulsar-client` and `pulsar-perf`.

### Motivation

Support configuring DeleteInactiveTopic setting in namespace policy

### Modifications

Only the two parameters `brokerDeleteInactiveTopicsMode` and `brokerDeleteInactiveTopicsMaxInactiveDurationSeconds` support namespace policy. The parameters are changed to Map structure, the key is the namespace, and the value is the parameter value.
Such as: namespace1=delete_when_no_subscriptions, namespace2=delete_when_no_subscriptions.

In addition, there is a key name called `default`. If it is set, other namespaces that do not specify parameters will use this parameter.
Such as: default=delete_when_no_subscriptions

### Motivation

CompletableFuture<Messages<T>> from Consumer.batchReceiveAsync() not completed exceptionnally when closing Consumer.

### Modifications

pendingBatchReceives was not cleaned up when the connection was closed, so I added pendingBatchReceives cleanup.

### Modifications

Add state check when connection opened of the consumer. If the consumer state is closing or closed, we don’t need to send the subscribe command