This is an automated email from the ASF dual-hosted git repository.
chenhang pushed a change to branch branch-2.8
in repository https://gitbox.apache.org/repos/asf/pulsar.git.
from bd5f75f KeyShared dispatcher on non-persistent topics was not
respecting consumer flow-control (#11692)
new fe7dc86 [Broker Interceptor] Fix Pulsar didn't respond error messages
when throw InterceptException (#11650)
new 9789e3a [Functions]Support protobuf schema for pulsar function
(#11709)
new 2fb2e59 [Broker] Remove subscription when closing Reader on
non-persistent topics (#11731)
new 1ed33f2 [Broker] Call .release() when discarding entry to prevent
direct memory leak (#11748)
new 7147d8a [Issue 11689][Client] Fixed block forever bug in
Consumer.batchReceive (#11691)
new 9c2888f Avoid duplicated disconnecting producer when after add entry
failed. (#11741)
new de813bf [pulsar-client] clean up MultiTopicsConsumerImpl reference on
consumer creation failure (#11754)
new 9287e87 [Broker] Handle NPE when full key range isn't covered with
active consumers (#11749)
new 4490258 Upgrade bk version to resolve the BouncyCatle issue (#11759)
new bce43cb [pulsar-client] remove consumer reference from PulsarClient
on subscription failure (#11758)
new 3456269 Fix the topic in fenced state and can not recover. (#11737)
The 11 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:
distribution/server/src/assemble/LICENSE.bin.txt | 55 ++++---
.../apache/bookkeeper/mledger/impl/OpAddEntry.java | 9 +-
pom.xml | 2 +-
.../org/apache/pulsar/broker/service/Producer.java | 9 +-
.../apache/pulsar/broker/service/ServerCnx.java | 2 +-
.../nonpersistent/NonPersistentSubscription.java | 9 +-
.../service/nonpersistent/NonPersistentTopic.java | 4 +-
.../PersistentDispatcherSingleActiveConsumer.java | 2 +
...istentStickyKeyDispatcherMultipleConsumers.java | 8 +-
.../broker/service/persistent/PersistentTopic.java | 12 +-
.../apache/pulsar/broker/web/ExceptionHandler.java | 57 +++++++
.../pulsar/broker/web/PreInterceptFilter.java | 8 +-
.../org/apache/pulsar/broker/web/WebService.java | 3 +-
.../pulsar/broker/admin/AdminApiSchemaTest.java | 4 +-
.../broker/intercept/InterceptFilterOutTest.java | 4 +-
.../pulsar/broker/service/PersistentTopicTest.java | 25 +++-
.../pulsar/broker/web/ExceptionHandlerTest.java | 63 ++++++++
.../org/apache/pulsar/client/impl/ReaderTest.java | 48 ++++++
.../pulsar/client/admin/internal/BaseResource.java | 2 +-
.../client/admin/internal/FunctionsImpl.java | 16 +-
.../pulsar/client/admin/internal/PackagesImpl.java | 2 +-
.../pulsar/client/admin/internal/SinksImpl.java | 10 +-
.../pulsar/client/admin/internal/SourcesImpl.java | 10 +-
.../pulsar/client/admin/internal/WorkerImpl.java | 10 +-
.../admin/internal/http/AsyncHttpConnector.java | 16 ++
.../apache/pulsar/client/impl/ConsumerBase.java | 165 ++++++++++++---------
.../apache/pulsar/client/impl/ConsumerImpl.java | 59 ++++----
.../client/impl/MultiTopicsConsumerImpl.java | 73 +++++----
.../pulsar/client/impl/UnAckedMessageTracker.java | 1 +
.../pulsar/client/impl/ZeroQueueConsumerImpl.java | 2 +-
.../pulsar/client/impl/ClientTestFixtures.java | 16 +-
.../pulsar/client/impl/ConsumerImplTest.java | 16 +-
.../client/impl/MultiTopicsConsumerImplTest.java | 52 +++++--
.../apache/pulsar/client/impl/ReaderImplTest.java | 41 ++---
pulsar-functions/runtime-all/pom.xml | 17 +++
.../functions/instance/JavaInstanceDepsTest.java | 3 +
pulsar-sql/presto-distribution/LICENSE | 24 +--
37 files changed, 591 insertions(+), 268 deletions(-)
create mode 100644
pulsar-broker/src/main/java/org/apache/pulsar/broker/web/ExceptionHandler.java
create mode 100644
pulsar-broker/src/test/java/org/apache/pulsar/broker/web/ExceptionHandlerTest.java
