Re: [PR] [fix][broker] replace thenComposeAsync with thenCompose method in AuthorizationService [pulsar]

nodece commented on PR #24714: URL: https://github.com/apache/pulsar/pull/24714#issuecomment-3269099035 > Is it ok if I replace canLookup with canLookupAsync? Yes, you can make this replacement. After that, you can try removing the `thenComposeAsync`, but you still need to handle the

Re: [PR] Bump urllib3 from 2.2.3 to 2.5.0 in /tools/pytools [pulsar-site]

lhotari merged PR #1021: URL: https://github.com/apache/pulsar-site/pull/1021 -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to go to the specific comment. To unsubscribe, e-mail: commits-unsubscr...@pulsar

(pulsar-site) branch main updated: Bump brace-expansion from 1.1.11 to 1.1.12 (#1020)

This is an automated email from the ASF dual-hosted git repository. lhotari pushed a commit to branch main in repository https://gitbox.apache.org/repos/asf/pulsar-site.git The following commit(s) were added to refs/heads/main by this push: new 4801a7f66cd Bump brace-expansion from 1.1.11 t

(pulsar-site) branch main updated: Bump urllib3 from 2.2.3 to 2.5.0 in /tools/pytools (#1021)

This is an automated email from the ASF dual-hosted git repository. lhotari pushed a commit to branch main in repository https://gitbox.apache.org/repos/asf/pulsar-site.git The following commit(s) were added to refs/heads/main by this push: new e0b3b2744a3 Bump urllib3 from 2.2.3 to 2.5.0 i

Re: [PR] Bump brace-expansion from 1.1.11 to 1.1.12 [pulsar-site]

lhotari merged PR #1020: URL: https://github.com/apache/pulsar-site/pull/1020 -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to go to the specific comment. To unsubscribe, e-mail: commits-unsubscr...@pulsar

Re: [PR] Bump requests from 2.32.3 to 2.32.4 in /tools/pytools [pulsar-site]

lhotari merged PR #1019: URL: https://github.com/apache/pulsar-site/pull/1019 -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to go to the specific comment. To unsubscribe, e-mail: commits-unsubscr...@pulsar

(pulsar-site) branch main updated: Bump form-data from 2.5.2 to 2.5.5 (#1029)

This is an automated email from the ASF dual-hosted git repository. lhotari pushed a commit to branch main in repository https://gitbox.apache.org/repos/asf/pulsar-site.git The following commit(s) were added to refs/heads/main by this push: new 3e0e2271e01 Bump form-data from 2.5.2 to 2.5.5

Re: [PR] Bump form-data from 2.5.2 to 2.5.5 [pulsar-site]

lhotari merged PR #1029: URL: https://github.com/apache/pulsar-site/pull/1029 -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to go to the specific comment. To unsubscribe, e-mail: commits-unsubscr...@pulsar

(pulsar-site) branch dependabot/pip/tools/pytools/urllib3-2.5.0 deleted (was e86e2447389)

This is an automated email from the ASF dual-hosted git repository. github-bot pushed a change to branch dependabot/pip/tools/pytools/urllib3-2.5.0 in repository https://gitbox.apache.org/repos/asf/pulsar-site.git was e86e2447389 Bump urllib3 from 2.2.3 to 2.5.0 in /tools/pytools The revis

(pulsar-site) branch main updated: Update Getting Started documentation with latest requirements and best practices (#1033)

This is an automated email from the ASF dual-hosted git repository. lhotari pushed a commit to branch main in repository https://gitbox.apache.org/repos/asf/pulsar-site.git The following commit(s) were added to refs/heads/main by this push: new cae4a25fbba Update Getting Started documentati

(pulsar-site) branch dependabot/npm_and_yarn/brace-expansion-1.1.12 deleted (was a635a35b98b)

This is an automated email from the ASF dual-hosted git repository. github-bot pushed a change to branch dependabot/npm_and_yarn/brace-expansion-1.1.12 in repository https://gitbox.apache.org/repos/asf/pulsar-site.git was a635a35b98b Bump brace-expansion from 1.1.11 to 1.1.12 The revision

Re: [PR] Update Getting Started documentation with latest requirements and best practices [pulsar-site]

lhotari commented on code in PR #1033: URL: https://github.com/apache/pulsar-site/pull/1033#discussion_r2330773720 ## docs/getting-started-helm.md: ## @@ -9,11 +9,19 @@ This section guides you through every step of installing and running Apache Puls For deploying a Pulsar cl

Re: [PR] Update Getting Started documentation with latest requirements and best practices [pulsar-site]

lhotari commented on code in PR #1033: URL: https://github.com/apache/pulsar-site/pull/1033#discussion_r2330772649 ## docs/getting-started-helm.md: ## @@ -9,11 +9,19 @@ This section guides you through every step of installing and running Apache Puls For deploying a Pulsar cl

Re: [PR] Update Getting Started documentation with latest requirements and best practices [pulsar-site]

lhotari commented on code in PR #1033: URL: https://github.com/apache/pulsar-site/pull/1033#discussion_r2330779548 ## docs/getting-started-helm.md: ## @@ -32,10 +40,10 @@ We use [Minikube](https://minikube.sigs.k8s.io/docs/start/) in this quick start 1. Create a Kubernetes clu

Re: [PR] Update Getting Started documentation with latest requirements and best practices [pulsar-site]

lhotari commented on code in PR #1033: URL: https://github.com/apache/pulsar-site/pull/1033#discussion_r2330779548 ## docs/getting-started-helm.md: ## @@ -32,10 +40,10 @@ We use [Minikube](https://minikube.sigs.k8s.io/docs/start/) in this quick start 1. Create a Kubernetes clu

[I] [Bug] Reproducible Builds issues on 4.1.0 release [pulsar]

hboutemy opened a new issue, #24718: URL: https://github.com/apache/pulsar/issues/24718 ### Search before reporting - [x] I searched in the [issues](https://github.com/apache/pulsar/issues) and found nothing similar. ### Read release policy - [x] I understand that [u

Re: [PR] [improve][pip] PIP-434: Expose Netty channel configuration WRITE_BUFFER_WATER_MARK to pulsar conf and pause receive requests when channel is unwritable [pulsar]

poorbarcode merged PR #24510: URL: https://github.com/apache/pulsar/pull/24510 -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to go to the specific comment. To unsubscribe, e-mail: commits-unsubscr...@pulsa

Re: [PR] [improve][broker] PIP-433: Ensure topic creation before starting GEO [pulsar]

nodece commented on code in PR #24652: URL: https://github.com/apache/pulsar/pull/24652#discussion_r2332006873 ## pulsar-broker/src/main/java/org/apache/pulsar/broker/service/persistent/PersistentTopic.java: ## @@ -2236,11 +2237,11 @@ protected CompletableFuture addReplicationC

Re: [PR] [improve][pip] PIP-434: Expose Netty channel configuration WRITE_BUFFER_WATER_MARK to pulsar conf and pause receive requests when channel is unwritable [pulsar]

poorbarcode commented on code in PR #24510: URL: https://github.com/apache/pulsar/pull/24510#discussion_r2331839209 ## pip/pip-434.md: ## @@ -0,0 +1,94 @@ +# PIP-434: Expose Netty channel configuration WRITE_BUFFER_WATER_MARK to pulsar conf and pause receive requests when chann

(pulsar) branch master updated: [improve][broker] Optimize Reader creation in TopicPoliciesService (#24658)

This is an automated email from the ASF dual-hosted git repository. zixuan pushed a commit to branch master in repository https://gitbox.apache.org/repos/asf/pulsar.git The following commit(s) were added to refs/heads/master by this push: new 0cda4f400b0 [improve][broker] Optimize Reader cr

Re: [PR] [improve][broker] Optimize Reader creation in TopicPoliciesService [pulsar]

nodece merged PR #24658: URL: https://github.com/apache/pulsar/pull/24658 -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to go to the specific comment. To unsubscribe, e-mail: commits-unsubscr...@pulsar.apa

Re: [PR] [fix][broker] replace thenComposeAsync with thenCompose method in AuthorizationService [pulsar]

oneby-wang commented on PR #24714: URL: https://github.com/apache/pulsar/pull/24714#issuecomment-3268714201 > We'd better migrate the internal fix that from the private KSN project to Apache Pulsar. May kick me when you are in progess? I'm interested in this memory leak problem. --

Re: [PR] [fix][broker] replace thenComposeAsync with thenCompose method in AuthorizationService [pulsar]

oneby-wang commented on code in PR #24714: URL: https://github.com/apache/pulsar/pull/24714#discussion_r2331900473 ## pulsar-broker-common/src/main/java/org/apache/pulsar/broker/authorization/AuthorizationService.java: ## @@ -219,7 +219,7 @@ public CompletableFuture canProduceAs

Re: [PR] [fix][broker] replace thenComposeAsync with thenCompose method in AuthorizationService [pulsar]

BewareMyPower commented on code in PR #24714: URL: https://github.com/apache/pulsar/pull/24714#discussion_r2331885984 ## pulsar-broker-common/src/main/java/org/apache/pulsar/broker/authorization/AuthorizationService.java: ## @@ -219,7 +219,7 @@ public CompletableFuture canProduc

Re: [PR] [fix] Generate sequenceID at send time to ensure sequential ordering [pulsar-client-go]

intkuroky commented on PR #1411: URL: https://github.com/apache/pulsar-client-go/pull/1411#issuecomment-3268686801 > How could the out-of-order issue happen? Yes, the sending operation is indeed executed within the same event loop. However, the generation of sequenceID does not occur

Re: [PR] [fix] Don't use ForkJoinPool when using CompletableFuture.thenXXXAsync [pulsar]

BewareMyPower commented on PR #24383: URL: https://github.com/apache/pulsar/pull/24383#issuecomment-3268666517 > it would be better to use a dedicated ForkJoinPool where necessary, I agree. -- This is an automated message from the Apache Git Service. To respond to the message, plea

Re: [PR] [fix][broker] replace thenComposeAsync with thenCompose method in AuthorizationService [pulsar]

oneby-wang commented on code in PR #24714: URL: https://github.com/apache/pulsar/pull/24714#discussion_r2331849966 ## pulsar-broker-common/src/main/java/org/apache/pulsar/broker/authorization/AuthorizationService.java: ## @@ -219,7 +219,7 @@ public CompletableFuture canProduceAs

Re: [PR] [fix][broker] replace thenComposeAsync with thenCompose method in AuthorizationService [pulsar]

oneby-wang commented on PR #24714: URL: https://github.com/apache/pulsar/pull/24714#issuecomment-3266396219 > Similar changes in #24383. I don't think that we should blindly change from thenComposeAsync to thenCompose since some implementations might be blocking the callback completion thre

Re: [PR] [improve][pip] PIP-434: Expose Netty channel configuration WRITE_BUFFER_WATER_MARK to pulsar conf and pause receive requests when channel is unwritable [pulsar]

poorbarcode commented on code in PR #24510: URL: https://github.com/apache/pulsar/pull/24510#discussion_r2331837393 ## pip/pip-434.md: ## @@ -0,0 +1,95 @@ +# PIP-434: Expose Netty channel configuration WRITE_BUFFER_WATER_MARK to pulsar conf and pause receive requests when chann

Re: [I] [Bug] Consumer stops consuming due to inconsistent state between dispatcher and cursor [pulsar]

dragonls commented on issue #24697: URL: https://github.com/apache/pulsar/issues/24697#issuecomment-3268624268 > > [@lhotari](https://github.com/lhotari) Reproduced in 3.0.13. > > [@dragonls](https://github.com/dragonls) Could you please share topic stats and internal stats in a [gist

Re: [PR] [fix][broker] replace thenComposeAsync with thenCompose method in AuthorizationService [pulsar]

BewareMyPower commented on PR #24714: URL: https://github.com/apache/pulsar/pull/24714#issuecomment-3268618587 > If DataSketchesSummaryLogger.ThreadLocalAccessor is accessed by normal thread(not netty thread), map element will not be removed when thread is completed. I've suffered th

Re: [PR] [fix][broker] replace thenComposeAsync with thenCompose method in AuthorizationService [pulsar]

oneby-wang commented on code in PR #24714: URL: https://github.com/apache/pulsar/pull/24714#discussion_r2331753787 ## pulsar-broker-common/src/main/java/org/apache/pulsar/broker/authorization/AuthorizationService.java: ## @@ -219,7 +219,7 @@ public CompletableFuture canProduceAs

Re: [PR] [fix][broker] replace thenComposeAsync with thenCompose method in AuthorizationService [pulsar]

oneby-wang commented on code in PR #24714: URL: https://github.com/apache/pulsar/pull/24714#discussion_r2331753787 ## pulsar-broker-common/src/main/java/org/apache/pulsar/broker/authorization/AuthorizationService.java: ## @@ -219,7 +219,7 @@ public CompletableFuture canProduceAs

Re: [PR] [fix][broker] replace thenComposeAsync with thenCompose method in AuthorizationService [pulsar]

codecov-commenter commented on PR #24714: URL: https://github.com/apache/pulsar/pull/24714#issuecomment-3268535635 ## [Codecov](https://app.codecov.io/gh/apache/pulsar/pull/24714?dropdown=coverage&src=pr&el=h1&utm_medium=referral&utm_source=github&utm_content=comment&utm_campaign=pr+comments

Re: [PR] [improve][io] Upgrade to Debezium 3.2.2 [pulsar]

lhotari commented on PR #24712: URL: https://github.com/apache/pulsar/pull/24712#issuecomment-3267640169 @efcasado I've suggested to cherry-pick this to branch-4.1 so that we could include this in 4.1.1 release. I made the proposal on the dev mailing list: https://lists.apache.org/thread/jr

Re: [PR] [fix] Don't use ForkJoinPool when using CompletableFuture.thenXXXAsync [pulsar]

lhotari commented on code in PR #24383: URL: https://github.com/apache/pulsar/pull/24383#discussion_r2330265658 ## pulsar-broker-common/src/main/java/org/apache/pulsar/broker/authorization/AuthorizationService.java: ## @@ -218,7 +218,7 @@ public CompletableFuture canProduceAsync

Re: [PR] [fix][test]fix flaky MessagePayloadProcessorTest.testDefaultProcessor [pulsar]

codelipenghui merged PR #24710: URL: https://github.com/apache/pulsar/pull/24710 -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to go to the specific comment. To unsubscribe, e-mail: commits-unsubscr...@pul

Re: [I] Upgrade to later version of Debezium Postgres [pulsar]

lhotari closed issue #24333: Upgrade to later version of Debezium Postgres URL: https://github.com/apache/pulsar/issues/24333 -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to go to the specific comment. To

(pulsar) branch branch-3.0 updated: [fix][sec] Upgrade Netty to 4.1.127.Final to address CVEs (#24717)

This is an automated email from the ASF dual-hosted git repository. lhotari pushed a commit to branch branch-3.0 in repository https://gitbox.apache.org/repos/asf/pulsar.git The following commit(s) were added to refs/heads/branch-3.0 by this push: new ab728258938 [fix][sec] Upgrade Netty to

(pulsar) branch branch-4.0 updated: [fix][sec] Upgrade Netty to 4.1.127.Final to address CVEs (#24717)

This is an automated email from the ASF dual-hosted git repository. lhotari pushed a commit to branch branch-4.0 in repository https://gitbox.apache.org/repos/asf/pulsar.git The following commit(s) were added to refs/heads/branch-4.0 by this push: new 41137666341 [fix][sec] Upgrade Netty to

(pulsar) branch branch-3.3 updated: [fix][sec] Upgrade Netty to 4.1.127.Final to address CVEs (#24717)

This is an automated email from the ASF dual-hosted git repository. lhotari pushed a commit to branch branch-3.3 in repository https://gitbox.apache.org/repos/asf/pulsar.git The following commit(s) were added to refs/heads/branch-3.3 by this push: new c88d33fb843 [fix][sec] Upgrade Netty to

(pulsar) 01/05: [improve][ml] Improve cache insert performance by removing exists check since it's already covered by putIfAbsent (#24699)

This is an automated email from the ASF dual-hosted git repository. lhotari pushed a commit to branch branch-4.1 in repository https://gitbox.apache.org/repos/asf/pulsar.git commit 3f510c6a02706edc62ded53d3ca5ac2963d2b7a6 Author: Lari Hotari AuthorDate: Thu Sep 4 12:29:28 2025 +0300 [improv

(pulsar) 04/05: [improve][build] Disable javadoc build failure (#24594)

This is an automated email from the ASF dual-hosted git repository. lhotari pushed a commit to branch branch-4.1 in repository https://gitbox.apache.org/repos/asf/pulsar.git commit ec0df9ccffec9f11380dfddef949efa59293beb7 Author: Zixuan Liu AuthorDate: Mon Sep 8 22:22:17 2025 +0800 [improve

(pulsar) 02/05: [improve][client] PIP-407 Add newMessage with schema and transactions (#23942)

This is an automated email from the ASF dual-hosted git repository. lhotari pushed a commit to branch branch-4.1 in repository https://gitbox.apache.org/repos/asf/pulsar.git commit 9e6f7a130e22381a9726bf02ea985a9ab380a633 Author: Omar Yasin AuthorDate: Thu Sep 4 23:11:31 2025 +0100 [improve

(pulsar) 03/05: [fix][broker] Fix NPE and annotate nullable return values for ManagedCursorContainer (#24706)

This is an automated email from the ASF dual-hosted git repository. lhotari pushed a commit to branch branch-4.1 in repository https://gitbox.apache.org/repos/asf/pulsar.git commit 77d18bfcd372509c3074beea024f1189581116ef Author: Yunze Xu AuthorDate: Fri Sep 5 15:54:14 2025 +0800 [fix][brok

(pulsar) 05/05: [fix][sec] Upgrade Netty to 4.1.127.Final to address CVEs (#24717)

This is an automated email from the ASF dual-hosted git repository. lhotari pushed a commit to branch branch-4.1 in repository https://gitbox.apache.org/repos/asf/pulsar.git commit eb39530e711f9326058535baca38f294fc365270 Author: Lari Hotari AuthorDate: Mon Sep 8 21:49:12 2025 +0300 [fix][s

(pulsar) branch branch-4.1 updated (4097ce09426 -> eb39530e711)

This is an automated email from the ASF dual-hosted git repository. lhotari pushed a change to branch branch-4.1 in repository https://gitbox.apache.org/repos/asf/pulsar.git from 4097ce09426 [feat][misc] upgrade oxia version to 0.6.2 (#24689) new 3f510c6a027 [improve][ml] Improve cache

Re: [PR] [fix][sec] Upgrade Netty to 4.1.127.Final to address CVEs [pulsar]

codecov-commenter commented on PR #24717: URL: https://github.com/apache/pulsar/pull/24717#issuecomment-3267488876 ## [Codecov](https://app.codecov.io/gh/apache/pulsar/pull/24717?dropdown=coverage&src=pr&el=h1&utm_medium=referral&utm_source=github&utm_content=comment&utm_campaign=pr+comments

[PR] [fix][sec] Upgrade Netty to 4.1.127.Final to address CVEs [pulsar]

lhotari opened a new pull request, #24717: URL: https://github.com/apache/pulsar/pull/24717 ### Motivation Addresses CVE-2025-58057 and CVE-2025-58056 in Netty. Pulsar users aren't impacted, but we need to use dependencies that don't contain known CVEs. Release notes * https

[PR] Test with k8s v1.34.0 [pulsar-helm-chart]

lhotari opened a new pull request, #628: URL: https://github.com/apache/pulsar-helm-chart/pull/628 (no comment) -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to go to the specific comment. To unsubscri

Re: [PR] Update Getting Started documentation with latest requirements and best practices [pulsar-site]

lhotari commented on code in PR #1033: URL: https://github.com/apache/pulsar-site/pull/1033#discussion_r2330772649 ## docs/getting-started-helm.md: ## @@ -9,11 +9,19 @@ This section guides you through every step of installing and running Apache Puls For deploying a Pulsar cl

Re: [PR] Update Getting Started documentation with latest requirements and best practices [pulsar-site]

lhotari commented on code in PR #1033: URL: https://github.com/apache/pulsar-site/pull/1033#discussion_r2330773105 ## docs/getting-started-helm.md: ## @@ -9,11 +9,19 @@ This section guides you through every step of installing and running Apache Puls For deploying a Pulsar cl

Re: [PR] Update Getting Started documentation with latest requirements and best practices [pulsar-site]

lhotari commented on code in PR #1033: URL: https://github.com/apache/pulsar-site/pull/1033#discussion_r2330779548 ## docs/getting-started-helm.md: ## @@ -32,10 +40,10 @@ We use [Minikube](https://minikube.sigs.k8s.io/docs/start/) in this quick start 1. Create a Kubernetes clu

[PR] [improve][pip] PIP-441: Add Broker-Level Metrics for Skipped Non-Recoverable Data [pulsar]

codelipenghui opened a new pull request, #24716: URL: https://github.com/apache/pulsar/pull/24716 ## Summary This PIP proposes adding two broker-level metrics to provide essential visibility into non-recoverable data skipping when `autoSkipNonRecoverableData` is enabled. ## Ne

Re: [I] Flaky-test: MessagePayloadProcessorTest.testDefaultProcessor [pulsar]

codelipenghui closed issue #24709: Flaky-test: MessagePayloadProcessorTest.testDefaultProcessor URL: https://github.com/apache/pulsar/issues/24709 -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to go to the

svn commit: r79146 - in release/pulsar: pulsar-client-reactive-0.5.10 pulsar-client-reactive-0.5.3 pulsar-client-reactive-0.5.4 pulsar-client-reactive-0.5.5 pulsar-client-reactive-0.5.6 pulsar-client-

Author: lhotari Date: Mon Sep 8 15:14:47 2025 New Revision: 79146 Log: Remove old pulsar-client-reactive releases Deleted: release/pulsar/pulsar-client-reactive-0.5.10/ release/pulsar/pulsar-client-reactive-0.5.3/ release/pulsar/pulsar-client-reactive-0.5.4/ release/pulsar/pulsar-cli

svn commit: r79141 - in release/pulsar: pulsar-client-cpp-3.5.0 pulsar-client-cpp-3.5.1 pulsar-client-cpp-3.6.0 pulsar-client-cpp-3.7.0 pulsar-client-cpp-3.7.1 pulsar-client-go-0.13.0 pulsar-client-go

Author: lhotari Date: Mon Sep 8 14:55:11 2025 New Revision: 79141 Log: Cleanup old pulsar-client-cpp, pulsar-client-go, pulsar-client-python and pulsar-manager releases Deleted: release/pulsar/pulsar-client-cpp-3.5.0/ release/pulsar/pulsar-client-cpp-3.5.1/ release/pulsar/pulsar-client

Re: [PR] [fix][test]fix flaky MessagePayloadProcessorTest.testDefaultProcessor [pulsar]

codecov-commenter commented on PR #24710: URL: https://github.com/apache/pulsar/pull/24710#issuecomment-3266741187 ## [Codecov](https://app.codecov.io/gh/apache/pulsar/pull/24710?dropdown=coverage&src=pr&el=h1&utm_medium=referral&utm_source=github&utm_content=comment&utm_campaign=pr+comments

svn commit: r79142 - in release/pulsar/pulsar-client-node: pulsar-client-node-1.11.0 pulsar-client-node-1.11.1 pulsar-client-node-1.12.0 pulsar-client-node-1.13.0 pulsar-client-node-1.13.1 pulsar-clie

Author: lhotari Date: Mon Sep 8 14:56:31 2025 New Revision: 79142 Log: Remove old pulsar-client-node releases Deleted: release/pulsar/pulsar-client-node/pulsar-client-node-1.11.0/ release/pulsar/pulsar-client-node/pulsar-client-node-1.11.1/ release/pulsar/pulsar-client-node/pulsar-clien

svn commit: r79140 - in release/pulsar: pulsar-3.0.10 pulsar-3.0.11 pulsar-3.0.12 pulsar-3.1.3 pulsar-3.2.2 pulsar-3.2.3 pulsar-3.2.4 pulsar-3.3.4 pulsar-3.3.5 pulsar-3.3.6 pulsar-3.3.7 pulsar-4.0.3 p

Author: lhotari Date: Mon Sep 8 14:51:59 2025 New Revision: 79140 Log: Remove old Pulsar releases Deleted: release/pulsar/pulsar-3.0.10/ release/pulsar/pulsar-3.0.11/ release/pulsar/pulsar-3.0.12/ release/pulsar/pulsar-3.1.3/ release/pulsar/pulsar-3.2.2/ release/pulsar/pulsar-3

svn commit: r79139 - in release/pulsar/helm-chart: 3.0.0 3.1.0 3.2.0 3.3.0 3.3.1 3.4.0 3.4.1 3.5.0 3.6.0 3.7.0 3.8.0 3.9.0 4.0.0 4.0.1 4.1.0

Author: lhotari Date: Mon Sep 8 14:47:56 2025 New Revision: 79139 Log: Archive old pulsar-helm-chart releases Deleted: release/pulsar/helm-chart/3.0.0/ release/pulsar/helm-chart/3.1.0/ release/pulsar/helm-chart/3.2.0/ release/pulsar/helm-chart/3.3.0/ release/pulsar/helm-chart/3.3.

(pulsar-site) branch main updated: Update urls to archive.apache.org/dist for released to be removed from https://dist.apache.org/repos/dist/release/pulsar/helm-chart/

This is an automated email from the ASF dual-hosted git repository. lhotari pushed a commit to branch main in repository https://gitbox.apache.org/repos/asf/pulsar-site.git The following commit(s) were added to refs/heads/main by this push: new f6610654d82 Update urls to archive.apache.org/

Re: [PR] [fix][broker] replace thenComposeAsync with thenCompose method in AuthorizationService [pulsar]

oneby-wang commented on code in PR #24714: URL: https://github.com/apache/pulsar/pull/24714#discussion_r2330303730 ## pulsar-broker-common/src/main/java/org/apache/pulsar/broker/authorization/AuthorizationService.java: ## @@ -219,7 +219,7 @@ public CompletableFuture canProduceAs

Re: [PR] [improve][build] Disable javadoc build failure [pulsar]

nodece merged PR #24594: URL: https://github.com/apache/pulsar/pull/24594 -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to go to the specific comment. To unsubscribe, e-mail: commits-unsubscr...@pulsar.apa

Re: [PR] [improve][build] Disable javadoc build failure [pulsar]

codecov-commenter commented on PR #24594: URL: https://github.com/apache/pulsar/pull/24594#issuecomment-3266559931 ## [Codecov](https://app.codecov.io/gh/apache/pulsar/pull/24594?dropdown=coverage&src=pr&el=h1&utm_medium=referral&utm_source=github&utm_content=comment&utm_campaign=pr+comments

Re: [PR] [fix][broker] replace thenComposeAsync with thenCompose method in AuthorizationService [pulsar]

lhotari commented on code in PR #24714: URL: https://github.com/apache/pulsar/pull/24714#discussion_r2330374669 ## pulsar-broker-common/src/main/java/org/apache/pulsar/broker/authorization/AuthorizationService.java: ## @@ -219,7 +219,7 @@ public CompletableFuture canProduceAsync

(pulsar-site) branch asf-site-next updated: Site updated at revision 22c1ee10

This is an automated email from the ASF dual-hosted git repository. urfree pushed a commit to branch asf-site-next in repository https://gitbox.apache.org/repos/asf/pulsar-site.git The following commit(s) were added to refs/heads/asf-site-next by this push: new 1019e63bffe Site updated at r

Re: [PR] [fix][broker] replace thenComposeAsync with thenCompose method in AuthorizationService [pulsar]

oneby-wang commented on code in PR #24714: URL: https://github.com/apache/pulsar/pull/24714#discussion_r2330303730 ## pulsar-broker-common/src/main/java/org/apache/pulsar/broker/authorization/AuthorizationService.java: ## @@ -219,7 +219,7 @@ public CompletableFuture canProduceAs

Re: [PR] [fix][broker] replace thenComposeAsync with thenCompose method in AuthorizationService [pulsar]

lhotari commented on code in PR #24714: URL: https://github.com/apache/pulsar/pull/24714#discussion_r2330263429 ## pulsar-broker-common/src/main/java/org/apache/pulsar/broker/authorization/AuthorizationService.java: ## @@ -219,7 +219,7 @@ public CompletableFuture canProduceAsync

(pulsar-site) branch release_4.1.0 updated (4eb8f47a2d3 -> 4d68b8ae4f2)

This is an automated email from the ASF dual-hosted git repository. zhaocong pushed a change to branch release_4.1.0 in repository https://gitbox.apache.org/repos/asf/pulsar-site.git from 4eb8f47a2d3 Release 4.1.0 add 4d68b8ae4f2 add 4.1.0 doc No new revisions were added by this update

Re: [PR] [fix][broker] replace thenComposeAsync with thenCompose method in AuthorizationService [pulsar]

lhotari commented on PR #24714: URL: https://github.com/apache/pulsar/pull/24714#issuecomment-3266305133 Similar changes in #24383. I don't think that we should change from thenComposeAsync to thenCompose since some implementations might be blocking the callback completion thread. This chan

(pulsar-site) branch asf-site-next updated: Site updated at revision 43da7252

This is an automated email from the ASF dual-hosted git repository. urfree pushed a commit to branch asf-site-next in repository https://gitbox.apache.org/repos/asf/pulsar-site.git The following commit(s) were added to refs/heads/asf-site-next by this push: new af931d88b80 Site updated at r

Re: [PR] [fix] Don't use ForkJoinPool when using CompletableFuture.thenXXXAsync [pulsar]

lhotari commented on PR #24383: URL: https://github.com/apache/pulsar/pull/24383#issuecomment-3266273289 > Thank you for providing the additional information. I think it would be better to use a dedicated ForkJoinPool where necessary, instead of relying on the default common pool everywhere

(pulsar-site) branch asf-site-next updated: Site updated at revision 43da7252

This is an automated email from the ASF dual-hosted git repository. urfree pushed a commit to branch asf-site-next in repository https://gitbox.apache.org/repos/asf/pulsar-site.git The following commit(s) were added to refs/heads/asf-site-next by this push: new 88037a19248 Site updated at r

Re: [I] [Bug] Consumer stops consuming due to inconsistent state between dispatcher and cursor [pulsar]

lhotari commented on issue #24697: URL: https://github.com/apache/pulsar/issues/24697#issuecomment-3266124317 > [@lhotari](https://github.com/lhotari) Reproduced in 3.0.13. @dragonls Could you please share topic stats and internal stats in a [gist](https://gist.github.com/)? you can s

(pulsar) branch master updated: [improve][misc] Protect branch-4.1 (#24715)

This is an automated email from the ASF dual-hosted git repository. lhotari pushed a commit to branch master in repository https://gitbox.apache.org/repos/asf/pulsar.git The following commit(s) were added to refs/heads/master by this push: new 56399ee448d [improve][misc] Protect branch-4.1

Re: [PR] [improve][misc] Protect branch-4.1 [pulsar]

lhotari merged PR #24715: URL: https://github.com/apache/pulsar/pull/24715 -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to go to the specific comment. To unsubscribe, e-mail: commits-unsubscr...@pulsar.ap

[PR] [improve][misc] Protect branch-4.1 [pulsar]

lhotari opened a new pull request, #24715: URL: https://github.com/apache/pulsar/pull/24715 ### Motivation Pulsar 4.1.0 has been released and we shouldn't allow force pushes to branch-4.1 . ### Modifications - Add configuration to `.asf.yaml` to protect `branch-4.1`

Re: [I] [Bug] Key_Shared or Shared subscription doesn't always deliver messages from the replay queue after a consumer disconnects and leaves a backlog unless new messages are produced [pulsar]

lhotari commented on issue #23845: URL: https://github.com/apache/pulsar/issues/23845#issuecomment-3266050439 > > Would you like to contribute a fix for the issue? > > [@lhotari](https://github.com/lhotari) Sure. If I find a way to fix it without performance and memory issues I will s

Re: [PR] [improve][pip] PIP-439: Adding Transaction Support to Pulsar Functions Through Auto-Transaction Wrapping [pulsar]

wzhramc commented on code in PR #24704: URL: https://github.com/apache/pulsar/pull/24704#discussion_r2329816562 ## pip/pip-439.md: ## @@ -0,0 +1,573 @@ +# PIP-439: Adding Transaction Support to Pulsar Functions Through Auto-Transaction Wrapping + +# Background knowledge + +Apac

(pulsar-site) branch main updated: fix: add siderbar for 4.1.x

This is an automated email from the ASF dual-hosted git repository. zhaocong pushed a commit to branch main in repository https://gitbox.apache.org/repos/asf/pulsar-site.git The following commit(s) were added to refs/heads/main by this push: new 6f82f6d0bac fix: add siderbar for 4.1.x 6f82f

(pulsar-site) 02/02: Add instructions for new feature releases

This is an automated email from the ASF dual-hosted git repository. lhotari pushed a commit to branch main in repository https://gitbox.apache.org/repos/asf/pulsar-site.git commit 43da7252d8a25f94928238f2eb63f93dd426d03b Author: Lari Hotari AuthorDate: Mon Sep 8 14:51:35 2025 +0300 Add inst

(pulsar-site) 01/02: Add 4.1.x to static/reference/index.html

This is an automated email from the ASF dual-hosted git repository. lhotari pushed a commit to branch main in repository https://gitbox.apache.org/repos/asf/pulsar-site.git commit 789cfbafe20fcaf1dad49c5f2a595657c0abf249 Author: Lari Hotari AuthorDate: Mon Sep 8 14:47:20 2025 +0300 Add 4.1.

(pulsar-site) branch release_4.1.0 updated (2043c943884 -> 50811165fa6)

This is an automated email from the ASF dual-hosted git repository. zhaocong pushed a change to branch release_4.1.0 in repository https://gitbox.apache.org/repos/asf/pulsar-site.git from 2043c943884 fix md style add 50811165fa6 fix md style No new revisions were added by this update.

Re: [PR] [fix][broker] replace thenComposeAsync with thenCompose method in AuthorizationService [pulsar]

oneby-wang commented on PR #24714: URL: https://github.com/apache/pulsar/pull/24714#issuecomment-3265887676 There are still some `thenComposeAsync` calls in the code that do not specify an executor, and I think this will pose potential performance and memory leak risks. I'm not sure whe

Re: [I] [Bug] Consumer stops consuming due to inconsistent state between dispatcher and cursor [pulsar]

dragonls commented on issue #24697: URL: https://github.com/apache/pulsar/issues/24697#issuecomment-3265888472 > A fix in 3.0.13 is related to cursor state management: [#24569](https://github.com/apache/pulsar/pull/24569). https://github.com/user-attachments/assets/4e7335e6-4922-4b46-

[PR] [fix][broker] replace thenComposeAsync with thenCompose method in AuthorizationService [pulsar]

oneby-wang opened a new pull request, #24714: URL: https://github.com/apache/pulsar/pull/24714 ### Motivation I think we should not use any `CompletableFuture.xxxAsync()` method in Pulsar broker, unless we specify a thread pool using Netty `DefaultThreadlFactory`. I encountered `Data

(pulsar-site) branch release_4.1.0 deleted (was 50811165fa6)

This is an automated email from the ASF dual-hosted git repository. zhaocong pushed a change to branch release_4.1.0 in repository https://gitbox.apache.org/repos/asf/pulsar-site.git was 50811165fa6 fix md style The revisions that were on this branch are still contained in other references

Re: [I] [Bug] Key_Shared or Shared subscription doesn't always deliver messages from the replay queue after a consumer disconnects and leaves a backlog unless new messages are produced [pulsar]

lhotari commented on issue #23845: URL: https://github.com/apache/pulsar/issues/23845#issuecomment-3265791812 > [@tarmacmonsterg](https://github.com/tarmacmonsterg) I have created [#24700](https://github.com/apache/pulsar/pull/24700) to address the race condition. @nborisov Yes, this

Re: [I] [Bug] Key_Shared or Shared subscription doesn't always deliver messages from the replay queue after a consumer disconnects and leaves a backlog unless new messages are produced [pulsar]

lhotari commented on issue #23845: URL: https://github.com/apache/pulsar/issues/23845#issuecomment-3265789299 > The issue reproduction is not consistent unfortunately. I am still trying to find the root cause. > Hope this input would be helpful for the investigation. Thanks for the

Re: [PR] Release 4.1.0 [pulsar-site]

coderzc merged PR #1036: URL: https://github.com/apache/pulsar-site/pull/1036 -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to go to the specific comment. To unsubscribe, e-mail: commits-unsubscr...@pulsar

Re: [PR] [improve][pip] PIP-439: Adding Transaction Support to Pulsar Functions Through Auto-Transaction Wrapping [pulsar]

wzhramc commented on code in PR #24704: URL: https://github.com/apache/pulsar/pull/24704#discussion_r2329826075 ## pip/pip-439.md: ## @@ -0,0 +1,573 @@ +# PIP-439: Adding Transaction Support to Pulsar Functions Through Auto-Transaction Wrapping + +# Background knowledge + +Apac

Re: [I] [Bug] Pulsaradmin client is not consistently returning all properties on peeked messages [pulsar-client-go]

RobertIndie closed issue #1418: [Bug] Pulsaradmin client is not consistently returning all properties on peeked messages URL: https://github.com/apache/pulsar-client-go/issues/1418 -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub

(pulsar-client-go) branch master updated: chore(deps): bump github.com/docker/docker (#1405)

This is an automated email from the ASF dual-hosted git repository. zike pushed a commit to branch master in repository https://gitbox.apache.org/repos/asf/pulsar-client-go.git The following commit(s) were added to refs/heads/master by this push: new 8fb4613c chore(deps): bump github.com/do

Re: [PR] chore(deps): bump github.com/docker/docker from 27.1.1+incompatible to 28.0.0+incompatible [pulsar-client-go]

RobertIndie merged PR #1405: URL: https://github.com/apache/pulsar-client-go/pull/1405 -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to go to the specific comment. To unsubscribe, e-mail: commits-unsubscr.

Re: [PR] [improve][pip] PIP-439: Adding Transaction Support to Pulsar Functions Through Auto-Transaction Wrapping [pulsar]

wzhramc commented on code in PR #24704: URL: https://github.com/apache/pulsar/pull/24704#discussion_r2329810401 ## pip/pip-439.md: ## @@ -0,0 +1,573 @@ +# PIP-439: Adding Transaction Support to Pulsar Functions Through Auto-Transaction Wrapping + +# Background knowledge + +Apac

(pulsar-client-go) branch dependabot/go_modules/github.com/go-viper/mapstructure/v2-2.4.0 deleted (was c1d1c9f1)

This is an automated email from the ASF dual-hosted git repository. github-bot pushed a change to branch dependabot/go_modules/github.com/go-viper/mapstructure/v2-2.4.0 in repository https://gitbox.apache.org/repos/asf/pulsar-client-go.git was c1d1c9f1 chore(deps): bump github.com/go-viper

Re: [PR] chore(deps): bump github.com/go-viper/mapstructure/v2 from 2.2.1 to 2.4.0 [pulsar-client-go]

RobertIndie merged PR #1415: URL: https://github.com/apache/pulsar-client-go/pull/1415 -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to go to the specific comment. To unsubscribe, e-mail: commits-unsubscr.

Re: [PR] [Issue #1418] Fix: Properties not getting consistently set on pulsaradmin subscription message responses [pulsar-client-go]

RobertIndie merged PR #1419: URL: https://github.com/apache/pulsar-client-go/pull/1419 -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to go to the specific comment. To unsubscribe, e-mail: commits-unsubscr.

(pulsar-client-go) branch master updated: chore(deps): bump github.com/go-viper/mapstructure/v2 (#1415)

This is an automated email from the ASF dual-hosted git repository. zike pushed a commit to branch master in repository https://gitbox.apache.org/repos/asf/pulsar-client-go.git The following commit(s) were added to refs/heads/master by this push: new 555e8fc8 chore(deps): bump github.com/go

  1   2   >