[improve][broker] LS-1263:Sync commits from apache/pulsar branch-3.0 into 3.1_ds#256
Merged
srinath-ctds merged 98 commits into3.1_dsfrom LS-1263-newApr 23, 2024
+7,500-1,828
Commits
Commits on Apr 19, 2024
[fix] [broker] Producer is blocked on creation because backlog exceeded on topic, when dedup is enabled and no producer is there (apache#20951)
[improve] [broker] Improve cache handling for partitioned topic metadata when doing lookup (apache#21063)
[improve] [broker] Print warn log if ssl handshake error & print ledger id when switch ledger (apache#21201)
[fix] [client] fix reader.hasMessageAvailable return false when incoming queue is not empty (apache#21259)
[fix] [broker] [branch-3.0] Fast fix infinite HTTP call createSubscriptions caused by wrong topicName (apache#21997)
[improve][fn][branch-3.0] Add missing "exception" argument to some
log.error(apache#22140) (apache#22213)[fix] [broker] Close dispatchers stuck due to mismatch between dispatcher.consumerList and dispatcher.consumerSet (apache#22270)
[fix] [broker] fix mismatch between dispatcher.consumerList and dispatcher.consumerSet (apache#22283)
[fix][client]Fixed getting an incorrect
maxMessageSizevalue when accessing multiple clusters in the same process (apache#22306)[fix][client] Consumer lost message ack due to race condition in acknowledge with batch message (apache#22353)
[fix][broker] Avoid expired unclosed ledgers when checking expired messages by ledger closure time (apache#22335)
[fix][client] fix Reader.hasMessageAvailable might return true after seeking to latest (apache#22201)
[fix][broker] Fix wrong double-checked locking for readOnActiveConsumerTask in dispatcher (apache#22279)
[fix][client] Fix wrong results of hasMessageAvailable and readNext after seeking by timestamp (apache#22363)
[fix][broker] Fix consumer stops receiving messages when with large backlogs processing (apache#22454)
[fix][client] Fix client side memory leak when call MessageImpl.create and fix imprecise client-side metrics: pendingMessagesUpDownCounter, pendingBytesUpDownCounter, latencyHistogram (apache#22393)
[fix] [broker] Prevent long deduplication cursor backlog so that topic loading wouldn't timeout (apache#22479)
[improve][broker] Improve Gzip compression, allow excluding specific paths or disabling it (apache#22370)
[fix][broker] Optimize /metrics, fix unbounded request queue issue and fix race conditions in metricsBufferResponse mode (apache#22494)
[fix][test] Flaky-test: testMessageExpiryWithTimestampNonRecoverableException and testIncorrectClientClock (apache#22489)
[improve][broker] Optimize gzip compression for /metrics endpoint by sharing/caching compressed result (apache#22521)
[fix][broker] Fix a deadlock in SystemTopicBasedTopicPoliciesService during NamespaceEventsSystemTopicFactory init (apache#22528)
[fix][broker] Fix NPE causing dispatching to stop when using Key_Shared mode and allowOutOfOrderDelivery=true (apache#22533)
- committed
![dependabot[bot]](https://avatars.githubusercontent.com/in/29110?v=4&size=32){kind=avatar}
Commits on Apr 22, 2024
Fix [improve] [proxy] Not close the socket if lookup failed caused by too many requests (apache#21216)
committed[fix][broker] Update topic partition failed when config maxNumPartitionsPerPartitionedTopic<0 (apache#22397)
[improve][broker] Repeat the handleMetadataChanges callback when configurationMetadataStore equals localMetadataStore (apache#22519)
[fix][broker] Fix broken topic policy implementation compatibility with old pulsar version (apache#22535)
[improve][broker] Support X-Forwarded-For and HA Proxy Protocol for resolving original client IP of http/https requests (apache#22524)
[fix][ml] Fix NPE of getValidPositionAfterSkippedEntries when recovering a terminated managed ledger (apache#22552)
[fix][offload] Increase file upload limit from 2048MiB to 4096MiB for GCP/GCS offloading (apache#22554)
Commits on Apr 23, 2024
- authored