(pulsar) branch branch-3.3 updated: [fix] Bump io.grpc from 1.56.0 to 1.56.1 (#23276)

2024-09-09 Thread mattisonchao
This is an automated email from the ASF dual-hosted git repository. mattisonchao 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 c26e8392cd6 [fix] Bump io.grpc fro

[PR] [feat][metadata] Bump oxia java version from 0.3.2 to 0.4.5 [pulsar]

2024-09-09 Thread via GitHub
mattisonchao opened a new pull request, #23277: URL: https://github.com/apache/pulsar/pull/23277 ### Motivation Bump oxia java version from 0.3.2 to 0.4.5 ### Modifications - Bump oxia java version from 0.3.2 to 0.4.5 ### Verifying this change - [x] Make s

(pulsar) branch master updated: [fix] Bump io.grpc from 1.56.0 to 1.56.1 (#23276)

2024-09-09 Thread mattisonchao
This is an automated email from the ASF dual-hosted git repository. mattisonchao 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 96fd04b22f8 [fix] Bump io.grpc from 1.56.0

Re: [PR] [fix] Bump io.grpc from 1.56.0 to 1.56.1 [pulsar]

2024-09-09 Thread via GitHub
mattisonchao merged PR #23276: URL: https://github.com/apache/pulsar/pull/23276 -- 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...@puls

Re: [PR] [fix] Bump io.grpc from 1.56.0 to 1.56.1 [pulsar]

2024-09-09 Thread via GitHub
mattisonchao commented on PR #23276: URL: https://github.com/apache/pulsar/pull/23276#issuecomment-2339694346 >Please share the context to others about why this is important for Pulsar. Pulsar is pluggable messaging system. For some plugins that is using GRPC as the RPC framework will

Re: [PR] [fix] Bump io.grpc from 1.56.0 to 1.56.1 [pulsar]

2024-09-09 Thread via GitHub
lhotari commented on PR #23276: URL: https://github.com/apache/pulsar/pull/23276#issuecomment-2339677171 > Bump io.grpc from 1.56.0 to 1.56.1 to address this super important fix. [grpc/grpc-java#10328](https://github.com/grpc/grpc-java/pull/10328) @mattisonchao Please share the contex

[PR] Bump io.grpc from 1.56.0 to 1.56.1 [pulsar]

2024-09-09 Thread via GitHub
mattisonchao opened a new pull request, #23276: URL: https://github.com/apache/pulsar/pull/23276 ### Motivation Bump io.grpc from 1.56.0 to 1.56.1 to address this super important fix. https://github.com/grpc/grpc-java/pull/10328 ### Modifications - Bump io.grpc from 1.56

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

2024-09-09 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 44e665476286 Docs sync done from apache/pulsar

Re: [PR] [fix][client] Fix broker/Client CPU reaching 100% during retriable connection failure [pulsar]

2024-09-09 Thread via GitHub
rdhabalia merged PR #23251: URL: https://github.com/apache/pulsar/pull/23251 -- 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: [I] [Bug] Broker seeing high latency, high CPU and high GC Pauses [pulsar]

2024-09-09 Thread via GitHub
rdhabalia closed issue #23250: [Bug] Broker seeing high latency, high CPU and high GC Pauses URL: https://github.com/apache/pulsar/issues/23250 -- 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

[I] Use pulsar-client-go-test docker to test TestBlueGreenMigrationTestSuite case [pulsar-client-go]

2024-09-09 Thread via GitHub
geniusjoe opened a new issue, #1282: URL: https://github.com/apache/pulsar-client-go/issues/1282 **Is your feature request related to a problem? Please describe.** When I ran `make test`, every test case worked fine except one error from `test_extensible_load_manager` : ``` ✔ Netwo

Re: [PR] RPC framework implemented by the Pulsar client [pulsar-java-contrib]

2024-09-09 Thread via GitHub
Denovo1998 commented on code in PR #6: URL: https://github.com/apache/pulsar-java-contrib/pull/6#discussion_r1750283332 ## pulsar-rpc-contrib/src/main/java/org/apache/pulsar/rpc/contrib/client/PulsarRpcClient.java: ## @@ -0,0 +1,180 @@ +/* + * Licensed under the Apache License,

Re: [PR] RPC framework implemented by the Pulsar client [pulsar-java-contrib]

2024-09-09 Thread via GitHub
Denovo1998 commented on code in PR #6: URL: https://github.com/apache/pulsar-java-contrib/pull/6#discussion_r1750297371 ## pulsar-rpc-contrib/src/main/java/org/apache/pulsar/rpc/contrib/client/ReplyListener.java: ## @@ -0,0 +1,74 @@ +/* + * Licensed under the Apache License, Ver

Re: [PR] RPC framework implemented by the Pulsar client [pulsar-java-contrib]

2024-09-09 Thread via GitHub
Denovo1998 commented on code in PR #6: URL: https://github.com/apache/pulsar-java-contrib/pull/6#discussion_r1750283847 ## pulsar-rpc-contrib/src/main/java/org/apache/pulsar/rpc/contrib/server/RequestListener.java: ## @@ -0,0 +1,88 @@ +/* + * Licensed under the Apache License, V

Re: [PR] RPC framework implemented by the Pulsar client [pulsar-java-contrib]

2024-09-09 Thread via GitHub
Denovo1998 commented on code in PR #6: URL: https://github.com/apache/pulsar-java-contrib/pull/6#discussion_r1750283332 ## pulsar-rpc-contrib/src/main/java/org/apache/pulsar/rpc/contrib/client/PulsarRpcClient.java: ## @@ -0,0 +1,180 @@ +/* + * Licensed under the Apache License,

Re: [PR] RPC framework implemented by the Pulsar client [pulsar-java-contrib]

2024-09-09 Thread via GitHub
Denovo1998 commented on code in PR #6: URL: https://github.com/apache/pulsar-java-contrib/pull/6#discussion_r1750279670 ## pulsar-rpc-contrib/src/test/java/org/apache/pulsar/rpc/contrib/SimpleRpcCallTest.java: ## @@ -0,0 +1,476 @@ +/* + * Licensed under the Apache License, Versi

Re: [PR] [fix][broker] Fix for Broker Restart Failure Due to Incomplete NAR File Extraction in /tmp Directory [pulsar]

2024-09-09 Thread via GitHub
nikhilerigila09 commented on code in PR #23274: URL: https://github.com/apache/pulsar/pull/23274#discussion_r1750129564 ## pulsar-common/src/main/java/org/apache/pulsar/common/nar/NarUnpacker.java: ## @@ -83,22 +83,31 @@ static File doUnpackNar(final File nar, final File baseWo

Re: [PR] [fix][broker] Fix for Broker Restart Failure Due to Incomplete NAR File Extraction in /tmp Directory [pulsar]

2024-09-09 Thread via GitHub
nikhilerigila09 commented on code in PR #23274: URL: https://github.com/apache/pulsar/pull/23274#discussion_r1750129564 ## pulsar-common/src/main/java/org/apache/pulsar/common/nar/NarUnpacker.java: ## @@ -83,22 +83,31 @@ static File doUnpackNar(final File nar, final File baseWo

Re: [PR] [go]: reduce dependency [pulsar-client-go]

2024-09-09 Thread via GitHub
ttys3 commented on PR #819: URL: https://github.com/apache/pulsar-client-go/pull/819#issuecomment-2337878682 > +1 to upgrading the cobra dependency However, I'm not sure if it's a good idea to split pulsar-perf-go to a separate module. In general it's recommended to have a single go module

Re: [I] [Bug] Broker Fails to Restart Due to Incomplete NAR File Extraction in `/tmp` Directory [pulsar]

2024-09-09 Thread via GitHub
lhotari commented on issue #23273: URL: https://github.com/apache/pulsar/issues/23273#issuecomment-2337766524 > * Suggested fix: Implement a mechanism that writes a ".success" file after successful NAR extraction and ensures this file is present before using the directory. An alterna

Re: [D] Key_Shared consumer scale behavior with a partitioned topic [pulsar]

2024-09-09 Thread via GitHub
GitHub user lhotari added a comment to the discussion: Key_Shared consumer scale behavior with a partitioned topic There's yet another aspect of the individual hash tracking. Currently, when new consumers join, all message delivery is blocked for the consumer until the inflight messages that

[I] [Bug] Dispatcher will be closing and reopening when Key_shared consumers have different policies (AUTO_SPLIT/STICKY, allowOutOfOrderDelivery true/false) [pulsar]

2024-09-09 Thread via GitHub
lhotari opened a new issue, #23272: URL: https://github.com/apache/pulsar/issues/23272 ### 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 unsupp

Re: [PR] [fix][broker] fix pulsar-admin topics stats-internal caused a BK client thread a deadlock [pulsar]

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

[I] [Bug] Key_Shared subscription's "recently joined consumer" logic is unnecessary for KeySharedMode.STICKY [pulsar]

2024-09-09 Thread via GitHub
lhotari opened a new issue, #23271: URL: https://github.com/apache/pulsar/issues/23271 ### 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 unsupp

Re: [PR] [improve][broker] Make cluster metadata init command support metadata config path [pulsar]

2024-09-09 Thread via GitHub
lhotari commented on PR #23269: URL: https://github.com/apache/pulsar/pull/23269#issuecomment-2337589985 It seems that this is related to PIP-366 #23033 and should go only in master branch? -- This is an automated message from the Apache Git Service. To respond to the message, please log

Re: [PR] [fix][broker] fix pulsar-admin topics stats-internal caused a BK client thread a deadlock [pulsar]

2024-09-09 Thread via GitHub
poorbarcode commented on code in PR #23258: URL: https://github.com/apache/pulsar/pull/23258#discussion_r1749751058 ## pulsar-broker/src/main/java/org/apache/pulsar/compaction/CompactedTopicImpl.java: ## @@ -304,8 +306,10 @@ static CompletableFuture> readEntries(LedgerHandle lh