[GitHub] [pulsar] wolfstudy commented on issue #5822: Expose bookkeeper expose explicit lac configuration in broker.conf

wolfstudy commented on issue #5822: Expose bookkeeper expose explicit lac configuration in broker.conf URL: https://github.com/apache/pulsar/pull/5822#issuecomment-570764288 run java8 tests run integration tests This is an

[GitHub] [pulsar] wolfstudy commented on issue #5856: Make standalone to advertise "localhost" to avoid failure when hostname is not resolvable

wolfstudy commented on issue #5856: Make standalone to advertise "localhost" to avoid failure when hostname is not resolvable URL: https://github.com/apache/pulsar/pull/5856#issuecomment-570764208 run java8 tests This is an a

[GitHub] [pulsar] imankulov commented on issue #2219: Cpp client: add PatternMultiTopicsConsumerImpl to support regex subscribe

imankulov commented on issue #2219: Cpp client: add PatternMultiTopicsConsumerImpl to support regex subscribe URL: https://github.com/apache/pulsar/pull/2219#issuecomment-570763857 Looks like the client-feature matrix can now be updated. [ref](https://github.com/apache/pulsar/wiki/Client-F

[GitHub] [pulsar] huangdx0726 commented on issue #5716: [Issues 5709]remove the namespace checking

huangdx0726 commented on issue #5716: [Issues 5709]remove the namespace checking URL: https://github.com/apache/pulsar/pull/5716#issuecomment-570763061 retest this please This is an automated message from the Apache Git Servic

[GitHub] [pulsar] zzzming opened a new pull request #5990: [Issue 5969] prevent redelivery of acked batch message at the client api

zzzming opened a new pull request #5990: [Issue 5969] prevent redelivery of acked batch message at the client api URL: https://github.com/apache/pulsar/pull/5990 ### Motivation To address redelivered of acked batch message described by https://github.com/apache/pulsar/issues/5969

[GitHub] [pulsar-client-go] merlimat opened a new pull request #163: Fixed reading from connection

merlimat opened a new pull request #163: Fixed reading from connection URL: https://github.com/apache/pulsar-client-go/pull/163 ### Motivation Fixes #147 There is bug in the `connection_reader` routine. If a frame is spanning multiple IP packets, it might get the case wher

[GitHub] [pulsar-client-go] merlimat opened a new pull request #162: Avoid double cnx close notification on graceful server side close

merlimat opened a new pull request #162: Avoid double cnx close notification on graceful server side close URL: https://github.com/apache/pulsar-client-go/pull/162 ### Motivation We're processing the "connection closed" event twice when the broker sends a "producer closed" or "consu

[GitHub] [pulsar] jiazhai commented on issue #5969: Acked messages unexpectedly redelivered when others are negatively acked

jiazhai commented on issue #5969: Acked messages unexpectedly redelivered when others are negatively acked URL: https://github.com/apache/pulsar/issues/5969#issuecomment-570743967 Oh, since it is also related to transaction implementation, Penghui and me are already writing a PIP for this.

[GitHub] [pulsar-client-go] merlimat commented on a change in pull request #158: Topic reader implementation

merlimat commented on a change in pull request #158: Topic reader implementation URL: https://github.com/apache/pulsar-client-go/pull/158#discussion_r363005180 ## File path: pulsar/consumer_partition.go ## @@ -109,9 +129,11 @@ func newPartitionConsumer(parent Consumer, clie

[GitHub] [pulsar-client-go] cckellogg commented on issue #147: consumer.Receive () is blocking, availablePermits are decreasing, but msgBacklog is increasing

cckellogg commented on issue #147: consumer.Receive () is blocking, availablePermits are decreasing, but msgBacklog is increasing URL: https://github.com/apache/pulsar-client-go/issues/147#issuecomment-570726574 What version of the client are you using? There is PR up (https://github.com/

[GitHub] [pulsar] gmethvin opened a new pull request #5989: [docs] Improve documentation about batching

gmethvin opened a new pull request #5989: [docs] Improve documentation about batching URL: https://github.com/apache/pulsar/pull/5989 I noticed the documentation around batching didn't clarify some important details about how batching works in Pulsar, and particularly how it interacts wit

[GitHub] [pulsar-client-go] cckellogg commented on a change in pull request #158: Topic reader implementation

cckellogg commented on a change in pull request #158: Topic reader implementation URL: https://github.com/apache/pulsar-client-go/pull/158#discussion_r362986826 ## File path: pulsar/consumer_partition.go ## @@ -109,9 +129,11 @@ func newPartitionConsumer(parent Consumer, cl

[GitHub] [pulsar-client-go] merlimat commented on a change in pull request #157: [issue:144] Add retry logic when get connection error

merlimat commented on a change in pull request #157: [issue:144] Add retry logic when get connection error URL: https://github.com/apache/pulsar-client-go/pull/157#discussion_r362985749 ## File path: pulsar/internal/connection_pool.go ## @@ -65,7 +65,7 @@ func (p *connecti

[GitHub] [pulsar-client-go] merlimat opened a new pull request #161: Fixed the connection pool logic

merlimat opened a new pull request #161: Fixed the connection pool logic URL: https://github.com/apache/pulsar-client-go/pull/161 ### Motivation The PR #146 has completely broken the connection pool logic. Closed/failed connection are not being evicted from the pool anymore, resultin

[GitHub] [pulsar] EugenDueck commented on issue #5230: Allow for topic deletions with regex consumers

EugenDueck commented on issue #5230: Allow for topic deletions with regex consumers URL: https://github.com/apache/pulsar/pull/5230#issuecomment-570719171 @wolfstudy > The pr change the proto file, will move the milestone to `2.5.0` Will this retroactively fix the [changelog

[GitHub] [pulsar-client-go] merlimat commented on a change in pull request #158: Topic reader implementation

merlimat commented on a change in pull request #158: Topic reader implementation URL: https://github.com/apache/pulsar-client-go/pull/158#discussion_r362947111 ## File path: pulsar/consumer_partition.go ## @@ -516,15 +577,27 @@ func (pc *partitionConsumer) grabConn() error

[GitHub] [pulsar] rdhabalia opened a new pull request #5988: [pulsar-broker] Clean up closed producer to avoid publish-time for producer

rdhabalia opened a new pull request #5988: [pulsar-broker] Clean up closed producer to avoid publish-time for producer URL: https://github.com/apache/pulsar/pull/5988 ### Motivation We found many instances where broker close the producer without clearing from cache, because of that

[GitHub] [pulsar-client-go] merlimat opened a new pull request #160: Set delay delivery when publishing a message

merlimat opened a new pull request #160: Set delay delivery when publishing a message URL: https://github.com/apache/pulsar-client-go/pull/160 ### Motivation Fixes #150 . Added support for delay delivery This is an aut

[GitHub] [pulsar] cdbartholomew commented on issue #5969: Acked messages unexpectedly redelivered when others are negatively acked

cdbartholomew commented on issue #5969: Acked messages unexpectedly redelivered when others are negatively acked URL: https://github.com/apache/pulsar/issues/5969#issuecomment-570642173 @jerrypeng @sijie @gmethvin I agree that redelivering batches is OK in most cases. Redelivery of unacked

[GitHub] [pulsar-client-go] merlimat commented on a change in pull request #158: Topic reader implementation

merlimat commented on a change in pull request #158: Topic reader implementation URL: https://github.com/apache/pulsar-client-go/pull/158#discussion_r362894857 ## File path: pulsar/consumer_partition.go ## @@ -516,15 +577,27 @@ func (pc *partitionConsumer) grabConn() error

[GitHub] [pulsar-client-go] merlimat commented on a change in pull request #158: Topic reader implementation

merlimat commented on a change in pull request #158: Topic reader implementation URL: https://github.com/apache/pulsar-client-go/pull/158#discussion_r362880370 ## File path: pulsar/consumer_partition.go ## @@ -247,7 +294,7 @@ func (pc *partitionConsumer) MessageReceived(res

[GitHub] [pulsar] Fransvanierland opened a new issue #5987: New feature

Fransvanierland opened a new issue #5987: New feature URL: https://github.com/apache/pulsar/issues/5987 I was wondering if we could add Quality of Stream to set stream priority in a stream . Labeling streams based on priority and shortest route,AKA Cost path> . Something broader than t

[GitHub] [pulsar] thlautenschlaeger commented on issue #5912: "UNAVAILABLE: io exception" pulsar functions

thlautenschlaeger commented on issue #5912: "UNAVAILABLE: io exception" pulsar functions URL: https://github.com/apache/pulsar/issues/5912#issuecomment-570614523 thank you for your help! got it working now. changed the permissions for the pulsar function files download directory th

[GitHub] [pulsar] thlautenschlaeger closed issue #5912: "UNAVAILABLE: io exception" pulsar functions

thlautenschlaeger closed issue #5912: "UNAVAILABLE: io exception" pulsar functions URL: https://github.com/apache/pulsar/issues/5912 This is an automated message from the Apache Git Service. To respond to the message, please

[GitHub] [pulsar] jiazhai commented on issue #5716: [Issues 5709]remove the namespace checking

jiazhai commented on issue #5716: [Issues 5709]remove the namespace checking URL: https://github.com/apache/pulsar/pull/5716#issuecomment-570612446 @huangdx0726 Is the unit test passed locally? They are still fail in the CI: https://builds.apache.org/job/pulsar_precommit_java8/141

[GitHub] [pulsar] jiazhai commented on issue #5742: [pulsar-broker] add support to configure max pending publish request per connection

jiazhai commented on issue #5742: [pulsar-broker] add support to configure max pending publish request per connection URL: https://github.com/apache/pulsar/pull/5742#issuecomment-570611497 retest this please This is an automa

[GitHub] [pulsar] jiazhai commented on issue #5822: Expose bookkeeper expose explicit lac configuration in broker.conf

jiazhai commented on issue #5822: Expose bookkeeper expose explicit lac configuration in broker.conf URL: https://github.com/apache/pulsar/pull/5822#issuecomment-570610675 run java8 tests This is an automated message from

[pulsar] branch master updated (c7094c9 -> 88fc454)

This is an automated email from the ASF dual-hosted git repository. zhaijia pushed a change to branch master in repository https://gitbox.apache.org/repos/asf/pulsar.git. from c7094c9 [Reopen][Issue 5597] Retry when getPartitionedTopicMetadata failed (#5844) add 88fc454 fix reader bu

[GitHub] [pulsar] jiazhai merged pull request #5923: Fix reader builder clone error

jiazhai merged pull request #5923: Fix reader builder clone error URL: https://github.com/apache/pulsar/pull/5923 This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub an

[GitHub] [pulsar] kaynewu opened a new pull request #5986: [4510] A host can't connect and won't try other hosts again in multi-hosts service url configuration

kaynewu opened a new pull request #5986: [4510] A host can't connect and won't try other hosts again in multi-hosts service url configuration URL: https://github.com/apache/pulsar/pull/5986 Fixes #<[4510](https://github.com/apache/pulsar/issues/4510)> Master Issue: #<[4510](https://g

[GitHub] [pulsar] codelipenghui commented on issue #5822: Expose bookkeeper expose explicit lac configuration in broker.conf

codelipenghui commented on issue #5822: Expose bookkeeper expose explicit lac configuration in broker.conf URL: https://github.com/apache/pulsar/pull/5822#issuecomment-570594441 run java8 tests run integration tests This i

[GitHub] [pulsar] jiazhai edited a comment on issue #5923: Fix reader builder clone error

jiazhai edited a comment on issue #5923: Fix reader builder clone error URL: https://github.com/apache/pulsar/pull/5923#issuecomment-570578083 run java8 tests org.apache.pulsar.broker.admin.AdminApiTlsAuthTest.setup org.apache.pulsar.client.api.DispatcherBlockConsumerTest.setup

[GitHub] [pulsar] jiazhai commented on issue #5923: Fix reader builder clone error

jiazhai commented on issue #5923: Fix reader builder clone error URL: https://github.com/apache/pulsar/pull/5923#issuecomment-570578083 run java8 tests This is an automated message from the Apache Git Service. To respond to th

[GitHub] [pulsar] tuteng commented on issue #5977: [Github Action] Clean up space before running backwards compatibility test

tuteng commented on issue #5977: [Github Action] Clean up space before running backwards compatibility test URL: https://github.com/apache/pulsar/pull/5977#issuecomment-570577127 run java8 tests This is an automated message f

[GitHub] [pulsar] wjybupt commented on issue #5947: got HTTP 404 error when running "pulsar-admin functions list" on functions-worker

wjybupt commented on issue #5947: got HTTP 404 error when running "pulsar-admin functions list" on functions-worker URL: https://github.com/apache/pulsar/issues/5947#issuecomment-570574969 ok, i will try on monday as it was deploy in the product environment which is isolate from the public

[GitHub] [pulsar] duli559 edited a comment on issue #5955: ISSUE-5934: Support read/write properties from/to Message in flink pulsar consumer/producer

duli559 edited a comment on issue #5955: ISSUE-5934: Support read/write properties from/to Message in flink pulsar consumer/producer URL: https://github.com/apache/pulsar/pull/5955#issuecomment-570463990 @sijie @yjshen , it's a good advice, i have changed it. 1. add a interface 'PulsarPr

[GitHub] [pulsar] tuteng closed issue #5597: [pulsar-client-java] retry when getPartitionedTopicMetadata failed

tuteng closed issue #5597: [pulsar-client-java] retry when getPartitionedTopicMetadata failed URL: https://github.com/apache/pulsar/issues/5597 This is an automated message from the Apache Git Service. To respond to the mess

[pulsar] branch master updated (5c58ff4 -> c7094c9)

This is an automated email from the ASF dual-hosted git repository. guangning pushed a change to branch master in repository https://gitbox.apache.org/repos/asf/pulsar.git. from 5c58ff4 [pulsar-flink]Cache Pulsar client to make it shared among tasks in a process (#5900) add c7094c9 [

[GitHub] [pulsar] wolfstudy commented on issue #5822: Expose bookkeeper expose explicit lac configuration in broker.conf

wolfstudy commented on issue #5822: Expose bookkeeper expose explicit lac configuration in broker.conf URL: https://github.com/apache/pulsar/pull/5822#issuecomment-570566119 run integration tests run java8 tests This is an

[GitHub] [pulsar] tuteng merged pull request #5844: [Reopen][Issue 5597] Retry when getPartitionedTopicMetadata failed

tuteng merged pull request #5844: [Reopen][Issue 5597] Retry when getPartitionedTopicMetadata failed URL: https://github.com/apache/pulsar/pull/5844 This is an automated message from the Apache Git Service. To respond to the

[GitHub] [pulsar] jiazhai commented on issue #5923: Fix reader builder clone error

jiazhai commented on issue #5923: Fix reader builder clone error URL: https://github.com/apache/pulsar/pull/5923#issuecomment-570565589 run java8 tests This is an automated message from the Apache Git Service. To respo

[GitHub] [pulsar] wolfstudy merged pull request #5900: [pulsar-flink]Cache Pulsar client to make it shared among tasks in a process

wolfstudy merged pull request #5900: [pulsar-flink]Cache Pulsar client to make it shared among tasks in a process URL: https://github.com/apache/pulsar/pull/5900 This is an automated message from the Apache Git Service. To r

[pulsar] branch master updated (dcaa1d3 -> 5c58ff4)

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 dcaa1d3 fix 2 copies of 3bookie and stop 2 booksie after production. After the entire bookie is restored, it can be p

[GitHub] [pulsar] tuteng commented on issue #5856: Make standalone to advertise "localhost" to avoid failure when hostname is not resolvable

tuteng commented on issue #5856: Make standalone to advertise "localhost" to avoid failure when hostname is not resolvable URL: https://github.com/apache/pulsar/pull/5856#issuecomment-570565586 run java8 tests This is an auto

[pulsar] branch master updated (cff311c -> dcaa1d3)

This is an automated email from the ASF dual-hosted git repository. zhaijia pushed a change to branch master in repository https://gitbox.apache.org/repos/asf/pulsar.git. from cff311c Update document for debezium (#5973) add dcaa1d3 fix 2 copies of 3bookie and stop 2 booksie after pr

[GitHub] [pulsar] jiazhai closed issue #5962: After stopping the bookie and recovering, it can be produced at this time, but cannot be consumed normally. Restarting the broker can resume normal

jiazhai closed issue #5962: After stopping the bookie and recovering, it can be produced at this time, but cannot be consumed normally. Restarting the broker can resume normal URL: https://github.com/apache/pulsar/issues/5962 --

[GitHub] [pulsar] jiazhai merged pull request #5965: fix 2 copies of 3bookie and stop 2 booksie after production. After t…

jiazhai merged pull request #5965: fix 2 copies of 3bookie and stop 2 booksie after production. After t… URL: https://github.com/apache/pulsar/pull/5965 This is an automated message from the Apache Git Service. To respond t

[GitHub] [pulsar] wolfstudy edited a comment on issue #5947: got HTTP 404 error when running "pulsar-admin functions list" on functions-worker

wolfstudy edited a comment on issue #5947: got HTTP 404 error when running "pulsar-admin functions list" on functions-worker URL: https://github.com/apache/pulsar/issues/5947#issuecomment-570564726 > webServiceUrl =http://functions-worker ip1:6750/ @wjybupt The pulsar-admin is using

[GitHub] [pulsar] tuteng commented on issue #5982: [Github Action] Fix flaky test

tuteng commented on issue #5982: [Github Action] Fix flaky test URL: https://github.com/apache/pulsar/pull/5982#issuecomment-570565047 retest this please This is an automated message from the Apache Git Service. To respond to

[GitHub] [pulsar] wolfstudy edited a comment on issue #5947: got HTTP 404 error when running "pulsar-admin functions list" on functions-worker

wolfstudy edited a comment on issue #5947: got HTTP 404 error when running "pulsar-admin functions list" on functions-worker URL: https://github.com/apache/pulsar/issues/5947#issuecomment-570564726 > webServiceUrl =http://:6750/ @wjybupt The pulsar-admin is using `8080`, can you try

[GitHub] [pulsar] wolfstudy commented on issue #5947: got HTTP 404 error when running "pulsar-admin functions list" on functions-worker

wolfstudy commented on issue #5947: got HTTP 404 error when running "pulsar-admin functions list" on functions-worker URL: https://github.com/apache/pulsar/issues/5947#issuecomment-570564726 > webServiceUrl =http://:6750/ The pulsar-admin is using `8080`, can you try it again? -

[GitHub] [pulsar] murong00 opened a new pull request #5985: [Issue 5935] Support multi pulsar clusters to use the same bk cluster

murong00 opened a new pull request #5985: [Issue 5935] Support multi pulsar clusters to use the same bk cluster URL: https://github.com/apache/pulsar/pull/5985 ### Motivation Fixes #5935 Support multi pulsar clusters to use the specified bookkeeper cluster by pointing `BookKe

[GitHub] [pulsar] tuteng commented on issue #5982: [Github Action] Fix flaky test

tuteng commented on issue #5982: [Github Action] Fix flaky test URL: https://github.com/apache/pulsar/pull/5982#issuecomment-570544473 retest this please This is an automated message from the Apache Git Service. To respond to

[GitHub] [pulsar] tuteng commented on issue #5977: [Github Action] Clean up space before running backwards compatibility test

tuteng commented on issue #5977: [Github Action] Clean up space before running backwards compatibility test URL: https://github.com/apache/pulsar/pull/5977#issuecomment-570544363 run java8 tests This is an automated message f

[GitHub] [pulsar-translation] Anonymitaet removed a comment on issue #16: Trans docs

Anonymitaet removed a comment on issue #16: Trans docs URL: https://github.com/apache/pulsar-translation/pull/16#issuecomment-570528717 @sijia-w I've reviewed `https://crowdin.com/translate/apache-pulsar/658/en-zhcn`. Could you please re-translate the segments that I do not approve? (I'

[GitHub] [pulsar-translation] Anonymitaet commented on issue #16: Trans docs

Anonymitaet commented on issue #16: Trans docs URL: https://github.com/apache/pulsar-translation/pull/16#issuecomment-570528717 @sijia-w I've reviewed `https://crowdin.com/translate/apache-pulsar/658/en-zhcn`. Could you please re-translate the segments that I do not approve? (I've comm

[GitHub] [pulsar] congbobo184 commented on a change in pull request #5915: Allow to enable/disable delayed delivery for messages on namespace

congbobo184 commented on a change in pull request #5915: Allow to enable/disable delayed delivery for messages on namespace URL: https://github.com/apache/pulsar/pull/5915#discussion_r362728240 ## File path: pulsar-client-admin/src/main/java/org/apache/pulsar/client/admin/Namespace

[GitHub] [pulsar] zxbfeng opened a new issue #5984: PulsarApi.proto

zxbfeng opened a new issue #5984: PulsarApi.proto URL: https://github.com/apache/pulsar/issues/5984 The file PulsarApi.pb.go in this project is used proto version 3, but I find the PulsarApi.proto file provided by https://github.com/apache/pulsar/blob/master/pulsar-common/src/main/proto/P

[GitHub] [pulsar] tuteng commented on issue #5977: [Github Action] Clean up space before running backwards compatibility test

tuteng commented on issue #5977: [Github Action] Clean up space before running backwards compatibility test URL: https://github.com/apache/pulsar/pull/5977#issuecomment-570520476 run java8 tests This is an automated message f

[GitHub] [pulsar] wolfstudy commented on issue #5918: pop up "Templating init failed " when querying topics on grafana dashboard

wolfstudy commented on issue #5918: pop up "Templating init failed " when querying topics on grafana dashboard URL: https://github.com/apache/pulsar/issues/5918#issuecomment-570518301 @dockerzhang i can't reproduce your issue. My step of reproduce: - cd deployment/kubernetes/h

[GitHub] [pulsar] abhilashmandaliya edited a comment on issue #5387: When I create many PulsarClients and Consumers, fail to resolve hostname

abhilashmandaliya edited a comment on issue #5387: When I create many PulsarClients and Consumers, fail to resolve hostname URL: https://github.com/apache/pulsar/issues/5387#issuecomment-570510416 It seems that issue is still there @hrsakai I am getting this exception: ``` 14:15:

[GitHub] [pulsar] abhilashmandaliya commented on issue #5387: When I create many PulsarClients and Consumers, fail to resolve hostname

abhilashmandaliya commented on issue #5387: When I create many PulsarClients and Consumers, fail to resolve hostname URL: https://github.com/apache/pulsar/issues/5387#issuecomment-570510416 It seems that issue is still there @hrsakai I am getting this exception: ``` 14:15:33.545

[GitHub] [pulsar] fangpengcheng95 commented on issue #5983: one small barrier in start the standalone cluster

fangpengcheng95 commented on issue #5983: one small barrier in start the standalone cluster URL: https://github.com/apache/pulsar/issues/5983#issuecomment-570507816 @Jennifer88huang @codelipenghui @zhaijack @sijie PTAL. This

[GitHub] [pulsar] fangpengcheng95 commented on issue #5983: one small barrier in start the standalone cluster

fangpengcheng95 commented on issue #5983: one small barrier in start the standalone cluster URL: https://github.com/apache/pulsar/issues/5983#issuecomment-570507709 If this issue is important enough, i can add some tips in standalone documentation.

[GitHub] [pulsar] fangpengcheng95 opened a new issue #5983: one small barrier in start the standalone cluster

fangpengcheng95 opened a new issue #5983: one small barrier in start the standalone cluster URL: https://github.com/apache/pulsar/issues/5983 **Describe the bug** When I started a local standalone cluster according to the documentation, I encountered a small problem that the standalone

[GitHub] [pulsar] tuteng commented on issue #5912: "UNAVAILABLE: io exception" pulsar functions

tuteng commented on issue #5912: "UNAVAILABLE: io exception" pulsar functions URL: https://github.com/apache/pulsar/issues/5912#issuecomment-570502781 It seems that you should check your log =>workerId/logs/functions/test/test/excfunc/excfunc-0.log @thlautenschlaeger --