[GitHub] [pulsar] eolivelli commented on a change in pull request #11553: Exposing the broker entry metadata to client

2021-08-18 Thread GitBox
eolivelli commented on a change in pull request #11553: URL: https://github.com/apache/pulsar/pull/11553#discussion_r690962783 ## File path: pulsar-broker/src/main/java/org/apache/pulsar/broker/service/PulsarCommandSenderImpl.java ## @@ -243,8 +243,13 @@ public ChannelPromise

[GitHub] [pulsar] eolivelli commented on a change in pull request #11681: [Broker] Support disabling non-TLS service ports

2021-08-18 Thread GitBox
eolivelli commented on a change in pull request #11681: URL: https://github.com/apache/pulsar/pull/11681#discussion_r690968459 ## File path: pulsar-broker/src/main/java/org/apache/pulsar/broker/loadbalance/impl/SimpleLoadManagerImpl.java ## @@ -1122,7 +1122,7 @@ private String

[GitHub] [pulsar] BewareMyPower commented on pull request #11683: failed update partition of topic

2021-08-18 Thread GitBox
BewareMyPower commented on pull request #11683: URL: https://github.com/apache/pulsar/pull/11683#issuecomment-900885644 Please fix the code style. ``` Error: src/main/java/org/apache/pulsar/broker/admin/impl/PersistentTopicsBase.java:[3641,21] (whitespace) WhitespaceAround: 'for

[GitHub] [pulsar] BewareMyPower commented on a change in pull request #11683: failed update partition of topic

2021-08-18 Thread GitBox
BewareMyPower commented on a change in pull request #11683: URL: https://github.com/apache/pulsar/pull/11683#discussion_r690975274 ## File path: pulsar-broker/src/main/java/org/apache/pulsar/broker/admin/impl/PersistentTopicsBase.java ## @@ -3636,6 +3636,15 @@ private Persiste

[GitHub] [pulsar] abhilashmandaliya opened a new pull request #11697: [server] Fixed Casting Error

2021-08-18 Thread GitBox
abhilashmandaliya opened a new pull request #11697: URL: https://github.com/apache/pulsar/pull/11697 Fixed a casting error introduced in #11671. The double value of user-configured backlogQuota in GB is converted to long before converting to bytes. -- This is an automated message from

[GitHub] [pulsar] abhilashmandaliya commented on a change in pull request #11671: [server] Allow broker to start with default backlogquota in bytes

2021-08-18 Thread GitBox
abhilashmandaliya commented on a change in pull request #11671: URL: https://github.com/apache/pulsar/pull/11671#discussion_r690976781 ## File path: pulsar-broker/src/main/java/org/apache/pulsar/broker/service/BacklogQuotaManager.java ## @@ -53,9 +53,10 @@ public Backlo

[GitHub] [pulsar-client-go] beyondyinjl2 opened a new issue #594: kcItem.SetAccess undefined (type keychain.Item has no field or method SetAccess)

2021-08-18 Thread GitBox
beyondyinjl2 opened a new issue #594: URL: https://github.com/apache/pulsar-client-go/issues/594 system: macos big sur11.4 go version go version go1.15.6 darwin/amd64 Run code error: # github.com/99designs/keyring ../../pkg/mod/github.com/99designs/keyring@v1.1.5/keych

[GitHub] [pulsar] BewareMyPower commented on a change in pull request #11683: failed update partition of topic

2021-08-18 Thread GitBox
BewareMyPower commented on a change in pull request #11683: URL: https://github.com/apache/pulsar/pull/11683#discussion_r690988315 ## File path: pulsar-broker/src/main/java/org/apache/pulsar/broker/admin/impl/PersistentTopicsBase.java ## @@ -3636,6 +3637,20 @@ private Persiste

[GitHub] [pulsar] rayliu419 opened a new issue #11698: General questions on Pulsar - leader broker and ZK performance issues.

2021-08-18 Thread GitBox
rayliu419 opened a new issue #11698: URL: https://github.com/apache/pulsar/issues/11698 Hi team, I can't find a template to ask general question so I just post it here, please direct me to the right template/place if I am wrong. 1. Kafka(<2.8) use ZK to do leader broker elec

[GitHub] [pulsar] 315157973 commented on pull request #11691: [Issue 11689][Client] Fixed block forever bug in Consumer.batchReceive

2021-08-18 Thread GitBox
315157973 commented on pull request #11691: URL: https://github.com/apache/pulsar/pull/11691#issuecomment-900911001 The main reason for this to be locked is the following two pieces of logic: `pendingBatchReceiveTask` is run by the timed thread pool of ConsumerBase, and pollNextBatchRece

[GitHub] [pulsar] lhotari commented on pull request #11697: [server] Fixed Casting Error

2021-08-18 Thread GitBox
lhotari commented on pull request #11697: URL: https://github.com/apache/pulsar/pull/11697#issuecomment-900911565 Good catch @abhilashmandaliya -- 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] eolivelli commented on pull request #11697: [server] Fixed Casting Error

2021-08-18 Thread GitBox
eolivelli commented on pull request #11697: URL: https://github.com/apache/pulsar/pull/11697#issuecomment-900912023 @lhotari which kind of test are you requiring ? I am not sure it is worth to add the needed instrumentation to test this change. The rounding error is quite evident

[GitHub] [pulsar] codelipenghui commented on a change in pull request #11553: Exposing the broker entry metadata to client

2021-08-18 Thread GitBox
codelipenghui commented on a change in pull request #11553: URL: https://github.com/apache/pulsar/pull/11553#discussion_r691027666 ## File path: pulsar-broker/src/main/java/org/apache/pulsar/broker/service/PulsarCommandSenderImpl.java ## @@ -243,8 +243,13 @@ public ChannelProm

[GitHub] [pulsar] Anonymitaet commented on a change in pull request #11681: [Broker] Support disabling non-TLS service ports

2021-08-18 Thread GitBox
Anonymitaet commented on a change in pull request #11681: URL: https://github.com/apache/pulsar/pull/11681#discussion_r691044967 ## File path: site2/docs/security-tls-keystore.md ## @@ -131,6 +131,13 @@ brokerClientTlsTrustStorePassword=clientpw NOTE: it is important to rest

[GitHub] [pulsar] marcoguest commented on issue #10734: Pulsar C++ key-shared subscriber runs out of memory for non-persistent topic

2021-08-18 Thread GitBox
marcoguest commented on issue #10734: URL: https://github.com/apache/pulsar/issues/10734#issuecomment-900951071 Thank you @merlimat -- 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

[GitHub] [pulsar] sijia-w opened a new issue #11699: The link for `pulsar-java-tutorial` is broken

2021-08-18 Thread GitBox
sijia-w opened a new issue #11699: URL: https://github.com/apache/pulsar/issues/11699 **Is your enhancement request related to a problem? Please describe.** The links for `pulsar-java-tutorial` and relevant content on page https://pulsar.apache.org/docs/en/deploy-docs/#download-and-prepa

[GitHub] [pulsar] sijia-w commented on pull request #11648: [Doc] [ISSUE 11291] Update Pulsar Dashboard relevant content

2021-08-18 Thread GitBox
sijia-w commented on pull request #11648: URL: https://github.com/apache/pulsar/pull/11648#issuecomment-900969857 @Huanli-Meng A new issue for `pulsar-java-tutorial` can be found #11699. Shall we close this pr if there is nothing else to modify for now? -- This is an automated message fr

[GitHub] [pulsar] gaozhangmin commented on pull request #11683: failed update partition of topic

2021-08-18 Thread GitBox
gaozhangmin commented on pull request #11683: URL: https://github.com/apache/pulsar/pull/11683#issuecomment-900989358 @eolivelli @lhotari PTAL -- 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 th

[GitHub] [pulsar] Huanli-Meng closed issue #11291: [Doc] Remove Pulsar Dashboard contents

2021-08-18 Thread GitBox
Huanli-Meng closed issue #11291: URL: https://github.com/apache/pulsar/issues/11291 -- 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-unsubs

[GitHub] [pulsar] Huanli-Meng merged pull request #11648: [Doc] [ISSUE 11291] Update Pulsar Dashboard relevant content

2021-08-18 Thread GitBox
Huanli-Meng merged pull request #11648: URL: https://github.com/apache/pulsar/pull/11648 -- 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 (5835fd2 -> ca7c70e)

2021-08-18 Thread huanlimeng
This is an automated email from the ASF dual-hosted git repository. huanlimeng pushed a change to branch master in repository https://gitbox.apache.org/repos/asf/pulsar.git. from 5835fd2 KeyShared dispatcher on non-persistent topics was not respecting consumer flow-control (#11692) ad

[GitHub] [pulsar] lhotari commented on pull request #11697: [server] Fixed Casting Error

2021-08-18 Thread GitBox
lhotari commented on pull request #11697: URL: https://github.com/apache/pulsar/pull/11697#issuecomment-901002619 > @lhotari which kind of test are you requiring ? a unit test that verifies that the GB -> bytes calculation works as expected. > > I am not sure it is worth

[GitHub] [pulsar] frankjkelly opened a new issue #10627: Documentation: Suggest adding documentation for supported bundle split algorithms

2021-08-18 Thread GitBox
frankjkelly opened a new issue #10627: URL: https://github.com/apache/pulsar/issues/10627 **Is your enhancement request related to a problem? Please describe.** Add documentation for how to choose between load balancing algorithms **Describe the solution you'd like** * `support

[GitHub] [pulsar] congbobo184 closed issue #10627: Documentation: Suggest adding documentation for supported bundle split algorithms

2021-08-18 Thread GitBox
congbobo184 closed issue #10627: URL: https://github.com/apache/pulsar/issues/10627 -- 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-unsubs

[GitHub] [pulsar] congbobo184 commented on issue #10627: Documentation: Suggest adding documentation for supported bundle split algorithms

2021-08-18 Thread GitBox
congbobo184 commented on issue #10627: URL: https://github.com/apache/pulsar/issues/10627#issuecomment-901007011 > I have a few questions: > > * How does each algorithm work with other [split bundle configurations](https://github.com/apache/pulsar/blob/b1ff552333c20b081e914766ba54a17

[GitHub] [pulsar] congbobo184 removed a comment on issue #10627: Documentation: Suggest adding documentation for supported bundle split algorithms

2021-08-18 Thread GitBox
congbobo184 removed a comment on issue #10627: URL: https://github.com/apache/pulsar/issues/10627#issuecomment-901007011 > I have a few questions: > > * How does each algorithm work with other [split bundle configurations](https://github.com/apache/pulsar/blob/b1ff552333c20b081e91476

[GitHub] [pulsar] lhotari commented on pull request #11697: [server] Fixed Casting Error

2021-08-18 Thread GitBox
lhotari commented on pull request #11697: URL: https://github.com/apache/pulsar/pull/11697#issuecomment-901008509 To unit test the logic, I'd recommend doing a refactoring. It seems that it's possible to just override the setter "setBacklogQuotaDefaultLimitGB" in ServiceConfiguration

[GitHub] [pulsar] congbobo184 commented on issue #10627: Documentation: Suggest adding documentation for supported bundle split algorithms

2021-08-18 Thread GitBox
congbobo184 commented on issue #10627: URL: https://github.com/apache/pulsar/issues/10627#issuecomment-901009444 @Anonymitaet each algorithm is affected by these configurations the same. `range_equally_divide` use hash range, `topic_count_equally_divide` is evenly distributed. -- This i

[GitHub] [pulsar] congbobo184 commented on issue #8357: [docs] Add doc on how to use batching for key_shared subscription

2021-08-18 Thread GitBox
congbobo184 commented on issue #8357: URL: https://github.com/apache/pulsar/issues/8357#issuecomment-901013897 batch is every subscription mode feature, there is no need document key_shared separately. Is there an issue link? -- This is an automated message from the Apache Git Service.

[GitHub] [pulsar] congbobo184 commented on issue #4856: Admin REST API resetCursorOnPosition endpoint missing position parameter in docs

2021-08-18 Thread GitBox
congbobo184 commented on issue #4856: URL: https://github.com/apache/pulsar/issues/4856#issuecomment-901023857 @grantwwu The document has now been added. Does this problem still exist? If there are no problems, we will close this issue. -- This is an automated message from the Apache Git

[GitHub] [pulsar] lhotari commented on pull request #11697: [server] Fixed Casting Error

2021-08-18 Thread GitBox
lhotari commented on pull request #11697: URL: https://github.com/apache/pulsar/pull/11697#issuecomment-901028370 > It seems that it's possible to just override the setter "setBacklogQuotaDefaultLimitGB" in ServiceConfiguration class and update the backlogQuotaDefaultLimitBytes field on th

[GitHub] [pulsar] lhotari opened a new issue #11700: Flaky-test: ReplicatorTest.testTopicReplicatedAndProducerCreate

2021-08-18 Thread GitBox
lhotari opened a new issue #11700: URL: https://github.com/apache/pulsar/issues/11700 ReplicatorTest is flaky. The testTopicReplicatedAndProducerCreate test method fails sporadically. [example failure](https://github.com/apache/pulsar/pull/11681/checks?check_run_id=3359802221#st

[GitHub] [pulsar] lhotari opened a new issue #11701: Flaky-test: BrokerServiceThrottlingTest.testLookupThrottlingForClientByBroker

2021-08-18 Thread GitBox
lhotari opened a new issue #11701: URL: https://github.com/apache/pulsar/issues/11701 BrokerServiceThrottlingTest is flaky. The testLookupThrottlingForClientByBroker test method fails sporadically. [example failure](https://github.com/apache/pulsar/pull/11681/checks?check_run_id

[GitHub] [pulsar] Huanli-Meng commented on issue #4856: Admin REST API resetCursorOnPosition endpoint missing position parameter in docs

2021-08-18 Thread GitBox
Huanli-Meng commented on issue #4856: URL: https://github.com/apache/pulsar/issues/4856#issuecomment-901083922 @congbobo184 could you please help provide the link/PR for the added document? Thanks. -- This is an automated message from the Apache Git Service. To respond to the message, pl

[GitHub] [pulsar] abhilashmandaliya commented on pull request #11697: [server] Fixed Casting Error

2021-08-18 Thread GitBox
abhilashmandaliya commented on pull request #11697: URL: https://github.com/apache/pulsar/pull/11697#issuecomment-901099857 > > It seems that it's possible to just override the setter "setBacklogQuotaDefaultLimitGB" in ServiceConfiguration class and update the backlogQuotaDefaultLimitBytes

[GitHub] [pulsar] abhilashmandaliya edited a comment on pull request #11697: [server] Fixed Casting Error

2021-08-18 Thread GitBox
abhilashmandaliya edited a comment on pull request #11697: URL: https://github.com/apache/pulsar/pull/11697#issuecomment-901099857 > > It seems that it's possible to just override the setter "setBacklogQuotaDefaultLimitGB" in ServiceConfiguration class and update the backlogQuotaDefaultLim

[GitHub] [pulsar] lhotari commented on a change in pull request #11697: [server] Fixed Casting Error

2021-08-18 Thread GitBox
lhotari commented on a change in pull request #11697: URL: https://github.com/apache/pulsar/pull/11697#discussion_r691219392 ## File path: pulsar-broker/src/test/java/org/apache/pulsar/broker/service/BacklogQuotaManagerConfigurationTest.java ## @@ -0,0 +1,74 @@ +/** + * Licens

[GitHub] [pulsar] lhotari commented on a change in pull request #11697: [server] Fixed Casting Error

2021-08-18 Thread GitBox
lhotari commented on a change in pull request #11697: URL: https://github.com/apache/pulsar/pull/11697#discussion_r691222376 ## File path: pulsar-broker/src/test/java/org/apache/pulsar/broker/service/BacklogQuotaManagerConfigurationTest.java ## @@ -0,0 +1,74 @@ +/** + * Licens

[GitHub] [pulsar] lhotari commented on a change in pull request #11697: [server] Fixed Casting Error

2021-08-18 Thread GitBox
lhotari commented on a change in pull request #11697: URL: https://github.com/apache/pulsar/pull/11697#discussion_r691224136 ## File path: pulsar-broker/src/test/java/org/apache/pulsar/broker/service/BacklogQuotaManagerConfigurationTest.java ## @@ -0,0 +1,74 @@ +/** + * Licens

[GitHub] [pulsar] lhotari commented on a change in pull request #11697: [server] Fixed Casting Error

2021-08-18 Thread GitBox
lhotari commented on a change in pull request #11697: URL: https://github.com/apache/pulsar/pull/11697#discussion_r691226429 ## File path: pulsar-broker/src/test/java/org/apache/pulsar/broker/service/BacklogQuotaManagerConfigurationTest.java ## @@ -0,0 +1,74 @@ +/** + * Licens

[GitHub] [pulsar] LeBW commented on a change in pull request #11553: Exposing the broker entry metadata to client

2021-08-18 Thread GitBox
LeBW commented on a change in pull request #11553: URL: https://github.com/apache/pulsar/pull/11553#discussion_r691230182 ## File path: pulsar-broker/src/main/java/org/apache/pulsar/broker/service/PulsarCommandSenderImpl.java ## @@ -243,8 +243,13 @@ public ChannelPromise sendM

[GitHub] [pulsar] LeBW commented on a change in pull request #11553: Exposing the broker entry metadata to client

2021-08-18 Thread GitBox
LeBW commented on a change in pull request #11553: URL: https://github.com/apache/pulsar/pull/11553#discussion_r691230182 ## File path: pulsar-broker/src/main/java/org/apache/pulsar/broker/service/PulsarCommandSenderImpl.java ## @@ -243,8 +243,13 @@ public ChannelPromise sendM

[GitHub] [pulsar] lhotari commented on a change in pull request #11697: [server] Fixed Casting Error

2021-08-18 Thread GitBox
lhotari commented on a change in pull request #11697: URL: https://github.com/apache/pulsar/pull/11697#discussion_r691239823 ## File path: pulsar-broker/src/test/java/org/apache/pulsar/broker/service/BacklogQuotaManagerConfigurationTest.java ## @@ -0,0 +1,82 @@ +/** + * Licens

[GitHub] [pulsar] Vanlightly commented on pull request #11691: [Issue 11689][Client] Fixed block forever bug in Consumer.batchReceive

2021-08-18 Thread GitBox
Vanlightly commented on pull request #11691: URL: https://github.com/apache/pulsar/pull/11691#issuecomment-901139152 @315157973 we could look at something like that. The ConsumerImpl has its `internalPinnedExecutor` so could be leveraged to avoid multi-threaded calls by submitting some par

[GitHub] [pulsar] sijia-w commented on issue #7663: doc for deploying python functions with custom dependencies not explained in 2.6.0

2021-08-18 Thread GitBox
sijia-w commented on issue #7663: URL: https://github.com/apache/pulsar/issues/7663#issuecomment-901170493 @sergescevenels-naspers The functions are available in the latest version. See https://pulsar.apache.org/docs/en/next/functions-package/#python. Do you have further questions regardin

[GitHub] [pulsar] lhotari commented on pull request #11681: [Broker] Support disabling non-TLS service ports

2021-08-18 Thread GitBox
lhotari commented on pull request #11681: URL: https://github.com/apache/pulsar/pull/11681#issuecomment-901175813 > Thanks for your contribution. I've made some comments, PTAL. @Anonymitaet thanks for the suggestions. I committed them. Please PTAL -- This is an automated message f

[GitHub] [pulsar] eolivelli commented on a change in pull request #11697: [server] Fixed Casting Error

2021-08-18 Thread GitBox
eolivelli commented on a change in pull request #11697: URL: https://github.com/apache/pulsar/pull/11697#discussion_r691319160 ## File path: pulsar-broker/src/test/java/org/apache/pulsar/broker/service/BacklogQuotaManagerConfigurationTest.java ## @@ -0,0 +1,82 @@ +/** + * Lice

[GitHub] [pulsar] sijia-w opened a new pull request #11702: [docs] [ISSUE 10627] Add description for two ways of splitting namespace bundles

2021-08-18 Thread GitBox
sijia-w opened a new pull request #11702: URL: https://github.com/apache/pulsar/pull/11702 Fixes #10627 -- 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-

[GitHub] [pulsar] liangyuanpeng commented on issue #11529: 启动消费者,订阅某一个topic,启动报错,更换topic启动成功

2021-08-18 Thread GitBox
liangyuanpeng commented on issue #11529: URL: https://github.com/apache/pulsar/issues/11529#issuecomment-901236710 I suggest you use a higher version... -- 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] abhilashmandaliya commented on pull request #11697: [server] Fixed Casting Error

2021-08-18 Thread GitBox
abhilashmandaliya commented on pull request #11697: URL: https://github.com/apache/pulsar/pull/11697#issuecomment-901238374 Thanks, @lhotari, and @eolivelli for a thorough review and for helping me make it cleaner. I have considered all the suggestions. -- This is an automated message fr

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

2021-08-18 Thread GitBox
gaozhangmin removed a comment on pull request #10853: URL: https://github.com/apache/pulsar/pull/10853#issuecomment-879630968 @MarvinCai Could u please review it again? thanks. -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub

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

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

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

2021-08-18 Thread GitBox
gaozhangmin commented on pull request #10853: URL: https://github.com/apache/pulsar/pull/10853#issuecomment-901244616 @codelipenghui @cckellogg @MarvinCai this pr has been continued for a long time. PTAL. thanks -- This is an automated message from the Apache Git Service. To respond t

[GitHub] [pulsar] lhotari commented on pull request #11697: [server] Fixed Casting Error

2021-08-18 Thread GitBox
lhotari commented on pull request #11697: URL: https://github.com/apache/pulsar/pull/11697#issuecomment-901250163 LGTM. Good work @abhilashmandaliya ! Thanks for the contribution. -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitH

[GitHub] [pulsar] ivankelly merged pull request #11688: [client] Consider a timed-out lookup equivalent to TooManyRequests

2021-08-18 Thread GitBox
ivankelly merged pull request #11688: URL: https://github.com/apache/pulsar/pull/11688 -- 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] 315157973 commented on a change in pull request #11691: [Issue 11689][Client] Fixed block forever bug in Consumer.batchReceive

2021-08-18 Thread GitBox
315157973 commented on a change in pull request #11691: URL: https://github.com/apache/pulsar/pull/11691#discussion_r690863726 ## File path: pulsar-client/src/main/java/org/apache/pulsar/client/impl/ConsumerBase.java ## @@ -82,6 +79,7 @@ protected final ConsumerIntercepto

[GitHub] [pulsar] eolivelli commented on a change in pull request #11553: Exposing the broker entry metadata to client

2021-08-18 Thread GitBox
eolivelli commented on a change in pull request #11553: URL: https://github.com/apache/pulsar/pull/11553#discussion_r690962783 ## File path: pulsar-broker/src/main/java/org/apache/pulsar/broker/service/PulsarCommandSenderImpl.java ## @@ -243,8 +243,13 @@ public ChannelPromise

[GitHub] [pulsar] sijia-w commented on issue #7663: doc for deploying python functions with custom dependencies not explained in 2.6.0

2021-08-18 Thread GitBox
sijia-w commented on issue #7663: URL: https://github.com/apache/pulsar/issues/7663#issuecomment-901170493 @sergescevenels-naspers The functions are available in the latest version. See https://pulsar.apache.org/docs/en/next/functions-package/#python. Do you have further questions regardin

[GitHub] [pulsar] 315157973 commented on pull request #11691: [Issue 11689][Client] Fixed block forever bug in Consumer.batchReceive

2021-08-18 Thread GitBox
315157973 commented on pull request #11691: URL: https://github.com/apache/pulsar/pull/11691#issuecomment-900911001 The main reason for this to be locked is the following two pieces of logic: `pendingBatchReceiveTask` is run by the timed thread pool of ConsumerBase, and pollNextBatchRece

[GitHub] [pulsar] abhilashmandaliya commented on a change in pull request #11671: [server] Allow broker to start with default backlogquota in bytes

2021-08-18 Thread GitBox
abhilashmandaliya commented on a change in pull request #11671: URL: https://github.com/apache/pulsar/pull/11671#discussion_r690920856 ## File path: pulsar-broker/src/main/java/org/apache/pulsar/broker/service/BacklogQuotaManager.java ## @@ -53,9 +53,10 @@ public Backlo

[GitHub] [pulsar] eolivelli commented on a change in pull request #11671: [server] Allow broker to start with default backlogquota in bytes

2021-08-18 Thread GitBox
eolivelli commented on a change in pull request #11671: URL: https://github.com/apache/pulsar/pull/11671#discussion_r690940233 ## File path: pulsar-broker/src/main/java/org/apache/pulsar/broker/service/BacklogQuotaManager.java ## @@ -53,9 +53,10 @@ public BacklogQuotaMa

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

2021-08-18 Thread GitBox
gaozhangmin removed a comment on pull request #10853: URL: https://github.com/apache/pulsar/pull/10853#issuecomment-879630968 @MarvinCai Could u please review it again? thanks. -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub

[GitHub] [pulsar] merlimat commented on issue #10734: Pulsar C++ key-shared subscriber runs out of memory for non-persistent topic

2021-08-18 Thread GitBox
merlimat commented on issue #10734: URL: https://github.com/apache/pulsar/issues/10734#issuecomment-900567121 @marcoguest The memory limit in 2.8 is currently only working on limiting the amount of memory used by producers. In this the problem is also reproducible with non-persiste

[GitHub] [pulsar] congbobo184 removed a comment on issue #10627: Documentation: Suggest adding documentation for supported bundle split algorithms

2021-08-18 Thread GitBox
congbobo184 removed a comment on issue #10627: URL: https://github.com/apache/pulsar/issues/10627#issuecomment-901007011 > I have a few questions: > > * How does each algorithm work with other [split bundle configurations](https://github.com/apache/pulsar/blob/b1ff552333c20b081e91476

[GitHub] [pulsar] jerrypeng closed issue #11678: Pulsar functions terminateFunction doesn't clean up intermediate topics created for batchSource.

2021-08-18 Thread GitBox
jerrypeng closed issue #11678: URL: https://github.com/apache/pulsar/issues/11678 -- 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] Anonymitaet commented on pull request #11681: [Broker] Support disabling non-TLS service ports

2021-08-18 Thread GitBox
Anonymitaet commented on pull request #11681: URL: https://github.com/apache/pulsar/pull/11681#issuecomment-900740090 Thanks for your contribution. Do we need to update docs here https://pulsar.apache.org/docs/en/next/reference-configuration/#broker? -- This is an automated message from

[GitHub] [pulsar] congbobo184 commented on issue #4856: Admin REST API resetCursorOnPosition endpoint missing position parameter in docs

2021-08-18 Thread GitBox
congbobo184 commented on issue #4856: URL: https://github.com/apache/pulsar/issues/4856#issuecomment-901023857 @grantwwu The document has now been added. Does this problem still exist? If there are no problems, we will close this issue. -- This is an automated message from the Apache Git

[GitHub] [pulsar] ivankelly commented on pull request #11688: [client] Consider a timed-out lookup equivalent to TooManyRequests

2021-08-18 Thread GitBox
ivankelly commented on pull request #11688: URL: https://github.com/apache/pulsar/pull/11688#issuecomment-900402126 Test failure was a mixup with how testng initializes classes. Fixed now. -- This is an automated message from the Apache Git Service. To respond to the message, please log o

[GitHub] [pulsar] gaozhangmin commented on pull request #11683: failed update partition of topic

2021-08-18 Thread GitBox
gaozhangmin commented on pull request #11683: URL: https://github.com/apache/pulsar/pull/11683#issuecomment-900754094 -- 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 uns

[GitHub] [pulsar] merlimat commented on pull request #11693: Refactored PulsarResources to avoid building metadata paths everywhere

2021-08-18 Thread GitBox
merlimat commented on pull request #11693: URL: https://github.com/apache/pulsar/pull/11693#issuecomment-900742467 > Thanks for your contribution. For this PR, do we need to update docs? @Anonymitaet no need for docs changes here. Just labeled. -- This is an automated message from the

[GitHub] [pulsar] eolivelli commented on a change in pull request #11293: [IO] Pass client builder to debezium database history

2021-08-18 Thread GitBox
eolivelli commented on a change in pull request #11293: URL: https://github.com/apache/pulsar/pull/11293#discussion_r690950396 ## File path: pulsar-io/debezium/core/pom.xml ## @@ -62,12 +62,6 @@ ${kafka-client.version} - - ${project.groupId} - pulsa

[GitHub] [pulsar] congbobo184 commented on issue #8357: [docs] Add doc on how to use batching for key_shared subscription

2021-08-18 Thread GitBox
congbobo184 commented on issue #8357: URL: https://github.com/apache/pulsar/issues/8357#issuecomment-901013897 batch is every subscription mode feature, there is no need document key_shared separately. Is there an issue link? -- This is an automated message from the Apache Git Service.

[GitHub] [pulsar] abhilashmandaliya edited a comment on pull request #11697: [server] Fixed Casting Error

2021-08-18 Thread GitBox
abhilashmandaliya edited a comment on pull request #11697: URL: https://github.com/apache/pulsar/pull/11697#issuecomment-901099857 > > It seems that it's possible to just override the setter "setBacklogQuotaDefaultLimitGB" in ServiceConfiguration class and update the backlogQuotaDefaultLim

[GitHub] [pulsar] murong00 commented on a change in pull request #3823: [Issue 3822] [pulsar-io] Add a Pulsar IO connector for Alluxio sink

2021-08-18 Thread GitBox
murong00 commented on a change in pull request #3823: URL: https://github.com/apache/pulsar/pull/3823#discussion_r690881616 ## File path: pulsar-io/alluxio/src/main/java/org/apache/pulsar/io/alluxio/sink/AlluxioSink.java ## @@ -0,0 +1,284 @@ +/** + * Licensed to the Apache Sof

[GitHub] [pulsar] abhilashmandaliya commented on pull request #11697: [server] Fixed Casting Error

2021-08-18 Thread GitBox
abhilashmandaliya commented on pull request #11697: URL: https://github.com/apache/pulsar/pull/11697#issuecomment-901099857 -- 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.

[GitHub] [pulsar] lhotari commented on pull request #11681: [Broker] Support disabling non-TLS service ports

2021-08-18 Thread GitBox
lhotari commented on pull request #11681: URL: https://github.com/apache/pulsar/pull/11681#issuecomment-900821479 -- 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 unsubsc

[GitHub] [pulsar] Huanli-Meng merged pull request #11648: [Doc] [ISSUE 11291] Update Pulsar Dashboard relevant content

2021-08-18 Thread GitBox
Huanli-Meng merged pull request #11648: URL: https://github.com/apache/pulsar/pull/11648 -- 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] BewareMyPower commented on a change in pull request #11683: failed update partition of topic

2021-08-18 Thread GitBox
BewareMyPower commented on a change in pull request #11683: URL: https://github.com/apache/pulsar/pull/11683#discussion_r690975274 ## File path: pulsar-broker/src/main/java/org/apache/pulsar/broker/admin/impl/PersistentTopicsBase.java ## @@ -3636,6 +3636,15 @@ private Persiste

[GitHub] [pulsar] gaozhangmin commented on a change in pull request #11686: fix the bug, can not update topic when the update topicName is contained by an existed topic as a part

2021-08-18 Thread GitBox
gaozhangmin commented on a change in pull request #11686: URL: https://github.com/apache/pulsar/pull/11686#discussion_r690845106 ## File path: pulsar-broker/src/main/java/org/apache/pulsar/broker/admin/impl/PersistentTopicsBase.java ## @@ -3773,9 +3773,9 @@ private void valida

[GitHub] [pulsar] Anonymitaet commented on pull request #11693: Refactored PulsarResources to avoid building metadata paths everywhere

2021-08-18 Thread GitBox
Anonymitaet commented on pull request #11693: URL: https://github.com/apache/pulsar/pull/11693#issuecomment-900741551 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] eolivelli commented on pull request #11697: [server] Fixed Casting Error

2021-08-18 Thread GitBox
eolivelli commented on pull request #11697: URL: https://github.com/apache/pulsar/pull/11697#issuecomment-900912023 @lhotari which kind of test are you requiring ? I am not sure it is worth to add the needed instrumentation to test this change. The rounding error is quite evident

[GitHub] [pulsar] Vanlightly commented on a change in pull request #11691: [Issue 11689][Client] Fixed block forever bug in Consumer.batchReceive

2021-08-18 Thread GitBox
Vanlightly commented on a change in pull request #11691: URL: https://github.com/apache/pulsar/pull/11691#discussion_r690942099 ## File path: pulsar-client/src/main/java/org/apache/pulsar/client/impl/ConsumerBase.java ## @@ -204,26 +205,11 @@ protected ConsumerBase(PulsarClien

[GitHub] [pulsar] lhotari commented on a change in pull request #11697: [server] Fixed Casting Error

2021-08-18 Thread GitBox
lhotari commented on a change in pull request #11697: URL: https://github.com/apache/pulsar/pull/11697#discussion_r691219392 ## File path: pulsar-broker/src/test/java/org/apache/pulsar/broker/service/BacklogQuotaManagerConfigurationTest.java ## @@ -0,0 +1,74 @@ +/** + * Licens

[GitHub] [pulsar] liangyuanpeng commented on issue #11529: 启动消费者,订阅某一个topic,启动报错,更换topic启动成功

2021-08-18 Thread GitBox
liangyuanpeng commented on issue #11529: URL: https://github.com/apache/pulsar/issues/11529#issuecomment-901236710 I suggest you use a higher version... -- 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] congbobo184 closed issue #10627: Documentation: Suggest adding documentation for supported bundle split algorithms

2021-08-18 Thread GitBox
congbobo184 closed issue #10627: URL: https://github.com/apache/pulsar/issues/10627 -- 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-unsubs

[GitHub] [pulsar] Anonymitaet commented on pull request #11686: fix the bug, can not update topic when the update topicName is contained by an existed topic as a part

2021-08-18 Thread GitBox
Anonymitaet commented on pull request #11686: URL: https://github.com/apache/pulsar/pull/11686#issuecomment-900740552 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] Huanli-Meng closed issue #11291: [Doc] Remove Pulsar Dashboard contents

2021-08-18 Thread GitBox
Huanli-Meng closed issue #11291: URL: https://github.com/apache/pulsar/issues/11291 -- 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-unsubs

[GitHub] [pulsar] merlimat commented on a change in pull request #11553: Exposing the broker entry metadata to client

2021-08-18 Thread GitBox
merlimat commented on a change in pull request #11553: URL: https://github.com/apache/pulsar/pull/11553#discussion_r690832856 ## File path: pulsar-broker/src/main/java/org/apache/pulsar/broker/service/PulsarCommandSenderImpl.java ## @@ -243,8 +243,13 @@ public ChannelPromise s

[GitHub] [pulsar] gaozhangmin commented on a change in pull request #11683: failed update partition of topic

2021-08-18 Thread GitBox
gaozhangmin commented on a change in pull request #11683: URL: https://github.com/apache/pulsar/pull/11683#discussion_r690847754 ## File path: pulsar-broker/src/main/java/org/apache/pulsar/broker/admin/impl/PersistentTopicsBase.java ## @@ -3636,6 +3638,13 @@ private Persistent

[GitHub] [pulsar] BewareMyPower commented on pull request #11683: failed update partition of topic

2021-08-18 Thread GitBox
BewareMyPower commented on pull request #11683: URL: https://github.com/apache/pulsar/pull/11683#issuecomment-900885644 Please fix the code style. ``` Error: src/main/java/org/apache/pulsar/broker/admin/impl/PersistentTopicsBase.java:[3641,21] (whitespace) WhitespaceAround: 'for

[GitHub] [pulsar] Nicklee007 commented on pull request #11686: fix the bug, can not update topic when the update topicName is contained by an existed topic as a part

2021-08-18 Thread GitBox
Nicklee007 commented on pull request #11686: URL: https://github.com/apache/pulsar/pull/11686#issuecomment-900756328 > 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/.gi

[GitHub] [pulsar] Anonymitaet commented on a change in pull request #11681: [Broker] Support disabling non-TLS service ports

2021-08-18 Thread GitBox
Anonymitaet commented on a change in pull request #11681: URL: https://github.com/apache/pulsar/pull/11681#discussion_r691044967 ## File path: site2/docs/security-tls-keystore.md ## @@ -131,6 +131,13 @@ brokerClientTlsTrustStorePassword=clientpw NOTE: it is important to rest

[GitHub] [pulsar] codelipenghui closed issue #10734: Pulsar C++ key-shared subscriber runs out of memory for non-persistent topic

2021-08-18 Thread GitBox
codelipenghui closed issue #10734: URL: https://github.com/apache/pulsar/issues/10734 -- 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] marcoguest commented on issue #10734: Pulsar C++ key-shared subscriber runs out of memory for non-persistent topic

2021-08-18 Thread GitBox
marcoguest commented on issue #10734: URL: https://github.com/apache/pulsar/issues/10734#issuecomment-900951071 Thank you @merlimat -- 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

[GitHub] [pulsar] Nicklee007 commented on a change in pull request #11686: fix the bug, can not update topic when the update topicName is contained by an existed topic as a part

2021-08-18 Thread GitBox
Nicklee007 commented on a change in pull request #11686: URL: https://github.com/apache/pulsar/pull/11686#discussion_r690830592 ## File path: pulsar-broker/src/main/java/org/apache/pulsar/broker/admin/impl/PersistentTopicsBase.java ## @@ -3773,9 +3773,9 @@ private void validat

[GitHub] [pulsar] jerrypeng merged pull request #11679: [Issue 11678 ] [pulsar-functions] When the action has no 'continueOn', continue to invoke subsequent actions

2021-08-18 Thread GitBox
jerrypeng merged pull request #11679: URL: https://github.com/apache/pulsar/pull/11679 -- 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] congbobo184 commented on issue #10627: Documentation: Suggest adding documentation for supported bundle split algorithms

2021-08-18 Thread GitBox
congbobo184 commented on issue #10627: URL: https://github.com/apache/pulsar/issues/10627#issuecomment-901007011 -- 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 unsubscr

[GitHub] [pulsar] eolivelli commented on a change in pull request #11681: [Broker] Support disabling non-TLS service ports

2021-08-18 Thread GitBox
eolivelli commented on a change in pull request #11681: URL: https://github.com/apache/pulsar/pull/11681#discussion_r690968459 ## File path: pulsar-broker/src/main/java/org/apache/pulsar/broker/loadbalance/impl/SimpleLoadManagerImpl.java ## @@ -1122,7 +1122,7 @@ private String

[GitHub] [pulsar] Huanli-Meng closed issue #11625: [doc] Message redelivery and acknowledgement

2021-08-18 Thread GitBox
Huanli-Meng closed issue #11625: URL: https://github.com/apache/pulsar/issues/11625 -- 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-unsubs

[GitHub] [pulsar] eolivelli commented on a change in pull request #11697: [server] Fixed Casting Error

2021-08-18 Thread GitBox
eolivelli commented on a change in pull request #11697: URL: https://github.com/apache/pulsar/pull/11697#discussion_r691319160 ## File path: pulsar-broker/src/test/java/org/apache/pulsar/broker/service/BacklogQuotaManagerConfigurationTest.java ## @@ -0,0 +1,82 @@ +/** + * Lice

  1   2   >