v2.10.6.1

2.10.6.1 (2023-09-28)

• [fix][broker] Fix write duplicate entries into the compacted ledger after RawReader reconnects (apache#210 (60d4ea9)
• [fix][broker] Fixed reset for AggregatedNamespaceStats (apache#21225) (7ed452e)
• [improve] [client] Merge lookup requests for the same topic (apache#21232) (cac49ff)
• [improve] [proxy] Not close the socket if lookup failed caused by too many requests (apache#21216) (f48aa4b)

v2.10.6.0

Full Changelog: https://github.com/ascentstream/pulsar/commits/v2.10.6.0

v2.10.5.5

2.10.5.5 (2023-08-30)

• [branch-2.10] Remove cpp tests (b0e2c0a)
• [branch-2.10][fix][broker] Avoid infinite bundle unloading (apache#20822) (apache#20877) (31d59cf)
• [branch-2.10][fix][broker] Fix inconsensus namespace policies by getPoliciesIfCached (apache#20873) (6d321e1)
• [branch-2.10][fix][broker] Inconsistent behaviour for topic auto_creation (apache#20872) (fea2f9b)
• [broker] clean inactive bundle from bundleData in loadData and bundlesCache (apache#13974) (8d501f2)
• [fix] [bk] Correctct the bookie info after ZK client is reconnected (apache#21035) (1f9aa9b)
• [fix] [broker] Can not receive any messages after switch to standby cluster (apache#20767) (20adfe4)
• [fix] [cli] the variable producerName of BatchMsgContainer is null (apache#20819) (4dae6cb)
• [fix] [client] Messages lost when consumer reconnect (apache#20695) (5d9f764)
• [fix] [meta]Switch to the metadata store thread after zk operation (apache#20303) (32e1463)
• [fix] [ml] fix discontinuous ledger deletion (apache#20898) (ea16fb8)
• [fix] [Perf] PerformanceProducer do not produce expected number of messages. (apache#19775) (25bfc46)
• [fix] [txn] fix consumer can receive aborted txn message when readType is replay (apache#19815) (4d7876b)
• [fix][branch-2.10] Fix duplicated deleting topics (apache#20685) (f10797a)
• [fix][branch-2.10]Fix compilation issue introduced by Save createIfMissing in TopicLoadingContext (# (043ecd7)
• [fix][branch-2.10]Fix compilation issue introduced byfix Repeated messages of shared dispatcher (#16 (3548d67)
• [fix][broker] Fix can't stop phase-two of compaction even though messageId read reaches lastReadId ( (a5d1ca0)
• [fix][broker] Fix get topic policies as null during clean cache (apache#20763) (17a4bcf)
• [fix][broker] Fix incorrect number of read compacted entries (apache#20978) (c9cc8a7)
• [fix][broker] Fix message loss during topic compaction (apache#20980) (385bede)
• [fix][broker] fix MessageDeduplication throw NPE when enable broker dedup and set namespace disable (46372d6)
• [fix][broker] Fix namespace deletion if __change_events topic has not been created yet (apache#18804) (043dbc3)
• [fix][broker] Fix return the earliest position when query position by timestamp. (apache#20457) (6a62499)
• [fix][broker] Fix test and checkstyle (f8729c0)
• [fix][broker] In replication scenario, remote consumer could not be registered if there has no messa (54359b6)
• [fix][broker] Invalidate metadata children cache after key deleted (apache#20363) (64831dc)
• [fix][broker] Make sure all inflight writes have finished before completion of compaction (apache#21067) (810a2f0)
• [fix][broker] Return if AbstractDispatcherSingleActiveConsumer closed (apache#19934) (c1b3024)
• [fix][broker] Topic policy can not be work well if replay policy message has any exception. (apache#20613) (0a69f66)
• [fix][broker] Use MessageDigest.isEqual when comparing digests (apache#21061) (63e142c)
• [fix][broker][branch-2.10] Fix NPE when reset Replicator's cursor by position. (apache#20597) (apache#20781) (643ffad)
• [fix][broker]fix the publish latency spike issue with large number of producers (apache#20607) (9fa56fc)
• [fix][build] Mongo is fixed for 2.10.5 (apache#20810) (1cd009d)
• [fix][build]Fix compatibility issue cause by apache#20819 (apache#20834) (1eb5eb3)
• [fix][client] Fix race condition that leads to caching failed CompletableFutures in ConnectionPool ( (0a4639e)
• [fix][client] Make the whole grabCnx() progress atomic (apache#20595) (d5631c9)
• [fix][flaky-test]NamespaceServiceTest.flaky/testModularLoadManagerRemoveBundleAndLoad (apache#17487) (44c033c)
• [fix][fn] Exit JVM when main thread throws exception (apache#20689) (090d1b7)
• [fix][fn] Fix JavaInstanceStarter inferring type class name error (apache#19896) (2ba506b)
• [fix][fn] Make KubernetesRuntime translate characters in function tenant, namespace, and name during (3a3c6f3)
• [fix][io] Close the kafka source connector got stuck (apache#20698) (3a2e593)
• [fix][io] Update test certs for Elasticsearch (apache#21001) (fa0c70c)
• [fix][io][branch-2.10] Not restart instance when kafka source poll exception. (apache#20816) (4a894af)
• [fix][meta] Adding the missed bookie id in the registration manager. (apache#20641) (c5f2128)
• [fix][meta] Bookie Info lost by notification race condition. (apache#20642) (823dc8c)
• [fix][offload] Filesystem offloader class not found hadoop-hdfs-client (apache#20365) (a91874b)
• [fix][schema] Only handle exception when there has (apache#20730) (b639685)
• [fix][sec] Upgrade snappy-java to address multiple CVEs (apache#20604) (186fc9d)
• [fix][test] Fix flaky testCreateTopicWithZombieReplicatorCursor (apache#20037) (c5253fd)
• [fix][test] Fix test testThreadSwitchOfZkMetadataStore (e6d4f09)
• [fix][test] Fix the compilation issue introduced in apache#20597 (7b6d1c9)
• [fix][test] Fix the test introduced in apache#18804 (9a6a460)
• [fix][test] Replace test call to Auth0 with call to WireMock (apache#20465) (1dbc723)
• [fix][ws] Remove unnecessary ping/pong implementation (apache#20733) (eac263e)
• [improve] [broker] Add consumer-id into the log when doing subscribe. (apache#20568) (e25d764)
• [improve] [broker] Avoid PersistentSubscription.expireMessages logic check backlog twice. (apache#20416) (c9eb6bd)
• [improve] [broker] Print warn log if compaction failure (apache#19405) (ebf9961)
• [improve][admin] Return BAD_REQUEST on cluster data is null for createCluster (apache#20346) (46ef34a)
• [improve][broker] Save createIfMissing in TopicLoadingContext (apache#19993) (ee3ad34)
• [improve][proxy] Support disabling metrics endpoint (apache#21031) (084347c)
• [improve][sql] Fix the wrong format of the logs (apache#20907) (ca880c6)
• [improve][txn]Add log when can't send TcClientConnectRequest to broker. (apache#20880) (40d018f)
• Delete MockManagedCursor.java (c7925b3)
• Fix breaking change of the deprecated constructor of PersistentMessageExpiryMonitor (5c55633)
• fix the license description (2e1638b)
• Issue 16802: fix Repeated messages of shared dispatcher (apache#16812) (7093196)
• Release 2.10.5 (82c589f)
• Revert "[fix][broker] Fix message loss during topic compaction (apache#20980)" (b9ab757)
• Revert "[fix][broker] Fix NPE when reset Replicator's cursor by position. (apache#20597)" (209b222)
• Update ConnectionHandlerTest.java (a4b3ae5)
• Update FaultInjectableZKRegistrationManager.java (0e70bdd)
• Update MetadataStoreTest.java - The prior PR was not checked against codestyle (7670e01)
• fix: bundle-data metadata leak because of bundlestats was not clean (apache#17095) (f7138b9)

v3.0.1.0

Full Changelog: https://github.com/ascentstream/pulsar/commits/v3.0.1.0

v2.10.5.4

2.10.5.4 (2023-06-30)

• [cleanup][broker] Validate authz earlier in delete subscription logic (apache#20549) (04a7a60)
• [fix][broker] Fix the publish latency spike from the contention of MessageDeduplication (apache#20647) (fa68bf3)
• [fix][client]Fix deadlock issue of consumer while using multiple IO threads (apache#20669) (39cf8d7)
• [improve][broker][branch-2.10] Backport Linux metrics changes from master branch (apache#20659) (b355d31)
• [improve][test][branch-2.10] Backport disabling disk usage threshold for Elastic Testcontainers (#20 (526e216)
• Optimize conusmer pause (apache#14566) (90369a0)
• resolve conflict after updating (55609eb)

v2.10.5.3

2.10.5.3 (2023-06-26)

• [fix][broker] release orphan replicator after topic closed (apache#20567) (db7832b)

v2.10.5.2

Full Changelog: v2.10.5.2...v2.10.5.1

v2.10.5.1

Full Changelog: https://github.com/ascentstream/pulsar/commits/v2.10.5.1

v2.11.2.0

Full Changelog: https://github.com/ascentstream/pulsar/commits/v2.11.2.0

v2.10.5.0

Full Changelog: https://github.com/ascentstream/pulsar/commits/v2.10.5.0