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 375fc00 fix typo
new fcea0f4 Fixes #7512 handle exception when policy is updated. (#7514)
new 460abac Ensure the create subscription can be completed when the
operation timeout happens (#7522)
new af654c4 Fix: function BC issue introduced in 2.6 (#7528)
new 602735e [Issue 7489] Remove timestamp from metrics (#7539)
new 56ea8a8 [PROTOBUF] Fix protobuf generation on handling repeated long
number … (#7540)
new df3cd42 Add more logging to the auth operations on failure (#7567)
new bcb90d2 [CPP] Fix segment crashes that caused by race condition of
timer in cpp client (#7572)
new 7df08ca Improve security setting of Pulsar Functions (#7578)
new 56a0d69 Use Consume/Produce/Lookup interfaces for specific operations
in allowTopicOperation (#7587)
new f58aea8 [C++] Fix multitopic consumer segfault on connect error
(#7588)
new ad6edd5 Fix race condition on close consumer while reconnect to
broker. (#7589)
new 45d2c8f fix validation never return false (#7593)
new b246da9 fix the command for starting bookies in the foreground (#7596)
new d4a1ca5 Support configuring DeleteInactiveTopic setting in namespace
policy (#7598)
new 8268665 [oauth2 cpp] add support to read credentials from file (#7606)
new 0825f86 Make OAuth2 auth plugin to use AsyncHttpClient (#7615)
new 53ee16d fix NPE when using advertisedListeners (#7620)
new 180e5f2 fix batchReceiveAsync not completed exceptionally when
closing Consumer (#7661)
new 12cca8a Fix backward compatibility issues with batch index
acknowledgment. (#7655)
new 304924c fix:apache#7669 stats recorder time unit error (#7670)
new 0be16ea Fix batch index filter issue in Consumer. (#7654)
new 50493d0 [docs] Fix wrong required properties for HDFS2 sink (#7643)
new 85c5979 [pulsar-perf] Supports `tlsAllowInsecureConnection` in
pulsar-perf produce/consume/read. (#7300)
new 1842f7c Support to set listener name for client cli (#7621)
new a1f56e3 [doc] add cpp client document for oauth2 authentication
The 25 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:
.github/workflows/ci-go-functions-style.yaml | 8 +-
.github/workflows/ci-go-functions-test.yaml | 6 +-
pom.xml | 2 +
.../authorization/AuthorizationProvider.java | 29 +-
.../validator/MultipleListenerValidator.java | 8 +-
.../pulsar/broker/admin/impl/NamespacesBase.java | 48 +-
.../apache/pulsar/broker/admin/v2/Namespaces.java | 38 +-
.../pulsar/broker/namespace/NamespaceService.java | 6 +-
.../pulsar/broker/service/AbstractTopic.java | 28 +-
.../pulsar/broker/service/BrokerService.java | 8 +-
.../org/apache/pulsar/broker/service/Topic.java | 2 +-
.../service/nonpersistent/NonPersistentTopic.java | 23 +-
.../broker/service/persistent/PersistentTopic.java | 23 +-
.../broker/service/persistent/SystemTopic.java | 2 +-
.../pulsar/broker/service/BrokerTestBase.java | 7 +-
.../broker/service/InactiveTopicDeleteTest.java | 165 ++++++
.../service/PersistentTopicConcurrentTest.java | 4 +-
.../client/api/SimpleProducerConsumerTest.java | 74 +++
.../client/impl/BatchMessageIndexAckTest.java | 26 +-
.../pulsar/client/impl/TopicsConsumerImplTest.java | 57 ++
...entials_file.json => cpp_credentials_file.json} | 0
.../org/apache/pulsar/client/admin/Namespaces.java | 48 ++
.../client/admin/internal/NamespacesImpl.java | 81 +++
.../apache/pulsar/client/api/ConsumerBuilder.java | 6 +
pulsar-client-cpp/lib/ClientConnection.cc | 40 +-
pulsar-client-cpp/lib/MultiTopicsConsumerImpl.cc | 13 +-
pulsar-client-cpp/lib/auth/AuthOauth2.cc | 45 +-
pulsar-client-cpp/lib/auth/AuthOauth2.h | 2 +
pulsar-client-cpp/tests/AuthPluginTest.cc | 19 +
pulsar-client-cpp/tests/BasicEndToEndTest.cc | 13 +
.../pulsar/admin/cli/PulsarAdminToolTest.java | 14 +-
.../org/apache/pulsar/admin/cli/CmdNamespaces.java | 73 ++-
.../apache/pulsar/client/cli/PulsarClientTool.java | 6 +
.../apache/pulsar/client/impl/ConsumerBase.java | 26 +-
.../pulsar/client/impl/ConsumerBuilderImpl.java | 6 +
.../apache/pulsar/client/impl/ConsumerImpl.java | 60 +-
.../client/impl/MultiTopicsConsumerImpl.java | 25 +-
.../client/impl/ProducerStatsRecorderImpl.java | 8 +-
.../impl/auth/oauth2/AuthenticationOAuth2.java | 6 +-
.../impl/auth/oauth2/ClientCredentialsFlow.java | 5 +-
.../pulsar/client/impl/auth/oauth2/Flow.java | 4 +-
.../protocol/ClientCredentialsExchanger.java | 7 +-
.../impl/auth/oauth2/protocol/TokenClient.java | 143 +++--
.../impl/conf/ConsumerConfigurationData.java | 2 +
.../apache/pulsar/common/api/proto/PulsarApi.java | 18 +
...eryPolicies.java => InactiveTopicPolicies.java} | 13 +-
.../pulsar/common/policies/data/Policies.java | 6 +-
.../pulsar/common/policies/data/PolicyName.java | 1 +
.../util/protobuf/ByteBufCodedInputStream.java | 30 +
.../apache/pulsar/common/api/proto/TestApi.java | 641 +++++++++++++++++++++
.../common/protocol/RepeatedLongNonPackedTest.java | 65 +++
.../common/protocol/RepeatedLongPackedTest.java | 65 +++
.../src/test/proto/TestApi.proto | 23 +-
pulsar-function-go/pf/stats.go | 15 +-
.../instance/stats/ComponentStatsManager.java | 3 +-
.../instance/stats/FunctionStatsManager.java | 11 +-
.../functions/instance/stats/SinkStatsManager.java | 11 +-
.../instance/stats/SourceStatsManager.java | 11 +-
.../instance/src/main/python/function_stats.py | 16 +-
.../functions/worker/FunctionWorkerStarter.java | 7 +-
.../pulsar/functions/worker/WorkerUtils.java | 14 +-
.../pulsar/testclient/PerformanceConsumer.java | 22 +-
.../pulsar/testclient/PerformanceProducer.java | 25 +-
.../pulsar/testclient/PerformanceReader.java | 20 +
site2/docs/client-libraries-java.md | 4 +-
site2/docs/deploy-bare-metal.md | 2 +-
site2/docs/functions-worker.md | 20 +-
site2/docs/io-hdfs2-sink.md | 6 +-
site2/docs/reference-cli-tools.md | 8 +-
.../docs/{security-oauth.md => security-oauth2.md} | 30 +-
site2/website/sidebars.json | 2 +-
...e2_3.java => PulsarStandaloneTestSuite2_5.java} | 4 +-
.../backwardscompatibility/SmokeTest2_2.java | 4 +
.../backwardscompatibility/SmokeTest2_3.java | 4 +
.../backwardscompatibility/SmokeTest2_4.java | 4 +
.../{SmokeTest2_3.java => SmokeTest2_5.java} | 6 +-
.../integration/containers/PulsarContainer.java | 1 +
.../integration/topologies/PulsarTestBase.java | 46 ++
78 files changed, 2072 insertions(+), 302 deletions(-)
copy
pulsar-broker/src/test/resources/authentication/token/{credentials_file.json =>
cpp_credentials_file.json} (100%)
copy
pulsar-common/src/main/java/org/apache/pulsar/common/policies/data/{DelayedDeliveryPolicies.java
=> InactiveTopicPolicies.java} (81%)
create mode 100644
pulsar-common/src/test/java/org/apache/pulsar/common/api/proto/TestApi.java
create mode 100644
pulsar-common/src/test/java/org/apache/pulsar/common/protocol/RepeatedLongNonPackedTest.java
create mode 100644
pulsar-common/src/test/java/org/apache/pulsar/common/protocol/RepeatedLongPackedTest.java
copy
pulsar-broker-common/src/main/java/org/apache/pulsar/common/configuration/Category.java
=> pulsar-common/src/test/proto/TestApi.proto (68%)
rename site2/docs/{security-oauth.md => security-oauth2.md} (81%)
copy
tests/integration/src/test/java/org/apache/pulsar/tests/integration/backwardscompatibility/{PulsarStandaloneTestSuite2_3.java
=> PulsarStandaloneTestSuite2_5.java} (91%)
copy
tests/integration/src/test/java/org/apache/pulsar/tests/integration/backwardscompatibility/{SmokeTest2_3.java
=> SmokeTest2_5.java} (83%)
