[GitHub] [pulsar] codelipenghui commented on issue #7455: Key_Shared consumers with different subscriptions get messages out-of-order in 2.6.0.

codelipenghui commented on issue #7455: URL: https://github.com/apache/pulsar/issues/7455#issuecomment-657389671 > Regarding the broker dump, I don't know what you mean/need. Can you clarify ? the broker heap dump, I want to check some state of key_shared subscription. ---

[GitHub] [pulsar] feeblefakie edited a comment on issue #7455: Key_Shared consumers with different subscriptions get messages out-of-order in 2.6.0.

feeblefakie edited a comment on issue #7455: URL: https://github.com/apache/pulsar/issues/7455#issuecomment-657376872 @codelipenghui I just re-executed it . Here are the logs. [sub1.txt](https://github.com/apache/pulsar/files/4910870/sub1.txt) [sub2.txt](https://github.com/apache/pulsa

[GitHub] [pulsar] feeblefakie commented on issue #7455: Key_Shared consumers with different subscriptions get messages out-of-order in 2.6.0.

feeblefakie commented on issue #7455: URL: https://github.com/apache/pulsar/issues/7455#issuecomment-657376872 @codelipenghui I just re-executed it . Here are the logs. [sub1.txt](https://github.com/apache/pulsar/files/4910870/sub1.txt) [sub2.txt](https://github.com/apache/pulsar/files

[GitHub] [pulsar-client-go] shohi opened a new pull request #323: add Logger field to ClientOptions

shohi opened a new pull request #323: URL: https://github.com/apache/pulsar-client-go/pull/323 ### Motivation enable users to configure the logger used by the client, currently only support logrus.Logger. If no logger is provided, the default `logrus.StandardLogger()` will be used. This

[GitHub] [pulsar-client-go] wolfstudy commented on pull request #314: [Issue 52]Add interceptor

wolfstudy commented on pull request #314: URL: https://github.com/apache/pulsar-client-go/pull/314#issuecomment-657307348 @snowcrumble Can you merge the master code and fix conflict? This is an automated message from the Apa

[GitHub] [pulsar] codelipenghui commented on issue #7481: Default value and in-line doc for bookkeeper config: openLedgerRereplicationGracePeriod is incorrect

codelipenghui commented on issue #7481: URL: https://github.com/apache/pulsar/issues/7481#issuecomment-657306782 @anvinjain Thanks for the feedback, are you interested in pushing a fix for it? This is an automated message fr

[GitHub] [pulsar] codelipenghui commented on pull request #7448: make AsyncHttpConnector.delayer thread daemon

codelipenghui commented on pull request #7448: URL: https://github.com/apache/pulsar/pull/7448#issuecomment-657306109 /pulsarbot run-failure-checks This is an automated message from the Apache Git Service. To respond to the m

[GitHub] [pulsar] codelipenghui commented on pull request #7515: Update Jersey to 2.31

codelipenghui commented on pull request #7515: URL: https://github.com/apache/pulsar/pull/7515#issuecomment-657300461 /pulsarbot run-failure-checks This is an automated message from the Apache Git Service. To respond to the m

[GitHub] [pulsar] srkukarni opened a new pull request #7520: Rejigger contract between LeaderService and rest of components

srkukarni opened a new pull request #7520: URL: https://github.com/apache/pulsar/pull/7520 *(If this PR fixes a github issue, please add `Fixes #`.)* Fixes # *(or if this PR is one task of a github issue, please add `Master Issue: #` to link to the master issue.)*

[GitHub] [pulsar] srkukarni merged pull request #7493: Add BatchPushSource interface

srkukarni merged pull request #7493: URL: https://github.com/apache/pulsar/pull/7493 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

[pulsar] branch master updated: Add BatchPushSource interface (#7493)

This is an automated email from the ASF dual-hosted git repository. sanjeevrk 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 c94067d Add BatchPushSource interface (#7493

[GitHub] [pulsar] jerrypeng commented on a change in pull request #7509: Fix: Race condition in updateFunctionOnLeader

jerrypeng commented on a change in pull request #7509: URL: https://github.com/apache/pulsar/pull/7509#discussion_r453341133 ## File path: pulsar-functions/worker/src/main/java/org/apache/pulsar/functions/worker/FunctionMetaDataManager.java ## @@ -199,44 +203,49 @@ public sync

[GitHub] [pulsar] jerrypeng commented on a change in pull request #7509: Fix: Race condition in updateFunctionOnLeader

jerrypeng commented on a change in pull request #7509: URL: https://github.com/apache/pulsar/pull/7509#discussion_r453341001 ## File path: pulsar-functions/worker/src/main/java/org/apache/pulsar/functions/worker/rest/api/FunctionsImpl.java ## @@ -686,10 +686,33 @@ public void

[GitHub] [pulsar] srkukarni commented on a change in pull request #7509: Fix: Race condition in updateFunctionOnLeader

srkukarni commented on a change in pull request #7509: URL: https://github.com/apache/pulsar/pull/7509#discussion_r453337435 ## File path: pulsar-functions/worker/src/main/java/org/apache/pulsar/functions/worker/rest/api/FunctionsImpl.java ## @@ -686,10 +686,33 @@ public void

[GitHub] [pulsar] srkukarni commented on a change in pull request #7509: Fix: Race condition in updateFunctionOnLeader

srkukarni commented on a change in pull request #7509: URL: https://github.com/apache/pulsar/pull/7509#discussion_r453336440 ## File path: pulsar-functions/worker/src/main/java/org/apache/pulsar/functions/worker/FunctionMetaDataManager.java ## @@ -199,44 +203,49 @@ public sync

[GitHub] [pulsar] merlimat opened a new pull request #7519: Update Jackson to 2.11.1 and ensure all dependencies are pinned

merlimat opened a new pull request #7519: URL: https://github.com/apache/pulsar/pull/7519 ### Motivation There are several CVEs opened on earlier versions of Jackson, updating to latest stable. Additionally, we are not pinning the version on all the transitive dependencies an

[GitHub] [pulsar] merlimat commented on pull request #7499: [pulsar-broker] Broker handle back-pressure with max-pending message across topics to avoid OOM

merlimat commented on pull request #7499: URL: https://github.com/apache/pulsar/pull/7499#issuecomment-657232274 > don't want to restrict throughput per thread and that requires user to create multiple connections t @rdhabalia It does not impact the throughput once you have a minimum

[GitHub] [pulsar] 315157973 opened a new pull request #7518: Support partitioned topics in the Reader

315157973 opened a new pull request #7518: URL: https://github.com/apache/pulsar/pull/7518 Fixes # *(or if this PR is one task of a github issue, please add `Master Issue: #` to link to the master issue.)* Master Issue: #7265 ### Motivation Support partitione

[GitHub] [pulsar] kezhuw opened a new issue #7517: Conflict namespace bundle ownership after unloading and connected zookeeper server disconnected

kezhuw opened a new issue #7517: URL: https://github.com/apache/pulsar/issues/7517 **Describe the bug** `OwnedBundle.handleUnloadRequest` re-active unloading namespace bundle after fail to remove its ownership from zookeeper. It is possible that the ownership was successfully removed, b

[GitHub] [pulsar] Shoothzj closed issue #7452: Key-shared performance question

Shoothzj closed issue #7452: URL: https://github.com/apache/pulsar/issues/7452 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