(pulsar) branch branch-3.2 updated: [improve][broker] Add msgInReplay subscription stat and metric to improve Key_Shared observability (#23224)

2024-08-28 Thread lhotari
This is an automated email from the ASF dual-hosted git repository. lhotari pushed a commit to branch branch-3.2 in repository https://gitbox.apache.org/repos/asf/pulsar.git The following commit(s) were added to refs/heads/branch-3.2 by this push: new 244ba863e44 [improve][broker] Add msgIn

(pulsar) branch branch-3.3 updated: [improve][broker] Add msgInReplay subscription stat and metric to improve Key_Shared observability (#23224)

2024-08-28 Thread lhotari
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 03ea94bbea8 [improve][broker] Add msgIn

(pulsar) branch branch-3.0 updated: [improve][broker] Add msgInReplay subscription stat and metric to improve Key_Shared observability (#23224)

2024-08-28 Thread lhotari
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 766d2a40719 [improve][broker] Add msgIn

[I] Race during reonnect [pulsar-client-go]

2024-08-28 Thread via GitHub
Gilthoniel opened a new issue, #1274: URL: https://github.com/apache/pulsar-client-go/issues/1274 Expected behavior After reconnecting to the broker, a consumer or a producer should register itself for callbacks. Actual behavior After reconnecting to the broker

(pulsar) branch master updated: [improve][broker] Add msgInReplay subscription stat and metric to improve Key_Shared observability (#23224)

2024-08-28 Thread lhotari
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 59424a831b3 [improve][broker] Add msgInReplay s

Re: [PR] [improve][broker] Add msgInReplay subscription stat and metric to improve Key_Shared observability [pulsar]

2024-08-28 Thread via GitHub
lhotari merged PR #23224: URL: https://github.com/apache/pulsar/pull/23224 -- 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

Re: [PR] [improve][broker] Add msgInReplay subscription stat and metric to improve Key_Shared observability [pulsar]

2024-08-28 Thread via GitHub
lhotari commented on PR #23224: URL: https://github.com/apache/pulsar/pull/23224#issuecomment-2316674673 > +1 for having a PIP for this change since it actually changed the Public API output and metrics. > > Another point is can we only have new the field in the topic stats? Since we

Re: [PR] [improve][broker] Add retry for start service unit state channel (ExtensibleLoadManagerImpl only) [pulsar]

2024-08-28 Thread via GitHub
lhotari commented on code in PR #23230: URL: https://github.com/apache/pulsar/pull/23230#discussion_r1735538539 ## pulsar-broker/src/main/java/org/apache/pulsar/broker/loadbalance/extensions/ExtensibleLoadManagerImpl.java: ## @@ -401,10 +404,33 @@ public void start() throws Puls

Re: [PR] [feat][broker] PIP-264: Add replication subscription stats [pulsar]

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

Re: [PR] [feat][misc] PIP-264: Add OpenTelemetry authentication and token metrics [pulsar]

2024-08-28 Thread via GitHub
lhotari merged PR #23016: URL: https://github.com/apache/pulsar/pull/23016 -- 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

(pulsar) branch master updated: [feat][misc] PIP-264: Add OpenTelemetry authentication and token metrics (#23016)

2024-08-28 Thread lhotari
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 587af853fbf [feat][misc] PIP-264: Add OpenTelem

(pulsar) branch master updated: [improve][txn] Take first snapshot before persisting the first transactional message (#21406)

2024-08-28 Thread xiangying
This is an automated email from the ASF dual-hosted git repository. xiangying 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 e2bbb4b7cbc [improve][txn] Take first snapsho

Re: [PR] [improve][txn] Take first snapshot before persisting the first transactional message [pulsar]

2024-08-28 Thread via GitHub
liangyepianzhou merged PR #21406: URL: https://github.com/apache/pulsar/pull/21406 -- 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...@p

Re: [I] [Bug] Peek nth message REST API returns incorrect data [pulsar]

2024-08-28 Thread via GitHub
crossoverJie commented on issue #23228: URL: https://github.com/apache/pulsar/issues/23228#issuecomment-2316607444 https://github.com/apache/pulsar/blob/679a3d49eefc2a82bbeba085c258b1f2b751f28a/pulsar-broker/src/test/java/org/apache/pulsar/broker/admin/AdminApi2Test.java#L710 https:/

(pulsar-site) branch main updated: Docs sync done from apache/pulsar (#325c6a5)

2024-08-28 Thread urfree
This is an automated email from the ASF dual-hosted git repository. urfree 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 8205b77f55f1 Docs sync done from apache/pulsar

[PR] [fix][broker] support peek-message for compressed and encrypted messages [pulsar]

2024-08-28 Thread via GitHub
rdhabalia opened a new pull request, #23234: URL: https://github.com/apache/pulsar/pull/23234 Fixes #23233 ### Motivation It fixes this issue: https://github.com/apache/pulsar/issues/23233 Currently `peek-message` CLI/API returns encrypted or compressed messag

[I] [Bug] Pulsar CLI is not able to peek encrypted and compressed message [pulsar]

2024-08-28 Thread via GitHub
rdhabalia opened a new issue, #23233: URL: https://github.com/apache/pulsar/issues/23233 ### Search before asking - [X] I searched in the [issues](https://github.com/apache/pulsar/issues) and found nothing similar. ### Read release policy - [X] I understand that unsu

Re: [PR] [feat][misc] PIP-264: Add OpenTelemetry authentication and token metrics [pulsar]

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

Re: [PR] [feat][broker] PIP-264: Add replication subscription stats [pulsar]

2024-08-28 Thread via GitHub
dragosvictor commented on PR #23026: URL: https://github.com/apache/pulsar/pull/23026#issuecomment-2316276527 /pulsarbot rerun-failure-checks -- 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 s

Re: [PR] [feat][misc] PIP-264: Add OpenTelemetry authentication and token metrics [pulsar]

2024-08-28 Thread via GitHub
dragosvictor commented on PR #23016: URL: https://github.com/apache/pulsar/pull/23016#issuecomment-2316274446 /pulsarbot rerun-failure-checks -- 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 s

Re: [PR] [feat][misc] PIP-264: Add OpenTelemetry authentication and token metrics [pulsar]

2024-08-28 Thread via GitHub
dragosvictor commented on code in PR #23016: URL: https://github.com/apache/pulsar/pull/23016#discussion_r1735090699 ## pulsar-broker-common/src/main/java/org/apache/pulsar/broker/authentication/metrics/AuthenticationMetricsToken.java: ## @@ -0,0 +1,97 @@ +/* + * Licensed to the

Re: [PR] [feat][broker] PIP-264: Add replication subscription stats [pulsar]

2024-08-28 Thread via GitHub
lhotari commented on PR #23026: URL: https://github.com/apache/pulsar/pull/23026#issuecomment-2315949904 I'll close and re-open to get a fresh run that runs with latest changes from master branch. -- This is an automated message from the Apache Git Service. To respond to the message, plea

Re: [PR] [feat][broker] PIP-264: Add replication subscription stats [pulsar]

2024-08-28 Thread via GitHub
lhotari closed pull request #23026: [feat][broker] PIP-264: Add replication subscription stats URL: https://github.com/apache/pulsar/pull/23026 -- 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 sp

Re: [PR] [feat][misc] PIP-264: Add OpenTelemetry authentication and token metrics [pulsar]

2024-08-28 Thread via GitHub
dragosvictor commented on code in PR #23016: URL: https://github.com/apache/pulsar/pull/23016#discussion_r1735037869 ## pulsar-broker/src/test/java/org/apache/pulsar/broker/stats/PrometheusMetricsTest.java: ## @@ -1633,27 +1637,19 @@ public String getCommandData() { Met

Re: [PR] [feat][misc] PIP-264: Add OpenTelemetry authentication and token metrics [pulsar]

2024-08-28 Thread via GitHub
heesung-sn commented on code in PR #23016: URL: https://github.com/apache/pulsar/pull/23016#discussion_r1735019724 ## pulsar-broker/src/test/java/org/apache/pulsar/broker/stats/PrometheusMetricsTest.java: ## @@ -1633,27 +1637,19 @@ public String getCommandData() { Metri

Re: [PR] [improve][broker] Add limits for Key_Shared Subscription look ahead in dispatching [pulsar]

2024-08-28 Thread via GitHub
lhotari commented on code in PR #23231: URL: https://github.com/apache/pulsar/pull/23231#discussion_r1734810618 ## pulsar-broker/src/main/java/org/apache/pulsar/broker/service/persistent/PersistentStickyKeyDispatcherMultipleConsumers.java: ## @@ -436,36 +370,159 @@ protected syn

[PR] [Issue 1272][connection] Attempt to avoid deadlock during reconnection [pulsar-client-go]

2024-08-28 Thread via GitHub
Gilthoniel opened a new pull request, #1273: URL: https://github.com/apache/pulsar-client-go/pull/1273 Fixes #1272 ### Motivation Producers and consumers register themselves to the connection to be notified when it gets closed. Even though the callback push the events in a

[I] Deadlock in connection pool [pulsar-client-go]

2024-08-28 Thread via GitHub
Gilthoniel opened a new issue, #1272: URL: https://github.com/apache/pulsar-client-go/issues/1272 Expected behavior The client should properly handle a cluster that is not ready yet and retry until it gets healthy again. Actual behavior When the client is attem

(pulsar) branch master updated: [fix][broker] Fix thread unsafe access on the bundle range cache for load manager (#23217)

2024-08-28 Thread xyz
This is an automated email from the ASF dual-hosted git repository. xyz 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 325c6a58d53 [fix][broker] Fix thread unsafe access

Re: [PR] [fix][broker] Fix thread unsafe access on the bundle range cache for load manager [pulsar]

2024-08-28 Thread via GitHub
BewareMyPower merged PR #23217: URL: https://github.com/apache/pulsar/pull/23217 -- 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: [PR] [improve][admin] PIP-369 Introduce `unload` flag in `ns-isolation-policy set` call [pulsar]

2024-08-28 Thread via GitHub
grssam commented on PR #23120: URL: https://github.com/apache/pulsar/pull/23120#issuecomment-2315051417 /pulsarbot rerun-failure-checks -- 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 specifi

Re: [D] How to set up Broker config and other configs like bookie etc [pulsar]

2024-08-28 Thread via GitHub
GitHub user Khemendra-Bhardwaj added a comment to the discussion: How to set up Broker config and other configs like bookie etc > > Should I add the key : > > PULSAR_PREFIX_loadBalancerSheddingEnabled= true > > to charts/pulsar/templates/broker-configmap.yaml in pulsar helm repo ? > > No. For

Re: [PR] [fix][broker] Fix thread unsafe access on the bundle range cache for load manager [pulsar]

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

Re: [PR] [improve][broker] Reschedule reads with increasing backoff when no messages are dispatched [pulsar]

2024-08-28 Thread via GitHub
lhotari commented on code in PR #23226: URL: https://github.com/apache/pulsar/pull/23226#discussion_r1734462153 ## pulsar-broker/src/main/java/org/apache/pulsar/broker/service/persistent/PersistentDispatcherMultipleConsumers.java: ## @@ -671,19 +682,28 @@ public final synchroniz

Re: [PR] [improve][broker] Reschedule reads with increasing backoff when no messages are dispatched [pulsar]

2024-08-28 Thread via GitHub
equanz commented on code in PR #23226: URL: https://github.com/apache/pulsar/pull/23226#discussion_r1734460405 ## pulsar-broker/src/main/java/org/apache/pulsar/broker/service/persistent/PersistentDispatcherMultipleConsumers.java: ## @@ -671,19 +682,28 @@ public final synchronize

Re: [PR] [improve][admin] PIP-369 Introduce `unload` flag in `ns-isolation-policy set` call [pulsar]

2024-08-28 Thread via GitHub
grssam commented on PR #23120: URL: https://github.com/apache/pulsar/pull/23120#issuecomment-2314996386 /pulsarbot rerun-failure-checks -- 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 specifi

Re: [PR] [improve][broker] Reschedule reads with increasing backoff when no messages are dispatched [pulsar]

2024-08-28 Thread via GitHub
lhotari commented on code in PR #23226: URL: https://github.com/apache/pulsar/pull/23226#discussion_r1734451910 ## pulsar-broker/src/main/java/org/apache/pulsar/broker/service/persistent/PersistentDispatcherMultipleConsumers.java: ## @@ -671,19 +682,28 @@ public final synchroniz

svn commit: r71134 [1/2] - in /dev/pulsar/pulsar-client-cpp/pulsar-client-cpp-3.6.0-candidate-1: ./ apk-arm64/ apk-arm64/aarch64/ apk-x86_64/ apk-x86_64/x86_64/ deb-arm64/ deb-x86_64/ rpm-arm64/ rpm-a

2024-08-28 Thread baodi
Author: baodi Date: Wed Aug 28 10:47:05 2024 New Revision: 71134 Log: Staging artifacts and signature for Pulsar Client C++ release 3.6.0 Added: dev/pulsar/pulsar-client-cpp/pulsar-client-cpp-3.6.0-candidate-1/ dev/pulsar/pulsar-client-cpp/pulsar-client-cpp-3.6.0-candidate-1/apache-pulsa

svn commit: r71134 [2/2] - in /dev/pulsar/pulsar-client-cpp/pulsar-client-cpp-3.6.0-candidate-1: ./ apk-arm64/ apk-arm64/aarch64/ apk-x86_64/ apk-x86_64/x86_64/ deb-arm64/ deb-x86_64/ rpm-arm64/ rpm-a

2024-08-28 Thread baodi
Propchange: dev/pulsar/pulsar-client-cpp/pulsar-client-cpp-3.6.0-candidate-1/rpm-x86_64/x86_64/repodata/47be5a8a29cee6281e1b08265602c2382729e8bfe163643a443f14404fccd8fc-filelists.sqlite.bz2 -- svn:mime-type = applicati

Re: [PR] [improve][admin] PIP-369 Introduce `unload` flag in `ns-isolation-policy set` call [pulsar]

2024-08-28 Thread via GitHub
lhotari commented on PR #23120: URL: https://github.com/apache/pulsar/pull/23120#issuecomment-2314969340 > Not able to rerun the failed CI pipeline, but all tests passed in my repo - https://github.com/grssam/pulsar/pull/1 and the new tests that I added are part of "Broker Group 3" only.

Re: [PR] [improve][broker] Reschedule reads with increasing backoff when no messages are dispatched [pulsar]

2024-08-28 Thread via GitHub
equanz commented on code in PR #23226: URL: https://github.com/apache/pulsar/pull/23226#discussion_r1734436237 ## pulsar-broker/src/main/java/org/apache/pulsar/broker/service/persistent/PersistentDispatcherMultipleConsumers.java: ## @@ -671,19 +682,28 @@ public final synchronize

(pulsar) branch branch-3.3 updated: [fix] StatsOutputStream: add string write function (#308) (#23227)

2024-08-28 Thread lhotari
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 df213912b97 [fix] StatsOutputStream: ad

(pulsar) branch branch-3.0 updated: [fix] StatsOutputStream: add string write function (#308) (#23227)

2024-08-28 Thread lhotari
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 4e460c80515 [fix] StatsOutputStream: ad

(pulsar) branch branch-2.10 updated: [fix][meta] Fix close borrowed executor (#19761)

2024-08-28 Thread zixuan
This is an automated email from the ASF dual-hosted git repository. zixuan pushed a commit to branch branch-2.10 in repository https://gitbox.apache.org/repos/asf/pulsar.git The following commit(s) were added to refs/heads/branch-2.10 by this push: new 5790e3bd8df [fix][meta] Fix close borr

(pulsar-client-cpp) branch branch-3.6 created (now 8df0acd)

2024-08-28 Thread baodi
This is an automated email from the ASF dual-hosted git repository. baodi pushed a change to branch branch-3.6 in repository https://gitbox.apache.org/repos/asf/pulsar-client-cpp.git at 8df0acd Release 3.6.0 This branch includes the following new commits: new 8df0acd Release 3.6.0

(pulsar-client-cpp) annotated tag v3.6.0-candidate-1 updated (8df0acd -> b6172a6)

2024-08-28 Thread baodi
This is an automated email from the ASF dual-hosted git repository. baodi pushed a change to annotated tag v3.6.0-candidate-1 in repository https://gitbox.apache.org/repos/asf/pulsar-client-cpp.git *** WARNING: tag v3.6.0-candidate-1 was modified! *** from 8df0acd (commit) to b6172a6

(pulsar-client-cpp) 01/01: Release 3.6.0

2024-08-28 Thread baodi
This is an automated email from the ASF dual-hosted git repository. baodi pushed a commit to branch branch-3.6 in repository https://gitbox.apache.org/repos/asf/pulsar-client-cpp.git commit 8df0acd4e2d00fd9772b8773f3cdbcbf517a5912 Author: Baodi Shi AuthorDate: Wed Aug 28 16:17:04 2024 +0800

Re: [PR] [improve][admin] PIP-369 Introduce `unload` flag in `ns-isolation-policy set` call [pulsar]

2024-08-28 Thread via GitHub
grssam commented on PR #23120: URL: https://github.com/apache/pulsar/pull/23120#issuecomment-2314595332 Not able to rerun the failed CI pipeline, but all tests passed in my repo - https://github.com/grssam/pulsar/pull/1 and the new tests that I added are part of "Broker Group 3" only. --