[GitHub] [pulsar] sijie merged pull request #7483: Fix ArrayIndexOutOfBoundsException when dispatch messages to consumer.

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

[GitHub] [pulsar] sijie closed issue #7482: ERROR org.apache.bookkeeper.common.util.SafeRunnable - Unexpected throwable caught java.lang.ArrayIndexOutOfBoundsException: 100 while starting broker in c

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

[pulsar] branch master updated (6726072 -> beb9e3b)

This is an automated email from the ASF dual-hosted git repository. sijie pushed a change to branch master in repository https://gitbox.apache.org/repos/asf/pulsar.git. from 6726072 [Doc]--add authentication client with oauth2 support (#7462) add beb9e3b Fix

[GitHub] [pulsar-client-go] dferstay opened a new pull request #319: Do not allocate MessageIDs on the heap

dferstay opened a new pull request #319: URL: https://github.com/apache/pulsar-client-go/pull/319 Passing a function parameter by pointer (or writing a pointer into a channel) will cause the Go escape analysis to allocate the parameter on the heap. This change passes messageID

[GitHub] [pulsar] jiazhai merged pull request #7462: [Doc]--add authentication client with oauth2 support

jiazhai merged pull request #7462: URL: https://github.com/apache/pulsar/pull/7462 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: [Doc]--add authentication client with oauth2 support (#7462)

This is an automated email from the ASF dual-hosted git repository. zhaijia 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 6726072 [Doc]--add authentication client with

[GitHub] [pulsar] jiazhai closed issue #7425: Add doc of oauth2 client authentication into website.

jiazhai closed issue #7425: URL: https://github.com/apache/pulsar/issues/7425 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] 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-655883058 @codelipenghui Sure. How can I get a broker dump ? This is an automated message from the Apache Git Service.

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

wolfstudy commented on a change in pull request #314: URL: https://github.com/apache/pulsar-client-go/pull/314#discussion_r451932214 ## File path: pulsar/consumer_test.go ## @@ -1342,3 +1344,130 @@ func TestProducerName(t *testing.T) { consumer.Ack(msg)

[GitHub] [pulsar-client-go] taiyang-li opened a new issue #318: Some messages are missing when reopen consumer

taiyang-li opened a new issue #318: URL: https://github.com/apache/pulsar-client-go/issues/318 Expected behavior Messages are consumed at least once when reopen consumer. Actual behavior Some messages are missing when reopen consumer Steps to

[pulsar-client-go] branch master updated: Share buffer pool across all partitions (#310)

This is an automated email from the ASF dual-hosted git repository. rxl pushed a commit to branch master in repository https://gitbox.apache.org/repos/asf/pulsar-client-go.git The following commit(s) were added to refs/heads/master by this push: new 9cbe36f Share buffer pool across all

[GitHub] [pulsar-client-go] wolfstudy merged pull request #310: Share buffer pool across all partitions

wolfstudy merged pull request #310: URL: https://github.com/apache/pulsar-client-go/pull/310 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] jiazhai merged pull request #7467: Cpp oauth2 auth client

jiazhai merged pull request #7467: URL: https://github.com/apache/pulsar/pull/7467 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: Cpp oauth2 auth client (#7467)

This is an automated email from the ASF dual-hosted git repository. zhaijia 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 2d0cceb Cpp oauth2 auth client (#7467)

[GitHub] [pulsar] jiazhai commented on pull request #7467: Cpp oauth2 auth client

jiazhai commented on pull request #7467: URL: https://github.com/apache/pulsar/pull/7467#issuecomment-655857831 > * It seems that in Java plugin we are using encoded auth param string but in c++ client, we don't use encoded auth param. Is there any reason? > * I think it is worth

[GitHub] [pulsar] sijie commented on issue #7480: native go v0.1.1 No support produce batch？

sijie commented on issue #7480: URL: https://github.com/apache/pulsar/issues/7480#issuecomment-655856901 @sxpsxp12 Can you create the issue at https://github.com/apache/pulsar-client-go? This is an automated message from

[GitHub] [pulsar] sijie commented on issue #7479: support pulsar consumer keyshared in C++ And Cgo

sijie commented on issue #7479: URL: https://github.com/apache/pulsar/issues/7479#issuecomment-655855699 @sxpsxp12 Can you share a code example so that we can reproduce? Did you see any error logs at the broker side?

[GitHub] [pulsar] sijie commented on issue #7477: [python-client 2.6.0] ContextualVersionConflict grpcio dependency conflict

sijie commented on issue #7477: URL: https://github.com/apache/pulsar/issues/7477#issuecomment-655855101 @lbenc135 Can you share your python code example so we can reproduce it? This is an automated message from the Apache

[GitHub] [pulsar] sijie commented on issue #7476: Discovery service can't find active broker

sijie commented on issue #7476: URL: https://github.com/apache/pulsar/issues/7476#issuecomment-655854425 @aloyszhang No available broker usually happens when the session expires. Out of curiosity, why do you need to start a separate discovery service?

[GitHub] [pulsar] jiazhai opened a new issue #7486: Handle left work for cpp oauth2 client.

jiazhai opened a new issue #7486: URL: https://github.com/apache/pulsar/issues/7486 related with PR #7467 , some points need handle. - [] It seems that in Java plugin we are using encoded auth param string but in c++ client, we don't use encoded auth param. Is there any reason? -

[GitHub] [pulsar] codelipenghui commented on issue #7484: pulsar_msg_backlog metrics very inaccurate

codelipenghui commented on issue #7484: URL: https://github.com/apache/pulsar/issues/7484#issuecomment-655839914 @irairdon Looks #7082 has fixed this problem. This is an automated message from the Apache Git Service. To

[GitHub] [pulsar] 315157973 commented on issue #7485: Support configuring DeleteInactiveTopic setting in namespace policy

315157973 commented on issue #7485: URL: https://github.com/apache/pulsar/issues/7485#issuecomment-655839073 mark This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub

[GitHub] [pulsar-client-go] merlimat opened a new pull request #317: Export client metrics to Prometheus

merlimat opened a new pull request #317: URL: https://github.com/apache/pulsar-client-go/pull/317 ### Motivation Added basic client metrics using Prometheus lib. ```bash # HELP pulsar_client_bytes_published Counter of messages published by the client # TYPE

[GitHub] [pulsar] jerrypeng merged pull request #7474: Log scheduler stats for Pulsar Functions

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

[pulsar] branch master updated (eaf268c -> cc2c203)

This is an automated email from the ASF dual-hosted git repository. jerrypeng pushed a change to branch master in repository https://gitbox.apache.org/repos/asf/pulsar.git. from eaf268c [Issue 7347] Avoid the NPE occurs in method `ManagedLedgerImpl.isOffloadedNeedsDelete` (#7389) add

[GitHub] [pulsar-client-go] merlimat commented on pull request #310: Share buffer pool across all partitions

merlimat commented on pull request #310: URL: https://github.com/apache/pulsar-client-go/pull/310#issuecomment-655776643 > just only some concerns whether the use of sync.pool here will cause GC pressure because sync.Pool cannot specify a size, which is only subject to the GC threshold.

[GitHub] [pulsar-client-go] merlimat commented on a change in pull request #310: Share buffer pool across all partitions

merlimat commented on a change in pull request #310: URL: https://github.com/apache/pulsar-client-go/pull/310#discussion_r451842150 ## File path: perf/perf-producer.go ## @@ -62,6 +63,8 @@ func newProducerCommand() *cobra.Command { "Publish rate. Set to 0 to go

[GitHub] [pulsar-client-go] merlimat merged pull request #316: Reduce the size of the MessageID structs by one word on 64-bit arch

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

[pulsar-client-go] branch master updated: Reduce the size of the MessageID structs by one word on 64-bit arch (#316)

This is an automated email from the ASF dual-hosted git repository. mmerli pushed a commit to branch master in repository https://gitbox.apache.org/repos/asf/pulsar-client-go.git The following commit(s) were added to refs/heads/master by this push: new 6fcaf26 Reduce the size of the

[GitHub] [pulsar-client-go] dferstay opened a new pull request #316: Reduce the size of the MessageID structs by one word on 64-bit arch

dferstay opened a new pull request #316: URL: https://github.com/apache/pulsar-client-go/pull/316 An int occupies one word of memory; on 64-bit machines, this is 8 bytes. As a result, the messageID struct is 56-bytes: * ledgerID - 8 bytes * entryID - 8 bytes * batchIdx - 8

[GitHub] [pulsar] rdhabalia commented on a change in pull request #7473: [pulsar-broker] Cleanup already deleted namespace topics

rdhabalia commented on a change in pull request #7473: URL: https://github.com/apache/pulsar/pull/7473#discussion_r451810264 ## File path: pulsar-broker/src/main/java/org/apache/pulsar/broker/service/persistent/PersistentReplicator.java ## @@ -760,11 +761,13 @@ private void

[GitHub] [pulsar-client-go] devinbost commented on issue #315: Unable to use this dependency in Go module due to dependency collision

devinbost commented on issue #315: URL: https://github.com/apache/pulsar-client-go/issues/315#issuecomment-655726994 I created a new issue here for this: https://github.com/moby/moby/issues/41191 This is an automated

[GitHub] [pulsar-client-go] devinbost commented on issue #315: Unable to use this dependency in Go module due to dependency collision

devinbost commented on issue #315: URL: https://github.com/apache/pulsar-client-go/issues/315#issuecomment-655712602 Turns out that Docker repo isn't even maintained... To anyone who runs into this issue, I still need to figure out how to get the Docker SDK working because it's still

[GitHub] [pulsar-client-go] devinbost closed issue #315: Unable to use this dependency in Go module due to dependency collision

devinbost closed issue #315: URL: https://github.com/apache/pulsar-client-go/issues/315 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-client-go] devinbost commented on issue #315: Unable to use this dependency in Go module due to dependency collision

devinbost commented on issue #315: URL: https://github.com/apache/pulsar-client-go/issues/315#issuecomment-655707511 Resolved by installing the docker SDK with "-d" parameter, like this: `go get -d docker.io/go-docker` as mentioned here: https://github.com/docker/go-docker

[GitHub] [pulsar-client-go] devinbost commented on issue #315: Unable to use this dependency in Go module due to dependency collision

devinbost commented on issue #315: URL: https://github.com/apache/pulsar-client-go/issues/315#issuecomment-655702133 It looks like this issue might actually be due to me including an import to Docker's Go SDK in my code. Need to investigate further.

[GitHub] [pulsar-client-go] devinbost opened a new issue #315: Unable to use this dependency in Go module due to dependency collision

devinbost opened a new issue #315: URL: https://github.com/apache/pulsar-client-go/issues/315 Expected behavior I should not have problems when building my go module Actual behavior and steps to reproduce I get a never-ending rabbit hole of

[GitHub] [pulsar] jerrypeng commented on a change in pull request #7474: Log scheduler stats for Pulsar Functions

jerrypeng commented on a change in pull request #7474: URL: https://github.com/apache/pulsar/pull/7474#discussion_r451753300 ## File path: pulsar-functions/worker/src/main/java/org/apache/pulsar/functions/worker/MembershipManager.java ## @@ -225,7 +232,8 @@ public void

[GitHub] [pulsar] sijie opened a new issue #7485: Support configuring DeleteInactiveTopic setting in namespace policy

sijie opened a new issue #7485: URL: https://github.com/apache/pulsar/issues/7485 *Motivation* We should support configuring the `DeleteInactiveTopic` setting in namespace policy. This is an automated message from

[GitHub] [pulsar] sijie commented on issue #7385: When `authorizationEnabled=true` in proxy.conf the proxy does not appear to perform Authorization check

sijie commented on issue #7385: URL: https://github.com/apache/pulsar/issues/7385#issuecomment-655647766 @vzhikserg: the `proxyRole` is used for topic lookup (to figure who is the owner broker for a given topic) before establishing the proxied connections to the brokers. Hence the

[GitHub] [pulsar] sijie commented on pull request #7462: [Doc]--add authentication client with oauth2 support

sijie commented on pull request #7462: URL: https://github.com/apache/pulsar/pull/7462#issuecomment-655642288 @junquero yes This is an automated message from the Apache Git Service. To respond to the message, please log on

[GitHub] [pulsar] srkukarni commented on a change in pull request #7474: Log scheduler stats for Pulsar Functions

srkukarni commented on a change in pull request #7474: URL: https://github.com/apache/pulsar/pull/7474#discussion_r451695027 ## File path: pulsar-functions/worker/src/main/java/org/apache/pulsar/functions/worker/MembershipManager.java ## @@ -225,7 +232,8 @@ public void

[GitHub] [pulsar] sijie merged pull request #7389: [Issue 7347] Avoid the NPE occurs in method `ManagedLedgerImpl.isOffloadedNeedsDelete`

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

[GitHub] [pulsar] sijie closed issue #7347: NPE occurs in the method `ManagedLedgerImpl.isOffloadedNeedsDelete`.

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

[pulsar] branch master updated (c91505e -> eaf268c)

This is an automated email from the ASF dual-hosted git repository. sijie pushed a change to branch master in repository https://gitbox.apache.org/repos/asf/pulsar.git. from c91505e [Issue 5736] Add test checks in branches (#7465) add eaf268c [Issue 7347] Avoid the NPE occurs in

[GitHub] [pulsar] sijie commented on pull request #7483: Fix ArrayIndexOutOfBoundsException when dispatch messages to consumer.

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

[GitHub] [pulsar] irairdon opened a new issue #7484: pulsar_msg_backlog metrics very inaccurate

irairdon opened a new issue #7484: URL: https://github.com/apache/pulsar/issues/7484 **Describe the bug** Metric for pulsar_msg_backlog does not seem to match the true backlog at all. **To Reproduce** Steps to reproduce the behavior: 1. Install pulsar 2.5.2 2. Install

[GitHub] [pulsar-client-go] cckellogg commented on a change in pull request #303: Close msg channel when consumer close

cckellogg commented on a change in pull request #303: URL: https://github.com/apache/pulsar-client-go/pull/303#discussion_r451622413 ## File path: pulsar/consumer_singletopic.go ## @@ -0,0 +1,41 @@ +// Licensed to the Apache Software Foundation (ASF) under one +// or more

[GitHub] [pulsar] merlimat commented on a change in pull request #7475: Use CGroup CPU usage when present

merlimat commented on a change in pull request #7475: URL: https://github.com/apache/pulsar/pull/7475#discussion_r451611511 ## File path: pulsar-broker/src/main/java/org/apache/pulsar/broker/loadbalance/impl/LinuxBrokerHostUsageImpl.java ## @@ -87,45 +100,36 @@ public void

[GitHub] [pulsar] merlimat commented on a change in pull request #7473: [pulsar-broker] Cleanup already deleted namespace topics

merlimat commented on a change in pull request #7473: URL: https://github.com/apache/pulsar/pull/7473#discussion_r451586412 ## File path: pulsar-broker/src/main/java/org/apache/pulsar/broker/service/persistent/PersistentReplicator.java ## @@ -760,11 +761,13 @@ private void

[GitHub] [pulsar] merlimat commented on a change in pull request #7475: Use CGroup CPU usage when present

merlimat commented on a change in pull request #7475: URL: https://github.com/apache/pulsar/pull/7475#discussion_r451580996 ## File path: pulsar-broker/src/main/java/org/apache/pulsar/broker/loadbalance/impl/LinuxBrokerHostUsageImpl.java ## @@ -87,45 +100,36 @@ public void

[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-655547114 @rushsky518 Thanks for the contribution, would you please take a look the comment? This is an automated

[GitHub] [pulsar] codelipenghui commented on issue #7478: pulsar-admin reset cursor hangs

codelipenghui commented on issue #7478: URL: https://github.com/apache/pulsar/issues/7478#issuecomment-655545286 @ltamber Are you interested in fixing this problem? looks the problem is `sub.resetCursor(PositionImpl.get(messageId.getLedgerId(), messageId.getEntryId())).get();` can't

[GitHub] [pulsar] opera33 commented on issue #7482: ERROR org.apache.bookkeeper.common.util.SafeRunnable - Unexpected throwable caught java.lang.ArrayIndexOutOfBoundsException: 100 while starting bro

opera33 commented on issue #7482: URL: https://github.com/apache/pulsar/issues/7482#issuecomment-655542318 Hi, Didn't change that, if that help, I can try setting it. Thanks! On Wed, 8 Jul 2020, 21:45 lipenghui, wrote: > @opera33 Did

[GitHub] [pulsar] codelipenghui commented on issue #7482: ERROR org.apache.bookkeeper.common.util.SafeRunnable - Unexpected throwable caught java.lang.ArrayIndexOutOfBoundsException: 100 while starti

codelipenghui commented on issue #7482: URL: https://github.com/apache/pulsar/issues/7482#issuecomment-655536435 @opera33 I have created a PR #7483 for fixing this problem, thanks for your feedback. This is an automated

[GitHub] [pulsar] codelipenghui opened a new pull request #7483: Fix ArrayIndexOutOfBoundsException when dispatch messages to consumer.

codelipenghui opened a new pull request #7483: URL: https://github.com/apache/pulsar/pull/7483 Fixes #7482 ### Motivation Fix ArrayIndexOutOfBoundsException when dispatch messages to consumer. ### Does this pull request potentially affect one of the following parts:

[GitHub] [pulsar] codelipenghui removed a comment on issue #7482: ERROR org.apache.bookkeeper.common.util.SafeRunnable - Unexpected throwable caught java.lang.ArrayIndexOutOfBoundsException: 100 whil

codelipenghui removed a comment on issue #7482: URL: https://github.com/apache/pulsar/issues/7482#issuecomment-655529915 @opera33 Did you change the `dispatcherMaxRoundRobinBatchSize` in the broker.conf? This is an

[GitHub] [pulsar] codelipenghui commented on issue #7482: ERROR org.apache.bookkeeper.common.util.SafeRunnable - Unexpected throwable caught java.lang.ArrayIndexOutOfBoundsException: 100 while starti

codelipenghui commented on issue #7482: URL: https://github.com/apache/pulsar/issues/7482#issuecomment-655529915 @opera33 Did you change the `dispatcherMaxRoundRobinBatchSize` in the broker.conf? This is an automated

[GitHub] [pulsar] vzhikserg commented on issue #7385: When `authorizationEnabled=true` in proxy.conf the proxy does not appear to perform Authorization check

vzhikserg commented on issue #7385: URL: https://github.com/apache/pulsar/issues/7385#issuecomment-655521061 We see the same behavior using 2.6.0 on AKS deployment when connecting (jwt) via proxy with authentication and authorization enabled (using zookeeper): - Client has no

[GitHub] [pulsar] codelipenghui commented on pull request #7430: Handle NotAllowed Exception at the client side.

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

[GitHub] [pulsar] codelipenghui commented on a change in pull request #7299: [Issue 6437][broker] Prevent marker messages from accumulating in backlog of replicated subscription

codelipenghui commented on a change in pull request #7299: URL: https://github.com/apache/pulsar/pull/7299#discussion_r451542303 ## File path: pulsar-broker/src/main/java/org/apache/pulsar/broker/service/persistent/ReplicatedSubscriptionsController.java ## @@ -70,6 +74,56 @@

[GitHub] [pulsar] codelipenghui commented on pull request #7473: [pulsar-broker] Cleanup already deleted namespace topics

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

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

codelipenghui edited a comment on issue #7455: URL: https://github.com/apache/pulsar/issues/7455#issuecomment-655510237 This is an automated message from the Apache Git Service. To respond to the message, please log on to

[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-655510237 @feeblefakie could you please give me a broker dump and inconsistency logs like https://github.com/apache/pulsar/issues/7455#issuecomment-654763271 ? I want to check the

[GitHub] [pulsar-client-go] snowcrumble opened a new pull request #314: Add interceptor

snowcrumble opened a new pull request #314: URL: https://github.com/apache/pulsar-client-go/pull/314 ### Motivation Add A chain of interceptors for Producer and Consumer as an option, these interceptors will be called at some points, it can be used for tracing, metrics, and so on.

[GitHub] [pulsar] ivankelly commented on a change in pull request #7475: Use CGroup CPU usage when present

ivankelly commented on a change in pull request #7475: URL: https://github.com/apache/pulsar/pull/7475#discussion_r451470550 ## File path: pulsar-broker/src/main/java/org/apache/pulsar/broker/loadbalance/impl/LinuxBrokerHostUsageImpl.java ## @@ -87,45 +100,36 @@ public void

[GitHub] [pulsar] opera33 opened a new issue #7482: ERROR org.apache.bookkeeper.common.util.SafeRunnable - Unexpected throwable caught java.lang.ArrayIndexOutOfBoundsException: 100 while starting bro

opera33 opened a new issue #7482: URL: https://github.com/apache/pulsar/issues/7482 **Describe the bug** Getting error while trying to start broker in a 2 node cluster mode, with over 200 pulsar functions registered to it. **To Reproduce** I have freshly setup the cluster, and

[GitHub] [pulsar] sxpsxp12 commented on issue #7479: support pulsar consumer keyshared in C++ And Cgo

sxpsxp12 commented on issue #7479: URL: https://github.com/apache/pulsar/issues/7479#issuecomment-655444381 remarks: C++ consumer use subscribeWithRegex() This is an automated message from the Apache Git Service. To

[GitHub] [pulsar-client-go] snowcrumble commented on issue #52: Catch up Java client function list

snowcrumble commented on issue #52: URL: https://github.com/apache/pulsar-client-go/issues/52#issuecomment-655434696 > > Is there any plan for Interceptor? > > The feature LGTM+1, @snowcrumble If you are interested in this, can you send a pull request to impl this? OK, I

[GitHub] [pulsar] anvinjain opened a new issue #7481: Default value and in-line doc for bookkeeper config: openLedgerRereplicationGracePeriod is incorrect

anvinjain opened a new issue #7481: URL: https://github.com/apache/pulsar/issues/7481 **Describe the bug** Default bookkeeper conf that ships with apache pulsar indicates that the unit of `openLedgerRereplicationGracePeriod` is in seconds, but official bookkeeper doc(and code) mentions

[GitHub] [pulsar] sxpsxp12 opened a new issue #7480: native go v0.1.1 No support produce batch？

sxpsxp12 opened a new issue #7480: URL: https://github.com/apache/pulsar/issues/7480 **Describe the bug** native go v0.1.1 No support produce batch？ **To Reproduce** Steps to reproduce the behavior: 1. Go to '...' 2. Click on '' 3. Scroll down to '' 4. See

[GitHub] [pulsar] junquero commented on pull request #7462: [Doc]--add authentication client with oauth2 support

junquero commented on pull request #7462: URL: https://github.com/apache/pulsar/pull/7462#issuecomment-655402390 Does this plugin automatically get a new token when it expires? This is an automated message from the Apache

[GitHub] [pulsar] sxpsxp12 commented on issue #7479: support pulsar consumer keyshared in C++ And Cgo

sxpsxp12 commented on issue #7479: URL: https://github.com/apache/pulsar/issues/7479#issuecomment-655400511 pulsar broker change to 2.5.2, keyshared work ok；so, it is broker‘s problem? This is an automated message from the

[GitHub] [pulsar] sxpsxp12 opened a new issue #7479: support pulsar consumer keyshared in C++ And Cgo

sxpsxp12 opened a new issue #7479: URL: https://github.com/apache/pulsar/issues/7479 **Describe the bug** in pulsar 2.6.0，pulsar C++ client(newest) use keyshared policy，but consumer.receive() return timeout；when use other consumer type, it return pulsar data normally。 Above

[GitHub] [pulsar] ltamber opened a new issue #7478: pulsar-admin reset cursor hangs

ltamber opened a new issue #7478: URL: https://github.com/apache/pulsar/issues/7478 **Describe the bug** the thread stack below is one of pulsar-web thread pool. ```java "pulsar-web-54-19" #450 prio=5 os_prio=0 tid=0x7fcbb40b7000 nid=0x1db1 waiting on condition

[GitHub] [pulsar] Jennifer88huang commented on pull request #7471: [WIP] Add sidebar for "Pulasr SNI routing with ATS" content

Jennifer88huang commented on pull request #7471: URL: https://github.com/apache/pulsar/pull/7471#issuecomment-655367381 @rdhabalia Thank you again for your advice. I've finished refining the content. PTAL again, thank you. Meanwhile, I've adopted your original heading styles, and you

[GitHub] [pulsar] lbenc135 opened a new issue #7477: [python-client 2.6.0] ContextualVersionConflict grpcio dependency conflict

lbenc135 opened a new issue #7477: URL: https://github.com/apache/pulsar/issues/7477 **Describe the bug** When installing `pulsar-client==2.6.0` there's a dependency conflict with `grpcio` library. The dependency tree is (as I understand it): - pulsar-client - grpcio

[GitHub] [pulsar] aloyszhang edited a comment on issue #7476: Discovery service can't find active broker

aloyszhang edited a comment on issue #7476: URL: https://github.com/apache/pulsar/issues/7476#issuecomment-655260885 Addtionally, search zookkeeper cluster , no error found. And we dump the discovery process, found that `BrokerDiscoveryProvider` does not has availableBrokers in its

[GitHub] [pulsar-client-go] zymap opened a new pull request #313: Support oauth2 authentication for pulsar-client-go

zymap opened a new pull request #313: URL: https://github.com/apache/pulsar-client-go/pull/313 *Motivation* Support oauth2 authentication for pulsar-client-go This is an automated message from the Apache Git Service.

[GitHub] [pulsar] jerrypeng commented on a change in pull request #7474: Log scheduler stats for Pulsar Functions

jerrypeng commented on a change in pull request #7474: URL: https://github.com/apache/pulsar/pull/7474#discussion_r451310965 ## File path: pulsar-functions/worker/src/main/java/org/apache/pulsar/functions/worker/MembershipManager.java ## @@ -225,7 +232,8 @@ public void

[GitHub] [pulsar] jerrypeng commented on a change in pull request #7474: Log scheduler stats for Pulsar Functions

jerrypeng commented on a change in pull request #7474: URL: https://github.com/apache/pulsar/pull/7474#discussion_r451308305 ## File path: pulsar-functions/worker/src/main/java/org/apache/pulsar/functions/worker/SchedulerManager.java ## @@ -368,8 +390,13 @@ private void

[GitHub] [pulsar] jerrypeng commented on a change in pull request #7474: Log scheduler stats for Pulsar Functions

jerrypeng commented on a change in pull request #7474: URL: https://github.com/apache/pulsar/pull/7474#discussion_r451308599 ## File path: pulsar-functions/worker/src/main/java/org/apache/pulsar/functions/worker/SchedulerManager.java ## @@ -526,4 +553,118 @@ static String