This is an automated email from the ASF dual-hosted git repository.
lhotari pushed a change to branch branch-4.0
in repository https://gitbox.apache.org/repos/asf/pulsar.git
from d4f02691fa7 [fix][test] Fix flaky
NonPersistentTopicTest.testProducerRateLimit (#24951)
new 62ccca238a8 [fix][sec] Update Hbase version to 2.6.3-hadoop3 and
exclude Avro from hbase-client to remediate CVEs (#24953)
new e786cc2a5b0 [fix][broker] AvgShedder comparison error (#24954)
new 3f00a00d551 [cleanup][broker] Remove unused configuration
maxMessageSizeCheckIntervalInSeconds (#24958)
new 6aaf2330dc4 [improve][fn] Use PulsarByteBufAllocator.DEFAULT instead
of ByteBufAllocator.DEFAULT (#24952)
new 66b7f7c3b0c [fix][test] Fix invalid test
NonPersistentTopicTest.testProducerRateLimit (#24957)
new 421d64679dd [fix][test] Fix flaky
KeySharedSubscriptionBrokerCacheTest.testReplayQueueReadsGettingCached (#24955)
new 85e8b5d6734 [fix][broker]Transactional messages can never be sent
successfully if concurrently taking transaction buffer snapshot (#24945)
The 7 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/broker.conf | 4 -
conf/standalone.conf | 4 -
deployment/terraform-ansible/templates/broker.conf | 4 -
pom.xml | 2 +-
.../pulsar/broker/loadbalance/impl/AvgShedder.java | 3 +-
.../buffer/impl/TopicTransactionBuffer.java | 194 ++++++++++++++++-----
.../buffer/impl/TopicTransactionBufferState.java | 21 ++-
.../broker/transaction/TransactionConsumeTest.java | 101 +++++++++++
.../buffer/TopicTransactionBufferTest.java | 18 +-
.../buffer/utils/TransactionBufferTestImpl.java | 15 ++
.../pulsar/client/api/NonPersistentTopicTest.java | 5 +-
.../worker/rest/api/FunctionsMetricsResource.java | 4 +-
pulsar-io/hbase/pom.xml | 4 +
.../bookkeeper/client/PulsarMockBookKeeper.java | 3 +-
.../bookkeeper/client/PulsarMockLedgerHandle.java | 19 +-
.../bookkeeper/client/PulsarMockReadHandle.java | 13 +-
16 files changed, 315 insertions(+), 99 deletions(-)