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 1d59559 Use sendRequestWithId to add timeout to hasMessageAvailable
(#11600)
new 41ad624 [Broker] Fix set-publish-rate when using
preciseTopicPublishRateLimiterEnable=true (#10384)
new 598acec fix publish_time not set error when broker entry metadata
enable without AppendBrokerTimestampMetadataInterceptor (#11014)
new 79bbfce [Transaction] Fix delete sub then delete pending ack. (#11023)
new 8ce9e2d Fix MsgDropRate missing from NonPersistentTopics stats
output. (#11119)
new 705aae3 [broker] fix `GetTopicsOfNamespace` with binary lookup
service not check auth (#11172)
new 2439eda [Transaction] Fix transaction buffer client handle endTxn op
when topic or sub have been deleted. (#11304)
new 0a57e2c Fix Consumer listener does not respect receiver queue size
(#11455)
new be4f9a7 Pending ack set managed ledger config true (#11494)
new 349f5b9 Add metrics for writing or reading size of cursor (#11500)
new 353c72d Fix time based backlog quota. (#11509)
new 4befb41 [C++/Python] Fix bugs that were not exposed by broken C++ CI
before (#11557)
new 3ad5266 [Tests] Fix cpp build not failing when tests fail (#11575)
new 105fe87 Fix python doc generate (#11585)
new cf4bd92 Fix java.lang.NoSuchMethodError:
java.nio.ByteBuffer.position(I)Ljava/nio/ByteBuffer when enabling topic
metadata compression (#11594)
new 8a9d5b4 [Python Schema] Fix redefined Record or Enum in Python schema
(#11595)
new c9f6c9a Fix all threads will get stuck when deleting the namespace
(#11596)
new 3ee999e Fix null MessageId may be passed to its compareTo() method
(#11607)
new 33c9fb7 Fix: Cast exception occurs if function/source/sink type is
ByteBuffer (#11611)
new 4376f9b fix getPreviousPosition npe (#11621)
new 59cbd32 Avoid redundant calls for getting the offload policies from
the offloader (#11629)
The 20 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:
...er-broker-gp1.yaml => ci-unit-broker-jdk8.yaml} | 8 +-
build/run_unit_group.sh | 8 +
.../bookkeeper/mledger/ManagedCursorMXBean.java | 34 +-
.../bookkeeper/mledger/ManagedLedgerFactory.java | 11 +
.../bookkeeper/mledger/impl/ManagedCursorImpl.java | 5 +-
.../mledger/impl/ManagedCursorMXBeanImpl.java | 30 ++
.../mledger/impl/ManagedLedgerFactoryImpl.java | 5 +
.../bookkeeper/mledger/impl/ManagedLedgerImpl.java | 32 +-
.../apache/bookkeeper/mledger/impl/MetaStore.java | 12 +
.../bookkeeper/mledger/impl/MetaStoreImpl.java | 30 +-
.../bookkeeper/mledger/impl/ManagedLedgerTest.java | 40 +-
.../mledger/impl/OffloadLedgerDeleteTest.java | 19 +-
.../apache/pulsar/broker/admin/AdminResource.java | 6 +-
.../pulsar/broker/admin/impl/NamespacesBase.java | 3 +-
.../broker/admin/impl/PersistentTopicsBase.java | 48 +-
.../broker/admin/v2/NonPersistentTopics.java | 116 +++++
.../pulsar/broker/service/AbstractTopic.java | 2 +-
.../pulsar/broker/service/BacklogQuotaManager.java | 23 +-
.../broker/service/PrecisPublishLimiter.java | 113 +++--
.../pulsar/broker/service/PublishRateLimiter.java | 2 +-
.../broker/service/PublishRateLimiterDisable.java | 4 +
.../broker/service/PublishRateLimiterImpl.java | 5 +
.../apache/pulsar/broker/service/ServerCnx.java | 317 ++++++++-----
.../org/apache/pulsar/broker/service/Topic.java | 4 +-
.../service/nonpersistent/NonPersistentTopic.java | 11 +-
.../persistent/PersistentMessageExpiryMonitor.java | 8 +-
.../persistent/PersistentMessageFinder.java | 8 +-
.../broker/service/persistent/PersistentTopic.java | 141 +++---
.../service/persistent/SubscribeRateLimiter.java | 2 +-
.../broker/stats/metrics/ManagedCursorMetrics.java | 3 +
.../stats/prometheus/NamespaceStatsAggregator.java | 7 +-
.../pendingack/impl/MLPendingAckStoreProvider.java | 85 ++--
.../org/apache/pulsar/broker/ConfigHelper.java | 20 +-
.../apache/pulsar/broker/admin/AdminApiTest.java | 14 +-
.../apache/pulsar/broker/admin/AdminApiTest2.java | 20 +-
.../broker/admin/TopicPoliciesDisableTest.java | 4 +-
.../pulsar/broker/admin/TopicPoliciesTest.java | 230 +++++++++-
.../broker/service/BacklogQuotaManagerTest.java | 18 +-
.../service/ManagedLedgerCompressionTest.java | 2 +
.../pulsar/broker/service/PersistentTopicTest.java | 6 +
.../broker/service/PrecisPublishLimiterTest.java | 57 +++
.../pulsar/broker/service/ServerCnxTest.java | 13 +-
.../broker/stats/ManagedCursorMetricsTest.java | 63 +++
.../pulsar/broker/transaction/TransactionTest.java | 93 +++-
.../broker/transaction/TransactionTestBase.java | 6 +-
.../buffer/TransactionBufferClientTest.java | 216 +++++----
.../pendingack/PendingAckPersistentTest.java | 76 +++-
.../client/api/KeySharedSubscriptionTest.java | 6 +-
.../client/api/SimpleProducerConsumerTest.java | 95 +++-
.../impl/PatternTopicsConsumerImplAuthTest.java | 488 +++++++++++++++++++++
.../worker/PulsarFunctionLocalRunTest.java | 51 ++-
.../org/apache/pulsar/client/admin/Namespaces.java | 28 +-
.../org/apache/pulsar/client/admin/Topics.java | 19 +-
...ava => NonPersistentPartitionedTopicStats.java} | 12 +-
.../policies/data/PartitionedTopicStats.java | 4 +-
.../policies/data/impl/BacklogQuotaImpl.java | 5 +-
.../client/admin/internal/NamespacesImpl.java | 22 +-
.../pulsar/client/admin/internal/TopicsImpl.java | 104 +++--
pulsar-client-cpp/docker-tests.sh | 2 +-
pulsar-client-cpp/lib/ClientConnection.cc | 39 +-
pulsar-client-cpp/lib/ClientImpl.cc | 2 +-
pulsar-client-cpp/lib/ConnectionPool.cc | 2 +-
pulsar-client-cpp/lib/HTTPLookupService.cc | 1 +
.../python/pulsar/schema/definition.py | 43 +-
.../python/pulsar/schema/schema_avro.py | 2 +-
pulsar-client-cpp/python/pulsar_test.py | 34 +-
pulsar-client-cpp/python/schema_test.py | 58 ++-
pulsar-client-cpp/tests/BasicEndToEndTest.cc | 3 +
pulsar-client-cpp/tests/CustomLoggerTest.cc | 4 +-
.../pulsar/admin/cli/PulsarAdminToolTest.java | 69 ++-
.../org/apache/pulsar/admin/cli/CmdNamespaces.java | 11 +-
.../org/apache/pulsar/admin/cli/CmdTopics.java | 15 +-
.../apache/pulsar/client/impl/ConsumerBase.java | 31 +-
.../org/apache/pulsar/client/impl/MessageImpl.java | 43 +-
.../PersistentAcknowledgmentsGroupingTracker.java | 5 +-
.../apache/pulsar/client/impl/MessageImplTest.java | 17 +-
...=> NonPersistentPartitionedTopicStatsImpl.java} | 22 +-
.../data/stats/NonPersistentTopicStatsImpl.java | 113 ++++-
.../apache/pulsar/common/protocol/Commands.java | 5 +-
.../pulsar/common/util/ObjectMapperFactory.java | 3 +
.../org/apache/pulsar/common/util/RateLimiter.java | 29 +-
.../NonPersistentPartitionedTopicStatsTest.java | 61 +++
.../instance/stats/FunctionStatsManager.java | 14 +-
.../functions/instance/stats/SinkStatsManager.java | 4 +-
.../instance/stats/SourceStatsManager.java | 4 +-
.../pulsar/functions/source/TopicSchema.java | 6 +-
.../pulsar/sql/presto/PulsarSplitManager.java | 12 +-
site2/docs/cookbooks-retention-expiry.md | 12 +-
site2/docs/reference-metrics.md | 3 +
site2/docs/reference-pulsar-admin.md | 38 ++
90 files changed, 2778 insertions(+), 743 deletions(-)
copy .github/workflows/{ci-unit-broker-broker-gp1.yaml =>
ci-unit-broker-jdk8.yaml} (95%)
create mode 100644
pulsar-broker/src/test/java/org/apache/pulsar/broker/service/PrecisPublishLimiterTest.java
create mode 100644
pulsar-broker/src/test/java/org/apache/pulsar/client/impl/PatternTopicsConsumerImplAuthTest.java
copy
pulsar-client-admin-api/src/main/java/org/apache/pulsar/common/policies/data/{PartitionedTopicStats.java
=> NonPersistentPartitionedTopicStats.java} (76%)
copy
pulsar-common/src/main/java/org/apache/pulsar/common/policies/data/stats/{PartitionedTopicStatsImpl.java
=> NonPersistentPartitionedTopicStatsImpl.java} (72%)
create mode 100644
pulsar-common/src/test/java/org/apache/pulsar/common/policies/data/NonPersistentPartitionedTopicStatsTest.java
