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 63d4078 Fix conflict
new 828eb43 [C++] Reduce log level for ack-grouping tracker (#7373)
new b64e02a update for pr:Restore clusterDispatchRate policy for
compatibility (#7380)
new 0a2df5a [Issue 7347] Avoid the NPE occurs in method
`ManagedLedgerImpl.isOffloadedNeedsDelete` (#7389)
new 5b3889c Catch NPE and detect state doesn't move (#7401)
new 30a5221 Avoid NPEs at ledger creation when DNS failures happen (#7403)
new f62bc5b [Issue 7407] NPE with tombstones (#7408)
new eb343fd Fix batch ackset recycled multiple times. (#7409)
new ae246fe Decompression payload if needed in KeyShared subscription
(#7416)
new c86fe38 [client authentication] add authentication client with oauth2
support (#7420)
new cd19d3b [pulsar-doc] Add document for Pulasr SNI routing with ATS
(#7421)
new 2a65167 [pulsar-cli] fix update-cluster cli updates proxy-url (#7422)
new 1fd55cf [Doc]--Add labels to function statefulsets and services
(#7428)
new 754b864 Handle NotAllowed Exception at the client side. (#7430)
new f0363e3 shaded jclouds to avoid gson conflict
The 14 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:
.gitignore | 1 +
jclouds-shaded/pom.xml | 140 ++++++++++++++++++
.../bookkeeper/mledger/impl/ManagedCursorImpl.java | 4 +-
.../bookkeeper/mledger/impl/ManagedLedgerImpl.java | 53 ++++---
.../mledger/impl/OffloadLedgerDeleteTest.java | 62 +++++++-
.../bookkeeper/mledger/impl/OffloadPrefixTest.java | 2 +-
pom.xml | 13 +-
.../broker/service/AbstractBaseDispatcher.java | 47 ++----
.../broker/service/BrokerServiceException.java | 2 +
.../service/schema/BookkeeperSchemaStorage.java | 33 +++--
.../pulsar/compaction/TwoPhaseCompactor.java | 31 ++--
.../apache/pulsar/broker/admin/AdminApiTest2.java | 14 ++
.../client/api/KeySharedSubscriptionTest.java | 59 +++++++-
.../TokenAuthenticatedProducerConsumerTest.java | 143 ++++++++++++++++++
...kenOauth2AuthenticatedProducerConsumerTest.java | 160 +++++++++++++++++++++
.../client/impl/BatchMessageIndexAckTest.java | 31 ++++
.../authentication/token/credentials_file.json | 4 +
.../pulsar/client/api/PulsarClientException.java | 22 +++
pulsar-client-cpp/include/pulsar/Result.h | 1 +
pulsar-client-cpp/lib/AckGroupingTrackerEnabled.cc | 6 +-
pulsar-client-cpp/lib/ClientConnection.cc | 3 +
pulsar-client-cpp/lib/Result.cc | 3 +
.../org/apache/pulsar/admin/cli/CmdClusters.java | 10 +-
.../client/impl/BatchMessageKeyBasedContainer.java | 9 --
.../org/apache/pulsar/client/impl/ClientCnx.java | 2 +
.../client/impl/ConsumerStatsRecorderImpl.java | 2 +-
.../org/apache/pulsar/client/impl/MessageImpl.java | 10 +-
.../PersistentAcknowledgmentsGroupingTracker.java | 1 +
.../AuthenticationDataOAuth2.java} | 31 ++--
.../auth/oauth2/AuthenticationFactoryOAuth2.java} | 43 +++---
.../impl/auth/oauth2/AuthenticationOAuth2.java | 131 +++++++++++++++++
.../impl/auth/oauth2/ClientCredentialsFlow.java | 146 +++++++++++++++++++
.../pulsar/client/impl/auth/oauth2/Flow.java | 45 +++---
.../pulsar/client/impl/auth/oauth2/FlowBase.java | 80 +++++++++++
.../pulsar/client/impl/auth/oauth2/KeyFile.java | 66 +++++++++
.../pulsar/client/impl/auth/oauth2/Readme.md | 94 ++++++++++++
.../client/impl/auth/oauth2}/package-info.java | 2 +-
.../protocol/ClientCredentialsExchangeRequest.java | 23 +--
.../protocol/ClientCredentialsExchanger.java | 32 ++---
.../oauth2/protocol/DefaultMetadataResolver.java | 105 ++++++++++++++
.../client/impl/auth/oauth2/protocol/Metadata.java | 37 +++--
.../auth/oauth2/protocol/MetadataResolver.java | 17 +--
.../impl/auth/oauth2/protocol/TokenClient.java | 121 ++++++++++++++++
.../impl/auth/oauth2/protocol/TokenError.java | 24 ++--
.../oauth2/protocol/TokenExchangeException.java | 20 ++-
.../impl/auth/oauth2/protocol/TokenResult.java | 28 ++--
.../impl/auth/oauth2/protocol}/package-info.java | 2 +-
.../impl/auth/oauth2/AuthenticationOAuth2Test.java | 122 ++++++++++++++++
.../pulsar/client/impl/auth/oauth2/MockClock.java | 97 +++++++++++++
.../apache/pulsar/common/api/proto/PulsarApi.java | 3 +
.../pulsar/common/policies/data/ClusterData.java | 2 +
.../apache/pulsar/common/protocol/Commands.java | 11 +-
pulsar-common/src/main/proto/PulsarApi.proto | 1 +
site2/docs/admin-api-namespaces.md | 11 +-
site2/docs/assets/pulsar-sni-client.png | Bin 0 -> 232801 bytes
site2/docs/assets/pulsar-sni-geo.png | Bin 0 -> 201549 bytes
site2/docs/concepts-proxy-sni-routing.md | 122 ++++++++++++++++
site2/docs/functions-runtime.md | 3 +
.../version-2.4.0/functions-runtime.md | 3 +
.../version-2.4.1/functions-runtime.md | 3 +
.../version-2.4.2/functions-runtime.md | 3 +
.../version-2.5.0/functions-runtime.md | 3 +
.../version-2.5.1/functions-runtime.md | 3 +
.../version-2.5.2/functions-runtime.md | 3 +
tiered-storage/jcloud/pom.xml | 36 ++++-
.../impl/BlobStoreManagedLedgerOffloader.java | 6 +-
.../impl/BlobStoreManagedLedgerOffloaderTest.java | 2 +-
tiered-storage/pom.xml | 4 +
68 files changed, 2070 insertions(+), 283 deletions(-)
create mode 100644 jclouds-shaded/pom.xml
create mode 100644
pulsar-broker/src/test/java/org/apache/pulsar/client/api/TokenAuthenticatedProducerConsumerTest.java
create mode 100644
pulsar-broker/src/test/java/org/apache/pulsar/client/api/TokenOauth2AuthenticatedProducerConsumerTest.java
create mode 100644
pulsar-broker/src/test/resources/authentication/token/credentials_file.json
copy
pulsar-client/src/main/java/org/apache/pulsar/client/impl/auth/{AuthenticationDataToken.java
=> oauth2/AuthenticationDataOAuth2.java} (63%)
copy
pulsar-client/src/{test/java/org/apache/pulsar/client/impl/ClientInitializationTest.java
=>
main/java/org/apache/pulsar/client/impl/auth/oauth2/AuthenticationFactoryOAuth2.java}
(50%)
create mode 100644
pulsar-client/src/main/java/org/apache/pulsar/client/impl/auth/oauth2/AuthenticationOAuth2.java
create mode 100644
pulsar-client/src/main/java/org/apache/pulsar/client/impl/auth/oauth2/ClientCredentialsFlow.java
copy
pulsar-storm/src/main/java/org/apache/pulsar/storm/PulsarSpoutConsumer.java =>
pulsar-client/src/main/java/org/apache/pulsar/client/impl/auth/oauth2/Flow.java
(55%)
create mode 100644
pulsar-client/src/main/java/org/apache/pulsar/client/impl/auth/oauth2/FlowBase.java
create mode 100644
pulsar-client/src/main/java/org/apache/pulsar/client/impl/auth/oauth2/KeyFile.java
create mode 100644
pulsar-client/src/main/java/org/apache/pulsar/client/impl/auth/oauth2/Readme.md
copy {managed-ledger/src/main/java/org/apache/bookkeeper/mledger/util =>
pulsar-client/src/main/java/org/apache/pulsar/client/impl/auth/oauth2}/package-info.java
(94%)
copy
pulsar-common/src/main/java/org/apache/pulsar/common/protocol/schema/IsCompatibilityResponse.java
=>
pulsar-client/src/main/java/org/apache/pulsar/client/impl/auth/oauth2/protocol/ClientCredentialsExchangeRequest.java
(62%)
copy
pulsar-metadata/src/main/java/org/apache/pulsar/metadata/api/MetadataStoreException.java
=>
pulsar-client/src/main/java/org/apache/pulsar/client/impl/auth/oauth2/protocol/ClientCredentialsExchanger.java
(57%)
create mode 100644
pulsar-client/src/main/java/org/apache/pulsar/client/impl/auth/oauth2/protocol/DefaultMetadataResolver.java
copy
pulsar-common/src/main/java/org/apache/pulsar/common/functions/FunctionState.java
=>
pulsar-client/src/main/java/org/apache/pulsar/client/impl/auth/oauth2/protocol/Metadata.java
(58%)
copy
pulsar-broker-common/src/main/java/org/apache/pulsar/common/configuration/Category.java
=>
pulsar-client/src/main/java/org/apache/pulsar/client/impl/auth/oauth2/protocol/MetadataResolver.java
(77%)
create mode 100644
pulsar-client/src/main/java/org/apache/pulsar/client/impl/auth/oauth2/protocol/TokenClient.java
copy
pulsar-common/src/main/java/org/apache/pulsar/common/functions/FunctionState.java
=>
pulsar-client/src/main/java/org/apache/pulsar/client/impl/auth/oauth2/protocol/TokenError.java
(71%)
copy
pulsar-common/src/main/java/org/apache/pulsar/common/partition/PartitionedTopicMetadata.java
=>
pulsar-client/src/main/java/org/apache/pulsar/client/impl/auth/oauth2/protocol/TokenExchangeException.java
(66%)
copy
pulsar-common/src/main/java/org/apache/pulsar/common/functions/FunctionState.java
=>
pulsar-client/src/main/java/org/apache/pulsar/client/impl/auth/oauth2/protocol/TokenResult.java
(66%)
copy {managed-ledger/src/main/java/org/apache/bookkeeper/mledger/util =>
pulsar-client/src/main/java/org/apache/pulsar/client/impl/auth/oauth2/protocol}/package-info.java
(93%)
create mode 100644
pulsar-client/src/test/java/org/apache/pulsar/client/impl/auth/oauth2/AuthenticationOAuth2Test.java
create mode 100644
pulsar-client/src/test/java/org/apache/pulsar/client/impl/auth/oauth2/MockClock.java
create mode 100644 site2/docs/assets/pulsar-sni-client.png
create mode 100644 site2/docs/assets/pulsar-sni-geo.png
create mode 100644 site2/docs/concepts-proxy-sni-routing.md
