This is an automated email from the ASF dual-hosted git repository.
guangning pushed a change to branch branch-2.5
in repository https://gitbox.apache.org/repos/asf/pulsar.git.
from deafc24 client: make SubscriptionMode a member of
ConsumerConfigurationData (#6337)
new 92b0c75 Fixed static linking on C++ lib on MacOS (#5581)
new c8eb719 Expose bookkeeper expose explicit lac in broker.conf (#5822)
new a3615c2 [build] Skip javadoc task for pulsar-client-kafka-compact
modules (#5836)
new eaa8feb add_backlogSize_in_topicStat (#5914)
new 3aa47bc Fix negative un-ack messages in consumer stats (#5929)
new eaaf17b Avoid using same OpAddEntry between different ledger handles
(#5942)
new 39e33c7 Prevent creation of regular topic with the same name as
existing partitioned topic (#5943)
new c6b7665 [pulsar-broker] Clean up closed producer to avoid
publish-time for producer (#5988)
new 1b151fe Expose lastConsumedTimestamp and lastAckedTimestamp to
consumer stats (#6051)
new a8fc1c5 Fix issue 5505 (#6060)
new 43816e01 make acker transient (#6064)
new 99952d9 Fix zero queue consumer message redelivery (#6076)
new 18d8adb Fix message redelivery for zero queue consumer while using
async api to receive messages (#6090)
new b70b15c [Functions] The argument and description for dead letter
topic is wrong (#6101)
new 4624d16 [Websocket] Websocket doesn't set the correct cluster data
(#6102)
new caf82b5 Fix zeroQueueConsumer using listener (#6106)
new 9449053 [Broker]Reset cursor with a non-exists position (#6120)
new 15f876a Add timeout to search for web service URLs to avoid web
threads getting stuck (#6124)
new 3c4ca9b Output resource usage rate to log on broker (#6152)
new bd1bcb7 add missing check to dashboard-ingress (helm chart) (#6160)
new eebefbd Restore clusterDispatchRate policy for compatibility (#6176)
new 5df30c0 Create managed ledger path on local zookeeper when create
partitions (#6189)
new 74971cd Corrected the method name for source implementation (#6190)
new b9d0ac7 Fix get schema version in HttpLookupService. (#6193)
new 4b95701 Pin the netty-transport-native-epoll to avoid conflicts
(#6194)
new c74b092 [ISSUE-6131]: Ensure JVM memory and GC options are set for
bookie (#6201)
new 354a059 Fix bug that backlog message that has not yet expired could
be deleted due to TTL (#6211)
new b098b18 Use fully qualified hostname as default to advertise brokers
(#6235)
new 4d8c0f2 [Issue 6173][compaction] Fix log compaction for flow
control/empty topic/last deletion (#6237)
new c92a86f Fix deploy of WindowFunctions (#6246)
new 16fff18 [C++] Fixed memory corruption on ExecutorService destructor
(#6270)
new d00b09a [C++] Fixed handling of canceled timer events on
NegativeAcksTracker (#6272)
new 28cb139 Fix bug that tenants whose allowed clusters include global
cannot be created/updated (#6275)
new 765aa02 [Issue 4070][pulsar-client-cpp] Fix for possible deadlock
when closing Pulsar client (#6277)
new 941b978 Fixed casting in ZooKeeperCache.getDataIfPresent() (#6313)
new 26b34d4 Should flush the last potential duplicated since can't
combine potential duplicated messages and non-duplicated messages into a batch.
(#6326)
new 18da91621 Upgrade ZooKeeper to 3.5.7 (#6329)
new 968dad2 [pulsar-broker] close managed-ledgers before giving up bundle
ownership to avoid bad zk-version (#5599)
new a8d11f1 [Issue 5904]Support `unload` all partitions of a partitioned
topic (#6187)
new e0e1569 Avoid get partition metadata while the topic name is a
partition name. (#6339)
new 702e5be explicit statement env 'BOOKIE_MEM' and 'BOOKIE_GC' for
values-mini.yaml (#6340)
new dabdd84 Fix java doc for key shared policy. (#6341)
new 4893835 remove future.join() from PulsarSinkEffectivelyOnceProcessor
(#6361)
new 965c7b7 [Issue 6355][HELM] autorecovery - could not find or load main
class (#6373)
new 1493d16 [Pulsar-Client] Stop shade snappy-java in
pulsar-client-shaded (#6375)
new c9035ea Fix unit test (#6006)
new 2b5cc0d Remove problematic semicolon from conf (#6303)
The 47 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:
conf/bkenv.sh | 2 +-
conf/broker.conf | 4 +
conf/standalone.conf | 4 +
.../pulsar/templates/bookkeeper-statefulset.yaml | 1 +
.../helm/pulsar/templates/dashboard-ingress.yaml | 2 +
deployment/kubernetes/helm/pulsar/values-mini.yaml | 5 +-
deployment/kubernetes/helm/pulsar/values.yaml | 5 +-
distribution/server/src/assemble/LICENSE.bin.txt | 5 +-
.../bookkeeper/mledger/impl/ManagedCursorImpl.java | 21 +-
.../bookkeeper/mledger/impl/ManagedLedgerImpl.java | 20 +-
.../apache/bookkeeper/mledger/impl/OpAddEntry.java | 49 +-
.../bookkeeper/mledger/impl/OpFindNewest.java | 5 +-
.../bookkeeper/mledger/impl/ManagedCursorTest.java | 77 +-
.../bookkeeper/mledger/impl/ManagedLedgerTest.java | 38 +
pom.xml | 16 +-
.../apache/pulsar/broker/ServiceConfiguration.java | 3 +
.../pulsar/broker/ServiceConfigurationUtils.java | 3 +-
pulsar-broker-shaded/pom.xml | 5 -
.../pulsar/broker/BookKeeperClientFactoryImpl.java | 1 +
.../org/apache/pulsar/broker/PulsarService.java | 10 +-
.../apache/pulsar/broker/admin/AdminResource.java | 37 +-
.../pulsar/broker/admin/impl/ClustersBase.java | 5 +-
.../pulsar/broker/admin/impl/NamespacesBase.java | 6 +
.../broker/admin/impl/PersistentTopicsBase.java | 936 ++++++++++++---------
.../pulsar/broker/admin/impl/TenantsBase.java | 6 +-
.../broker/admin/v1/NonPersistentTopics.java | 18 +-
.../pulsar/broker/admin/v1/PersistentTopics.java | 7 +-
.../broker/admin/v2/NonPersistentTopics.java | 13 +-
.../pulsar/broker/admin/v2/PersistentTopics.java | 11 +-
.../broker/loadbalance/impl/OverloadShedder.java | 8 +-
.../pulsar/broker/namespace/NamespaceService.java | 13 +-
.../pulsar/broker/namespace/OwnedBundle.java | 8 +-
.../pulsar/broker/service/BrokerService.java | 5 +-
.../org/apache/pulsar/broker/service/Consumer.java | 9 +-
.../apache/pulsar/broker/service/ServerCnx.java | 5 +-
.../org/apache/pulsar/broker/service/Topic.java | 2 +-
.../service/nonpersistent/NonPersistentTopic.java | 59 +-
.../service/persistent/DispatchRateLimiter.java | 8 +
.../service/persistent/PersistentSubscription.java | 5 +
.../broker/service/persistent/PersistentTopic.java | 19 +-
.../pulsar/broker/web/PulsarWebResource.java | 9 +
.../org/apache/pulsar/client/api/RawReader.java | 7 +
.../apache/pulsar/client/impl/RawReaderImpl.java | 18 +-
.../pulsar/compaction/TwoPhaseCompactor.java | 69 +-
.../org/apache/pulsar/PulsarBrokerStarterTest.java | 2 +
.../broker/BookKeeperClientFactoryImplTest.java | 9 +
.../apache/pulsar/broker/admin/AdminApiTest.java | 23 +
.../apache/pulsar/broker/admin/AdminApiTest2.java | 120 ++-
.../pulsar/broker/admin/PersistentTopicsTest.java | 44 +-
.../pulsar/broker/admin/v1/V1_AdminApiTest2.java | 3 +-
.../loadbalance/impl/OverloadShedderTest.java | 14 +
.../broker/namespace/NamespaceServiceTest.java | 4 +-
.../broker/namespace/OwnershipCacheTest.java | 4 +-
.../pulsar/broker/service/BrokerServiceTest.java | 49 ++
.../service/PersistentMessageFinderTest.java | 2 +-
.../pulsar/broker/service/ServerCnxTest.java | 53 +-
.../pulsar/broker/stats/ConsumerStatsTest.java | 106 +++
.../pulsar/client/api/ClientDeduplicationTest.java | 12 +-
.../client/api/MessageDispatchThrottlingTest.java | 83 +-
.../apache/pulsar/client/api/SimpleSchemaTest.java | 33 +
.../apache/pulsar/client/api/TopicReaderTest.java | 2 +-
.../apache/pulsar/client/impl/RawReaderTest.java | 36 +-
.../pulsar/client/impl/ZeroQueueSizeTest.java | 112 +++
.../apache/pulsar/compaction/CompactionTest.java | 22 +-
.../apache/pulsar/compaction/CompactorTest.java | 2 +-
pulsar-client-all/pom.xml | 5 -
.../apache/pulsar/client/api/ConsumerBuilder.java | 2 +-
pulsar-client-cpp/CMakeLists.txt | 37 +-
pulsar-client-cpp/lib/ClientConnection.cc | 6 +-
pulsar-client-cpp/lib/ExecutorService.cc | 36 +-
pulsar-client-cpp/lib/ExecutorService.h | 6 +-
pulsar-client-cpp/lib/NegativeAcksTracker.cc | 6 +-
pulsar-client-cpp/python/CMakeLists.txt | 3 +-
pulsar-client-kafka-compat/pom.xml | 12 +
.../pulsar-client-kafka-shaded/pom.xml | 19 +-
.../pulsar-client-kafka-shaded_0_8/pom.xml | 23 +-
.../pulsar-client-kafka-shaded_0_9/pom.xml | 25 +-
pulsar-client-shaded/pom.xml | 5 -
.../apache/pulsar/admin/cli/CmdFunctionsTest.java | 4 +
.../org/apache/pulsar/admin/cli/CmdFunctions.java | 4 +-
.../client/impl/BatchMessageContainerImpl.java | 3 +-
.../pulsar/client/impl/BatchMessageIdImpl.java | 2 +-
.../apache/pulsar/client/impl/ConsumerImpl.java | 3 +-
.../pulsar/client/impl/HttpLookupService.java | 7 +-
.../apache/pulsar/client/impl/ProducerImpl.java | 24 +-
.../pulsar/client/impl/ZeroQueueConsumerImpl.java | 10 +-
pulsar-common/pom.xml | 2 +
.../pulsar/common/policies/data/ConsumerStats.java | 3 +
.../pulsar/common/policies/data/Policies.java | 6 +-
.../common/policies/data/SubscriptionStats.java | 9 +
.../pulsar/common/policies/data/TopicStats.java | 14 +-
.../data/loadbalancer/LocalBrokerData.java | 7 +
.../apache/pulsar/functions/sink/PulsarSink.java | 1 -
.../functions/utils/FunctionConfigUtils.java | 3 +-
pulsar-sql/presto-distribution/LICENSE | 8 +-
.../apache/pulsar/websocket/WebSocketService.java | 2 +
.../apache/pulsar/zookeeper/ZooKeeperCache.java | 8 +-
.../pulsar/zookeeper/ZookeeperCacheTest.java | 5 +-
site2/docs/admin-api-persistent-topics.md | 12 +
site2/docs/io-develop.md | 20 +-
100 files changed, 1887 insertions(+), 749 deletions(-)
create mode 100644
pulsar-broker/src/test/java/org/apache/pulsar/broker/stats/ConsumerStatsTest.java
