[GitHub] [pulsar] darksungg commented on issue #6832: Cannot connect to multiple geo-replicated partitioned topics via consumer

darksungg commented on issue #6832: URL: https://github.com/apache/pulsar/issues/6832#issuecomment-620391268 Hey @jiazhai thank you for the response. Please see below the producer (us-east), consumer(us-west) code: Producer: this.client = PulsarClient.builder()

[GitHub] [pulsar] gaoran10 commented on pull request #6034: [Pulsar IO][Issue 5633]Support avro schema for debezium connector

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

[GitHub] [pulsar] gaoran10 commented on pull request #6831: Update Jackson dependencies version to 2.10.1

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

[GitHub] [pulsar] gaoran10 commented on pull request #6034: [Pulsar IO][Issue 5633]Support avro schema for debezium connector

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

[GitHub] [pulsar] zplinuxlover commented on pull request #6775: change `org.apache.pulsar.broker.admin.impl.NamespacesBase` code

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

[GitHub] [pulsar] yangwenjie88 commented on issue #6829: pulsar-client MultiTopicsConsumerImpl frequently fullgc

yangwenjie88 commented on issue #6829: URL: https://github.com/apache/pulsar/issues/6829#issuecomment-620335502 > @yangwenjie88 Would you please have a try on use larger receiverQueueSize? Have tried to increase the size, after the increase, the memory is insufficient, resulting in

[GitHub] [pulsar] gaoran10 commented on pull request #6034: [Pulsar IO][Issue 5633]Support avro schema for debezium connector

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

[GitHub] [pulsar] jiazhai commented on issue #6832: Cannot connect to multiple geo-replicated partitioned topics via consumer

jiazhai commented on issue #6832: URL: https://github.com/apache/pulsar/issues/6832#issuecomment-620331084 @darksungg Seems the default consumer mode is exclusive, Would you please help try on a failover or shared mode?

[GitHub] [pulsar] jiazhai commented on issue #6829: pulsar-client MultiTopicsConsumerImpl frequently fullgc

jiazhai commented on issue #6829: URL: https://github.com/apache/pulsar/issues/6829#issuecomment-620327431 @yangwenjie88 Would you please have a try on use larger receiverQueueSize? This is an automated message from the

[GitHub] [pulsar] lookhua opened a new issue #6833: deploy pulsar dev,test,pro cluster at the same time , i hope the pulsar-Operator just like tidb-Operator

lookhua opened a new issue #6833: URL: https://github.com/apache/pulsar/issues/6833 **Is your feature request related to a problem? Please describe.** when i deploy pulsar cluster for dev,test,pro env ,i donot have a easy way to do it. **Describe the solution you'd like** i

[GitHub] [pulsar] nkurihar commented on pull request #6794: [Issue 6793][broker] Add config of maxNumPartitionsPerPartitionedTopic

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

[GitHub] [pulsar-client-go] zzzming opened a new pull request #236: allow empty payload for nonbatch message

zzzming opened a new pull request #236: URL: https://github.com/apache/pulsar-client-go/pull/236 ### Motivation This PR will fix a problem preventing consumer receiving empty payload with properties in non-batch mode; and empty payload without key and properties in batch mode.

[GitHub] [pulsar] darksungg edited a comment on issue #6832: Cannot connect to multiple geo-replicated partitioned topics via consumer

darksungg edited a comment on issue #6832: URL: https://github.com/apache/pulsar/issues/6832#issuecomment-620144387 Adding to this it seems that testing the issue, having 3 consumers on 1 client for each partition does not work, the second consumer gets stuck at .subscribe(). I've

[GitHub] [pulsar] darksungg commented on issue #6832: Cannot connect to multiple geo-replicated partitioned topics via consumer

darksungg commented on issue #6832: URL: https://github.com/apache/pulsar/issues/6832#issuecomment-620144387 Adding to this it seems that testing the issue, having 3 consumers on 1 client for each partition does not work, the second consumer gets stuck at .subscribe().

[GitHub] [pulsar] merlimat commented on pull request #6787: Using Readers still causes backlog quota to be observed

merlimat commented on pull request #6787: URL: https://github.com/apache/pulsar/pull/6787#issuecomment-620142566 > I think this is the minimum requirement that a reader should provide. > But a flag should be added to enable this and the default behavior is that the data shouldn't

[GitHub] [pulsar] shiv4289 commented on pull request #6782: [pulsar-storm] Fix: Authentication is failing with storm adapter

shiv4289 commented on pull request #6782: URL: https://github.com/apache/pulsar/pull/6782#issuecomment-620128102 > Umm.. If we serialize `AuthenticationToken` then it won't serialize token and store it instead it tries to serialize tokenSupplier and if supplier fetches token dynamically

[GitHub] [pulsar] BewareMyPower removed a comment on pull request #6827: [Issue 6822][C++] Fix segmentation fault if handleSendTimeout() is called after closeAsync()

BewareMyPower removed a comment on pull request #6827: URL: https://github.com/apache/pulsar/pull/6827#issuecomment-619660511 This is an automated message from the Apache Git Service. To respond to the message, please log on

[GitHub] [pulsar] BewareMyPower removed a comment on pull request #6827: [Issue 6822][C++] Fix segmentation fault if handleSendTimeout() is called after closeAsync()

BewareMyPower removed a comment on pull request #6827: URL: https://github.com/apache/pulsar/pull/6827#issuecomment-619583348 /pulsarbot run-failure-checks This is an automated message from the Apache Git Service. To respond

[GitHub] [pulsar-client-go] wolfstudy commented on issue #234: Cannot build the project

wolfstudy commented on issue #234: URL: https://github.com/apache/pulsar-client-go/issues/234#issuecomment-620087896 > @wolfstudy I installed the libraries. Seems correct but now I get another build error. I updated the bug description. They are just some warning logs, in fact,

[GitHub] [pulsar-client-go] wolfstudy edited a comment on issue #234: Cannot build the project

wolfstudy edited a comment on issue #234: URL: https://github.com/apache/pulsar-client-go/issues/234#issuecomment-620083839 > Another thing I am thinking, wouldn't it be better to offer the Go client with those binaries already built? Yes, for different versions, we have provided

[GitHub] [pulsar-client-go] wolfstudy edited a comment on issue #234: Cannot build the project

wolfstudy edited a comment on issue #234: URL: https://github.com/apache/pulsar-client-go/issues/234#issuecomment-620083839 > Another thing I am thinking, wouldn't it be better to offer the Go client with those binaries already built? Yes, for different versions, we have provided

[GitHub] [pulsar-client-go] wolfstudy edited a comment on issue #234: Cannot build the project

wolfstudy edited a comment on issue #234: URL: https://github.com/apache/pulsar-client-go/issues/234#issuecomment-620085461 > Thank you, I am going to look at it and see if I can build and that was the issue. If possible, you can use the native go client to instead cgo client. As

[GitHub] [pulsar-client-go] wolfstudy edited a comment on issue #234: Cannot build the project

wolfstudy edited a comment on issue #234: URL: https://github.com/apache/pulsar-client-go/issues/234#issuecomment-620085461 > Thank you, I am going to look at it and see if I can build and that was the issue. If possible, you can use the native go client to instead cgo client. As

[GitHub] [pulsar-client-go] wolfstudy commented on issue #234: Cannot build the project

wolfstudy commented on issue #234: URL: https://github.com/apache/pulsar-client-go/issues/234#issuecomment-620085461 > Thank you, I am going to look at it and see if I can build and that was the issue. If possible, you can use the native go client to instead cgo client. As docs

[GitHub] [pulsar-client-go] wolfstudy commented on issue #234: Cannot build the project

wolfstudy commented on issue #234: URL: https://github.com/apache/pulsar-client-go/issues/234#issuecomment-620083839 > Another thing I am thinking, wouldn't it be better to offer the Go client with those binaries already built? Yes, for different versions, we have provided the

[GitHub] [pulsar] surendra-k edited a comment on issue #6821: Pulsar+SSL Java client issue (TLS encryption) via Nginx

surendra-k edited a comment on issue #6821: URL: https://github.com/apache/pulsar/issues/6821#issuecomment-619983341 Nginx points to broker, didn't get 'how did you setup Nginx?' same thing is working with Python, but failing with Java. from logs Server and Client able to

[GitHub] [pulsar] darksungg opened a new issue #6832: Cannot connect to multiple geo-replicated partitioned topics via consumer

darksungg opened a new issue #6832: URL: https://github.com/apache/pulsar/issues/6832 We are using the geo-repliated model, producing in US-East via a partitioned topic (persistent://my-tenant/my-namespace/my-topic). Looking in US-West, we can see

[GitHub] [pulsar] surendra-k commented on issue #6821: Pulsar+SSL Java client issue (TLS encryption) via Nginx

surendra-k commented on issue #6821: URL: https://github.com/apache/pulsar/issues/6821#issuecomment-619983341 Nginx points to broker, couldn't get 'how did you setup Nginx?' same thing is working with Python, but failing with Java

[GitHub] [pulsar] surendra-k edited a comment on issue #6821: Pulsar+SSL Java client issue (TLS encryption) via Nginx

surendra-k edited a comment on issue #6821: URL: https://github.com/apache/pulsar/issues/6821#issuecomment-619983341 Nginx points to broker, didn't get 'how did you setup Nginx?' same thing is working with Python, but failing with Java

[GitHub] [pulsar] BewareMyPower commented on pull request #6827: [Issue 6822][C++] Fix segmentation fault if handleSendTimeout() is called after closeAsync()

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

[GitHub] [pulsar] hangc0276 commented on pull request #6814: Expose managed ledger bookie client metric to prometheus

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

[GitHub] [pulsar] BewareMyPower commented on pull request #6827: [Issue 6822][C++] Fix segmentation fault if handleSendTimeout() is called after closeAsync()

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

[GitHub] [pulsar-client-go] cornelk commented on issue #223: Reader can not read new messages after subscribing with LatestMessageID

cornelk commented on issue #223: URL: https://github.com/apache/pulsar-client-go/issues/223#issuecomment-619909447 What would be code that makes use of `LatestMessageID()` and is able to read the `hello-1` message? I expect to be able to read `hello-1` as latest message somehow,

[GitHub] [pulsar] javard commented on issue #6813: Function gets stuck in the context.getState() method

javard commented on issue #6813: URL: https://github.com/apache/pulsar/issues/6813#issuecomment-619897031 @sijie I think it's enabled. When I run in localrun without the flag `--state-storage-service-url` it throws the exception `java.lang.IllegalStateException: State is not enabled`.

[GitHub] [pulsar] gaoran10 opened a new pull request #6831: Update Jackson dependencies version to 2.10.1

gaoran10 opened a new pull request #6831: URL: https://github.com/apache/pulsar/pull/6831 # Motivation Update Jackson dependencies version to 2.10.1 for some security reasons, the update details are as follows. # Modify 1. org.apache.pulsar.examples:spark

[GitHub] [pulsar] sijie commented on pull request #6816: update topicName document to avoid confusion

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

[GitHub] [pulsar] sijie commented on pull request #6799: optional auth method name header in http authentication

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

[pulsar] branch master updated: [docs] Fix encryption examples (#6763)

This is an automated email from the ASF dual-hosted git repository. sijie 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 65ff6ac [docs] Fix encryption examples (#6763)

[pulsar] branch master updated (7bbba37 -> 5ec9d7b)

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 7bbba37 File connector should have type `source` in download page (#6826) add 5ec9d7b [PY] Fix serialization

[pulsar] branch master updated (1f852ee -> 7bbba37)

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 1f852ee Adjust version order (#6817) add 7bbba37 File connector should have type `source` in download page

[GitHub] [pulsar] sijie commented on issue #4937: Retrieve schema instance from schema info for type 'NONE'

sijie commented on issue #4937: URL: https://github.com/apache/pulsar/issues/4937#issuecomment-619797951 @gh77 what version of python function are you using? This is an automated message from the Apache Git Service. To

[GitHub] [pulsar] sijie commented on pull request #6787: Using Readers still causes backlog quota to be observed

sijie commented on pull request #6787: URL: https://github.com/apache/pulsar/pull/6787#issuecomment-619795865 > A file system is also operating within system constraints. When the disk (or user quota) is full, some actions will have to be taken. Correct. But the semantic is still

[GitHub] [pulsar] sijie commented on pull request #6796: Support cumulative acknowledgement when consuming partitioned topics for C++ client

sijie commented on pull request #6796: URL: https://github.com/apache/pulsar/pull/6796#issuecomment-619791334 > for a given message id, of all the highest message ids in the other partitions that we were queued before it in the shared queue. ackCumulative can work either case. It

[GitHub] [pulsar] sijie commented on pull request #6791: Use consistent hashing in KeyShared distribution

sijie commented on pull request #6791: URL: https://github.com/apache/pulsar/pull/6791#issuecomment-619788403 > the original question on having a configuration switch. Yes. I think the question is to have a configuration switch to allow people to deprecate the current

[pulsar-helm-chart] branch master updated: Fix namespace delete command in cleanup-helm-release.sh script (#5)

This is an automated email from the ASF dual-hosted git repository. sijie pushed a commit to branch master in repository https://gitbox.apache.org/repos/asf/pulsar-helm-chart.git The following commit(s) were added to refs/heads/master by this push: new 3e451fe Fix namespace delete command

[GitHub] [pulsar] BewareMyPower commented on pull request #6827: [Issue 6822][C++] Fix segmentation fault if handleSendTimeout() is called after closeAsync()

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