[GitHub] [pulsar] wolfstudy opened a new pull request #11336: Upgrade the go client version to 0.5.0

wolfstudy opened a new pull request #11336: URL: https://github.com/apache/pulsar/pull/11336 Signed-off-by: xiaolongran ### Motivation Upgrade the go client version to 0.5.0 -- This is an automated message from the Apache Git Service. To respond to the m

[GitHub] [pulsar] wolfstudy commented on pull request #11335: Add docs about how to use stateful functions in pulsar

wolfstudy commented on pull request #11335: URL: https://github.com/apache/pulsar/pull/11335#issuecomment-881218705 ping @Anonymitaet @Jennifer88huang PTAL the docs. -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use th

[pulsar] branch master updated (52199b2 -> bea3f66)

This is an automated email from the ASF dual-hosted git repository. rxl pushed a change to branch master in repository https://gitbox.apache.org/repos/asf/pulsar.git. from 52199b2 [DOCS] function worker docs enhancement (#11311) add bea3f66 set subscription name for go function runtim

[GitHub] [pulsar] wolfstudy commented on pull request #11332: [function] set subscription name for go function runtime

wolfstudy commented on pull request #11332: URL: https://github.com/apache/pulsar/pull/11332#issuecomment-881217588 > Thanks for your contribution. For this PR, do we need to update docs? > > (The [PR template contains info about doc](https://github.com/apache/pulsar/blob/master/.git

[GitHub] [pulsar] wolfstudy merged pull request #11332: [function] set subscription name for go function runtime

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

[GitHub] [pulsar] wolfstudy closed issue #11307: [go function] Not using the provided `subscriptionName` in the config to read from pulsar cluster

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

[GitHub] [pulsar] wolfstudy opened a new pull request #11335: Add docs about how to use stateful functions in pulsar

wolfstudy opened a new pull request #11335: URL: https://github.com/apache/pulsar/pull/11335 Signed-off-by: xiaolongran ### Motivation Add docs about how to use stateful functions in pulsar -- This is an automated message from the Apache Git Service. To resp

[GitHub] [pulsar] 315157973 commented on a change in pull request #11333: Add TransactionEnable in Namespace

315157973 commented on a change in pull request #11333: URL: https://github.com/apache/pulsar/pull/11333#discussion_r670967460 ## File path: pulsar-broker/src/main/java/org/apache/pulsar/broker/service/persistent/PersistentSubscription.java ## @@ -140,11 +143,21 @@ public Pers

[GitHub] [pulsar] Anonymitaet commented on pull request #11323: [C++] Use same regex code at ZTSClient

Anonymitaet commented on pull request #11323: URL: https://github.com/apache/pulsar/pull/11323#issuecomment-881177831 @equanz many thanks! -- 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 spe

[GitHub] [pulsar] littleorca opened a new issue #11334: Strange behavior of open cursor with initial position

littleorca opened a new issue #11334: URL: https://github.com/apache/pulsar/issues/11334 v2.8.0, managed-ledger: When using ManagedLedger.openCursor with InitialPosition, for the first time (creation), it seems that the markDeletePosition will be persisted using the LAC position at

[GitHub] [pulsar] mnit016 commented on issue #11070: Zookeeper in 3 node Kubernetes cluster does not pass heath check in 2.8.0

mnit016 commented on issue #11070: URL: https://github.com/apache/pulsar/issues/11070#issuecomment-881169710 I've faced the same issue here when upgrade to 2.8, is any update? -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub a

[GitHub] [pulsar] wangjialing218 commented on pull request #11325: support broker level dispatch rate limiter

wangjialing218 commented on pull request #11325: URL: https://github.com/apache/pulsar/pull/11325#issuecomment-881159803 /pulsarbot run-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 g

[GitHub] [pulsar] wangjialing218 commented on pull request #10973: [Elasticsearch-sink] support multi Elasticsearch hosts

wangjialing218 commented on pull request #10973: URL: https://github.com/apache/pulsar/pull/10973#issuecomment-881135615 /pulsarbot run-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 g

[GitHub] [pulsar] liangyepianzhou opened a new pull request #11333: Add TransactionEnable in Namespace

liangyepianzhou opened a new pull request #11333: URL: https://github.com/apache/pulsar/pull/11333 Add TransactionEnable in Namespace. There are some problems in namespaceTest and it is being debugged. Submit after debugging. -- This is an automated message from the Apache Git Service. T

[GitHub] [pulsar] freeznet commented on pull request #11332: [function] set subscription name for go function runtime

freeznet commented on pull request #11332: URL: https://github.com/apache/pulsar/pull/11332#issuecomment-881120606 /pulsarbot run-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 t

[GitHub] [pulsar] equanz commented on pull request #11323: [C++] Use same regex code at ZTSClient

equanz commented on pull request #11323: URL: https://github.com/apache/pulsar/pull/11323#issuecomment-881107139 @Anonymitaet > (The PR template contains info about doc, which helps others know more about the changes. Can you provide doc info in future PR descriptions? Thanks) I

[GitHub] [pulsar] dlg99 commented on pull request #11154: Fixing Debezium integration tests

dlg99 commented on pull request #11154: URL: https://github.com/apache/pulsar/pull/11154#issuecomment-881104990 tests do pass if I create a new pulsar client in the PulsarOffsetBackingStore's ctor instead of the one passed there (I hardcoded the url in the test). There is still some

[GitHub] [pulsar] Anonymitaet commented on pull request #11317: [pulsar-doc] Document pulsar-kafka adapter encryption support

Anonymitaet commented on pull request #11317: URL: https://github.com/apache/pulsar/pull/11317#issuecomment-881095024 @timmyyuan could you please help review this PR from the technical perspective? Thanks -- This is an automated message from the Apache Git Service. To respond to the mess

[GitHub] [pulsar] Anonymitaet commented on pull request #11322: Pulsar IO: allow Sinks to use native AVRO and JSON

Anonymitaet commented on pull request #11322: URL: https://github.com/apache/pulsar/pull/11322#issuecomment-881094634 Thanks for your contribution. For this PR, do we need to update docs? (The [PR template contains info about doc](https://github.com/apache/pulsar/blob/master/.github/

[GitHub] [pulsar] Anonymitaet commented on pull request #11323: [C++] Use same regex code at ZTSClient

Anonymitaet commented on pull request #11323: URL: https://github.com/apache/pulsar/pull/11323#issuecomment-881094369 Thanks for your contribution. For this PR, do we need to update docs? (The [PR template contains info about doc](https://github.com/apache/pulsar/blob/master/.github/

[GitHub] [pulsar] Anonymitaet commented on pull request #11325: support broker level dispatch rate limiter

Anonymitaet commented on pull request #11325: URL: https://github.com/apache/pulsar/pull/11325#issuecomment-881094239 Thanks for your contribution. The [PR template contains info about doc](https://github.com/apache/pulsar/blob/master/.github/PULL_REQUEST_TEMPLATE.md#documentation),

[GitHub] [pulsar] Anonymitaet commented on a change in pull request #11325: support broker level dispatch rate limiter

Anonymitaet commented on a change in pull request #11325: URL: https://github.com/apache/pulsar/pull/11325#discussion_r670887824 ## File path: pulsar-broker/src/test/java/org/apache/pulsar/client/api/SubscriptionMessageDispatchThrottlingTest.java ## @@ -310,6 +310,102 @@ publi

[GitHub] [pulsar] Anonymitaet commented on pull request #11331: [PIP-82] [pulsar-broker] updates to resource-group stats:

Anonymitaet commented on pull request #11331: URL: https://github.com/apache/pulsar/pull/11331#issuecomment-881092835 Thanks for providing info about docs! -- 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

[GitHub] [pulsar] Anonymitaet edited a comment on pull request #11332: [function] set subscription name for go function runtime

Anonymitaet edited a comment on pull request #11332: URL: https://github.com/apache/pulsar/pull/11332#issuecomment-881090938 Thanks for your contribution. For this PR, do we need to update docs? (The [PR template contains info about doc](https://github.com/apache/pulsar/blob/master/

[GitHub] [pulsar] Anonymitaet edited a comment on pull request #11332: [function] set subscription name for go function runtime

Anonymitaet edited a comment on pull request #11332: URL: https://github.com/apache/pulsar/pull/11332#issuecomment-881090938 Thanks for your contribution. For this PR, do we need to update docs? (The PR template contains info about doc, which helps others know more about the changes

[GitHub] [pulsar] Anonymitaet commented on pull request #11332: [function] set subscription name for go function runtime

Anonymitaet commented on pull request #11332: URL: https://github.com/apache/pulsar/pull/11332#issuecomment-881090938 Thanks for your contribution. For this PR, do we need to update docs? (The PR template contains info about doc, which helps others know more about the changes. Can y

[pulsar] branch master updated: [DOCS] function worker docs enhancement (#11311)

This is an automated email from the ASF dual-hosted git repository. liuyu 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 52199b2 [DOCS] function worker docs enhancement

[GitHub] [pulsar] Anonymitaet merged pull request #11311: [DOCS] function worker docs enhancement

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

[pulsar] branch master updated: Add annotations for ClientConfigurationData (#11258)

This is an automated email from the ASF dual-hosted git repository. liuyu 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 c821a28 Add annotations for ClientConfigurationD

[GitHub] [pulsar] Anonymitaet merged pull request #11258: Add annotations for ClientConfigurationData

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

[GitHub] [pulsar] kaushik-develop commented on pull request #11331: [PIP-82] [pulsar-broker] updates to resource-group stats:

kaushik-develop commented on pull request #11331: URL: https://github.com/apache/pulsar/pull/11331#issuecomment-881085318 /pulsarbot run-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

[GitHub] [pulsar] hrsakai commented on pull request #11216: [Websocket] Support cumulative acknowledge for Pulsar Websocket consumer.

hrsakai commented on pull request #11216: URL: https://github.com/apache/pulsar/pull/11216#issuecomment-881075664 If not pull mode, cumulative acknowledge does not seem to work well for me. * If messages are produced by java client or other clients, ws proxy can't calculate msg backlog

[GitHub] [pulsar] kaushik-develop commented on pull request #11331: [PIP-82] [pulsar-broker] updates to resource-group stats:

kaushik-develop commented on pull request #11331: URL: https://github.com/apache/pulsar/pull/11331#issuecomment-881049502 /pulsarbot run-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

[GitHub] [pulsar] nlu90 commented on a change in pull request #11263: Enhanced ElasticSearch Sink (TLS, Auth, KeyValue Schema, INSERT/UPDATE/DELETE, "_id" management, multi index support)

nlu90 commented on a change in pull request #11263: URL: https://github.com/apache/pulsar/pull/11263#discussion_r670808134 ## File path: pulsar-io/elastic-search/src/main/java/org/apache/pulsar/io/elasticsearch/JsonConverter.java ## @@ -0,0 +1,204 @@ +/** Review comment:

[GitHub] [pulsar] dlg99 commented on pull request #11154: Fixing Debezium integration tests

dlg99 commented on pull request #11154: URL: https://github.com/apache/pulsar/pull/11154#issuecomment-881012367 @nlu90 @eolivelli situation with this PR so far: I rebased it on latest master and "CI - Integration - Pulsar-IO Sinks and Sources" failed. Running testDebeziumMySqlSourceJs

[GitHub] [pulsar] nlu90 commented on a change in pull request #10973: [Elasticsearch-sink] support multi Elasticsearch hosts

nlu90 commented on a change in pull request #10973: URL: https://github.com/apache/pulsar/pull/10973#discussion_r670802722 ## File path: pulsar-io/elastic-search/src/main/java/org/apache/pulsar/io/elasticsearch/ElasticSearchSink.java ## @@ -139,11 +137,23 @@ private Credential

[GitHub] [pulsar] kaushik-develop commented on pull request #11331: [PIP-82] [pulsar-broker] updates to resource-group stats:

kaushik-develop commented on pull request #11331: URL: https://github.com/apache/pulsar/pull/11331#issuecomment-88130 /pulsarbot run-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

[GitHub] [pulsar] nlu90 opened a new pull request #11332: [function] set subscription name for go function runtime

nlu90 opened a new pull request #11332: URL: https://github.com/apache/pulsar/pull/11332 Fixes #11307 ### Motivation Function Go runtime should use the subscription name provided to consume from pulsar instead of ignoring it and use the default one. ### Modifications

[GitHub] [pulsar] nlu90 commented on a change in pull request #11322: Pulsar IO: allow Sinks to use native AVRO and JSON

nlu90 commented on a change in pull request #11322: URL: https://github.com/apache/pulsar/pull/11322#discussion_r670737934 ## File path: pulsar-functions/runtime-all/src/test/java/org/apache/pulsar/functions/instance/JavaInstanceDepsTest.java ## @@ -60,11 +60,14 @@ public void

[GitHub] [pulsar] kaushik-develop opened a new pull request #11331: [PIP-82] [pulsar-broker] updates to resource-group stats:

kaushik-develop opened a new pull request #11331: URL: https://github.com/apache/pulsar/pull/11331 * use the new (get*) APIs to pull local usage stats from the broker service * use both directions (publish/dispatch) * workaround for regression in subscribe() (see https://github.

[GitHub] [pulsar] dipinhora commented on issue #11315: How to retry send message after send fail at async mode?

dipinhora commented on issue #11315: URL: https://github.com/apache/pulsar/issues/11315#issuecomment-880928695 i'm running into this issue also.. (note: i'm new to pulsar so it is possible i'm missing something) i'm trying to figure out how to handle/retry `async send` failures (`ti

[pulsar] branch master updated: [PIP-82] [pulsar-broker] Add publish ratelimiter to resource group (#11184)

This is an automated email from the ASF dual-hosted git repository. jerrypeng 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 263a90b [PIP-82] [pulsar-broker] Add publish

[GitHub] [pulsar] jerrypeng merged pull request #11184: [PIP-82] [pulsar-broker] Add publish ratelimiter to resource group

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

[GitHub] [pulsar] merlimat commented on a change in pull request #11330: PIP-45: Converted ResourceQuotaCache

merlimat commented on a change in pull request #11330: URL: https://github.com/apache/pulsar/pull/11330#discussion_r670661872 ## File path: pulsar-client-admin-api/src/main/java/org/apache/pulsar/common/policies/data/ResourceQuota.java ## @@ -18,11 +18,14 @@ */ package org.

[GitHub] [pulsar] merlimat commented on a change in pull request #11330: PIP-45: Converted ResourceQuotaCache

merlimat commented on a change in pull request #11330: URL: https://github.com/apache/pulsar/pull/11330#discussion_r670661583 ## File path: pulsar-broker/src/main/java/org/apache/pulsar/broker/admin/impl/ResourceQuotasBase.java ## @@ -87,13 +84,9 @@ protected void internalSet

[GitHub] [pulsar] bharanic-dev commented on pull request #11184: [PIP-82] [pulsar-broker] Add publish ratelimiter to resource group

bharanic-dev commented on pull request #11184: URL: https://github.com/apache/pulsar/pull/11184#issuecomment-880803733 /pulsarbot run-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

[GitHub] [pulsar] moliqingwa commented on issue #5175: Namespace missing local cluster name in clusters list

moliqingwa commented on issue #5175: URL: https://github.com/apache/pulsar/issues/5175#issuecomment-880764017 > Any one have solution for that Solved. Run the following command `bin/pulsar-admin clusters list`, you'll see these cluster names are not includes the local cluster whi

[GitHub] [pulsar] moliqingwa removed a comment on issue #5175: Namespace missing local cluster name in clusters list

moliqingwa removed a comment on issue #5175: URL: https://github.com/apache/pulsar/issues/5175#issuecomment-880710087 Same issue. -- 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 com

[GitHub] [pulsar] 315157973 commented on a change in pull request #11316: When delete a topic, delete the topic policy together.

315157973 commented on a change in pull request #11316: URL: https://github.com/apache/pulsar/pull/11316#discussion_r670527672 ## File path: pulsar-broker/src/main/java/org/apache/pulsar/broker/service/SystemTopicBasedTopicPoliciesService.java ## @@ -302,10 +313,27 @@ private

[GitHub] [pulsar] eolivelli commented on a change in pull request #11330: PIP-45: Converted ResourceQuotaCache

eolivelli commented on a change in pull request #11330: URL: https://github.com/apache/pulsar/pull/11330#discussion_r670523160 ## File path: pulsar-client-admin-api/src/main/java/org/apache/pulsar/common/policies/data/ResourceQuota.java ## @@ -18,11 +18,14 @@ */ package org

[GitHub] [pulsar] 315157973 commented on a change in pull request #11316: When delete a topic, delete the topic policy together.

315157973 commented on a change in pull request #11316: URL: https://github.com/apache/pulsar/pull/11316#discussion_r670523036 ## File path: pulsar-broker/src/main/java/org/apache/pulsar/broker/service/SystemTopicBasedTopicPoliciesService.java ## @@ -302,10 +313,27 @@ private

[GitHub] [pulsar] moliqingwa commented on issue #5175: Namespace missing local cluster name in clusters list

moliqingwa commented on issue #5175: URL: https://github.com/apache/pulsar/issues/5175#issuecomment-880710087 Same issue. -- 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. T

[GitHub] [pulsar] horizonzy commented on a change in pull request #11316: When delete a topic, delete the topic policy together.

horizonzy commented on a change in pull request #11316: URL: https://github.com/apache/pulsar/pull/11316#discussion_r670460107 ## File path: pulsar-broker/src/main/java/org/apache/pulsar/broker/service/SystemTopicBasedTopicPoliciesService.java ## @@ -302,10 +313,27 @@ private

[pulsar] branch master updated (0584628 -> ac8194f)

This is an automated email from the ASF dual-hosted git repository. mmerli pushed a change to branch master in repository https://gitbox.apache.org/repos/asf/pulsar.git. from 0584628 PIP-45: Removed direct ZK access from BrokerService (#11267) add ac8194f Avoid throwing exceptions whe

[GitHub] [pulsar] merlimat merged pull request #11329: [C++] Avoid throwing exceptions when setting socket option

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

[GitHub] [pulsar] 315157973 commented on a change in pull request #11316: When delete a topic, delete the topic policy together.

315157973 commented on a change in pull request #11316: URL: https://github.com/apache/pulsar/pull/11316#discussion_r670452737 ## File path: pulsar-broker/src/main/java/org/apache/pulsar/broker/service/SystemTopicBasedTopicPoliciesService.java ## @@ -302,10 +313,27 @@ private

[GitHub] [pulsar] horizonzy commented on a change in pull request #11316: When delete a topic, delete the topic policy together.

horizonzy commented on a change in pull request #11316: URL: https://github.com/apache/pulsar/pull/11316#discussion_r670445895 ## File path: pulsar-broker/src/main/java/org/apache/pulsar/broker/service/BrokerService.java ## @@ -2580,6 +2581,17 @@ private boolean isSystemTopic(

[GitHub] [pulsar] horizonzy commented on a change in pull request #11316: When delete a topic, delete the topic policy together.

horizonzy commented on a change in pull request #11316: URL: https://github.com/apache/pulsar/pull/11316#discussion_r670445600 ## File path: pulsar-broker/src/test/java/org/apache/pulsar/broker/admin/TopicPoliciesTest.java ## @@ -2395,4 +2395,31 @@ public void testTopicRetent

[GitHub] [pulsar] horizonzy commented on a change in pull request #11316: When delete a topic, delete the topic policy together.

horizonzy commented on a change in pull request #11316: URL: https://github.com/apache/pulsar/pull/11316#discussion_r670440982 ## File path: pulsar-broker/src/main/java/org/apache/pulsar/broker/service/BrokerService.java ## @@ -2580,8 +2582,19 @@ private boolean isSystemTopic(

[GitHub] [pulsar] eolivelli commented on a change in pull request #11316: When delete a topic, delete the topic policy together.

eolivelli commented on a change in pull request #11316: URL: https://github.com/apache/pulsar/pull/11316#discussion_r670431735 ## File path: pulsar-broker/src/main/java/org/apache/pulsar/broker/service/BrokerService.java ## @@ -2580,8 +2582,19 @@ private boolean isSystemTopic(

[GitHub] [pulsar] gaozhangmin commented on issue #11318: NonRecoverableLedgerException No such ledger exists on Metadata Server

gaozhangmin commented on issue #11318: URL: https://github.com/apache/pulsar/issues/11318#issuecomment-880662714 how to reproduce? -- 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 co

[GitHub] [pulsar] codelipenghui commented on pull request #11126: [Transaction] Transaction delete marker monitor.

codelipenghui commented on pull request #11126: URL: https://github.com/apache/pulsar/pull/11126#issuecomment-880657017 @congbobo184 Could you please help update the description of the PR? And add more context about how the root cause is and how the PR can fix the issue, this will make oth

[pulsar] branch master updated (5aee599 -> 0584628)

This is an automated email from the ASF dual-hosted git repository. mmerli pushed a change to branch master in repository https://gitbox.apache.org/repos/asf/pulsar.git. from 5aee599 [broker] Fix issue that message ordering could be broken when redelivering messages on Key_Shared subscript

[GitHub] [pulsar] merlimat opened a new pull request #11330: PIP-45: Converted ResourceQuotaCache

merlimat opened a new pull request #11330: URL: https://github.com/apache/pulsar/pull/11330 ### Motivation Converted ResourceQuotaCache to not use Zookeeper directly -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and

[GitHub] [pulsar] merlimat merged pull request #11267: PIP-45: Removed direct ZK access from BrokerService

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

[GitHub] [pulsar] horizonzy commented on a change in pull request #11316: When delete a topic, delete the topic policy together.

horizonzy commented on a change in pull request #11316: URL: https://github.com/apache/pulsar/pull/11316#discussion_r670402938 ## File path: pulsar-broker/src/main/java/org/apache/pulsar/broker/service/BrokerService.java ## @@ -2580,6 +2581,17 @@ private boolean isSystemTopic(

[GitHub] [pulsar] horizonzy commented on a change in pull request #11316: When delete a topic, delete the topic policy together.

horizonzy commented on a change in pull request #11316: URL: https://github.com/apache/pulsar/pull/11316#discussion_r670400926 ## File path: pulsar-broker/src/main/java/org/apache/pulsar/broker/service/BrokerService.java ## @@ -2580,8 +2582,19 @@ private boolean isSystemTopic(

[GitHub] [pulsar] gaoran10 commented on a change in pull request #11316: When delete a topic, delete the topic policy together.

gaoran10 commented on a change in pull request #11316: URL: https://github.com/apache/pulsar/pull/11316#discussion_r670400100 ## File path: pulsar-broker/src/main/java/org/apache/pulsar/broker/service/BrokerService.java ## @@ -2580,8 +2582,19 @@ private boolean isSystemTopic(S

[GitHub] [pulsar] Anonymitaet commented on pull request #11319: fix required params to set-retention

Anonymitaet commented on pull request #11319: URL: https://github.com/apache/pulsar/pull/11319#issuecomment-880637778 > Could you please help confirm whether other releases also need to be updated? And if yes, could you please help update these docs? Thanks +1 Thanks for your

[GitHub] [pulsar-client-go] wolfstudy commented on issue #565: Send gorutine blocked

wolfstudy commented on issue #565: URL: https://github.com/apache/pulsar-client-go/issues/565#issuecomment-880637444 > Calling Wait() should release the lock right? Yes, When entering the `Wait()` phase, we should try to release the `Lock` so that subsequent gorutine can continue to

[GitHub] [pulsar] codelipenghui commented on a change in pull request #11316: When delete a topic, delete the topic policy together.

codelipenghui commented on a change in pull request #11316: URL: https://github.com/apache/pulsar/pull/11316#discussion_r670389690 ## File path: pulsar-broker/src/test/java/org/apache/pulsar/broker/admin/TopicPoliciesTest.java ## @@ -2395,4 +2395,31 @@ public void testTopicRe

[GitHub] [pulsar] BewareMyPower opened a new pull request #11329: [C++] Avoid throwing exceptions when setting socket option

BewareMyPower opened a new pull request #11329: URL: https://github.com/apache/pulsar/pull/11329 ### Motivation When the Pulsar C++ library was deployed to a Windows server, the program would crash after the connection is connected. Though it works on Windows 10. It's caused by the

[GitHub] [pulsar] urfreespace opened a new pull request #11328: [website][pulsar]: auto generate docs for pulsar subcommand: delete-cluster-metadata

urfreespace opened a new pull request #11328: URL: https://github.com/apache/pulsar/pull/11328 ### Master Issue: #10040 Motivation Support auto generate HTML page for pulsar client cli tool, for example: https://github.com/apache/pulsar/tree/asf-site/content/tools/pulsar-admin

[pulsar] branch master updated (72f7785 -> 5aee599)

This is an automated email from the ASF dual-hosted git repository. penghui pushed a change to branch master in repository https://gitbox.apache.org/repos/asf/pulsar.git. from 72f7785 fix batch size < 0 error when peekmessage (#11301) add 5aee599 [broker] Fix issue that message orderi

[GitHub] [pulsar] urfreespace opened a new pull request #11327: [website][pulsar]: auto generate docs for pulsar subcommand: initialize-cluster-metadata

urfreespace opened a new pull request #11327: URL: https://github.com/apache/pulsar/pull/11327 ### Master Issue: #10040 Motivation Support auto generate HTML page for pulsar client cli tool, for example: https://github.com/apache/pulsar/tree/asf-site/content/tools/pulsar-admin

[GitHub] [pulsar] codelipenghui merged pull request #10762: [broker] Fix issue that message ordering could be broken when redelivering messages on Key_Shared subscription

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

[GitHub] [pulsar] urfreespace opened a new pull request #11326: [website][pulsar]: auto generate docs for pulsar subcommand: functions-worker

urfreespace opened a new pull request #11326: URL: https://github.com/apache/pulsar/pull/11326 ### Master Issue: #10040 Motivation Support auto generate HTML page for pulsar client cli tool, for example: https://github.com/apache/pulsar/tree/asf-site/content/tools/pulsar-admin

[GitHub] [pulsar] equanz commented on pull request #11323: [C++] Use same regex code at ZTSClient

equanz commented on pull request #11323: URL: https://github.com/apache/pulsar/pull/11323#issuecomment-880617963 /pulsarbot run-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

[GitHub] [pulsar] gaozhangmin commented on pull request #10853: [Issue #9488][add admin api getBacklogSize]

gaozhangmin commented on pull request #10853: URL: https://github.com/apache/pulsar/pull/10853#issuecomment-880601705 @MarvinCai Please review this pr since I had changed, Only support a non-partitioned topic or a specific topic partition -- This is an automated message from the Apache

[GitHub] [pulsar] wangjialing218 commented on pull request #11325: support broker level dispatch rate limiter

wangjialing218 commented on pull request #11325: URL: https://github.com/apache/pulsar/pull/11325#issuecomment-880568892 @codelipenghui @315157973 please have a look -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the

[GitHub] [pulsar] wangjialing218 opened a new pull request #11325: support broker level dispatch rate limiter

wangjialing218 opened a new pull request #11325: URL: https://github.com/apache/pulsar/pull/11325 ### Motivation Fixes #7720 Current we support broker level publish rate limiter. This PR will add broker level dispatch rate limiter. ### Modifications Add broker

[GitHub] [pulsar] equanz commented on pull request #11323: [C++] Use same regex code at ZTSClient

equanz commented on pull request #11323: URL: https://github.com/apache/pulsar/pull/11323#issuecomment-880557393 /pulsarbot run-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

[GitHub] [pulsar] wangjialing218 commented on pull request #10973: [Elasticsearch-sink] support multi Elasticsearch hosts

wangjialing218 commented on pull request #10973: URL: https://github.com/apache/pulsar/pull/10973#issuecomment-880523501 /pulsarbot run-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 g

[pulsar] branch master updated (d2d192b -> 72f7785)

This is an automated email from the ASF dual-hosted git repository. xyz pushed a change to branch master in repository https://gitbox.apache.org/repos/asf/pulsar.git. from d2d192b [pulsar-io] pass the pulsar service url to debezium source for history database (#11251) add 72f7785 fix

[GitHub] [pulsar] BewareMyPower merged pull request #11301: Admin Tool: fix batch size < 0 erro when peekmessage

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

[GitHub] [pulsar] BewareMyPower closed issue #11300: peekmessage return wrong result with X-Pulsar-batch-size < 0

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

[GitHub] [pulsar] ca-simone-chiorazzo opened a new issue #11324: Missing python wheel for Mac Os 11.4 for both 2.7.2 and 2.8.0

ca-simone-chiorazzo opened a new issue #11324: URL: https://github.com/apache/pulsar/issues/11324 **Describe the bug** There is no wheel available for Mac OS 11.4 for both the 2.7.2 and 2.8.0 python client versions. It is possible to add them? **To Reproduce** Steps to r

[GitHub] [pulsar] equanz opened a new pull request #11323: [C++] Use same regex code at ZTSClient

equanz opened a new pull request #11323: URL: https://github.com/apache/pulsar/pull/11323 ### Motivation https://github.com/apache/pulsar/pull/9533/files#diff-41a90a5ec7937b5e2151752843621d6acfe8963077dc04c285842a09a4e45ecc causes some degraded behaviors at ZTSClient. 1. when usi

[GitHub] [pulsar] aloyszhang commented on pull request #11301: Admin Tool: fix batch size < 0 erro when peekmessage

aloyszhang commented on pull request #11301: URL: https://github.com/apache/pulsar/pull/11301#issuecomment-880492161 @BewareMyPower PATL -- 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 speci

[GitHub] [pulsar] eolivelli opened a new pull request #11322: Pulsar IO: allow Sinks to use native AVRO and JSON

eolivelli opened a new pull request #11322: URL: https://github.com/apache/pulsar/pull/11322 The Sink should be able to manage the result of GenericRecord.getNativeObject(). In order to do this Apache AVRO must be loaded from the same classloader that is loading Apache Pulsar Runtime.