Re: [PR] [improve][client] Add a warn log for calling reconsumeLater for a no-shared subscription [pulsar]

2024-07-12 Thread via GitHub
liangyepianzhou closed pull request #22330: [improve][client] Add a warn log for calling reconsumeLater for a no-shared subscription URL: https://github.com/apache/pulsar/pull/22330 -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub

[PR] [fix] [broker] Fix stuck when enable topic level replication and build remote admin fails [pulsar]

2024-07-12 Thread via GitHub
poorbarcode opened a new pull request, #23028: URL: https://github.com/apache/pulsar/pull/23028 ### Motivation The method `BrokerService. getClusterPulsarAdmin` will throw exceptions and the method `topics set replicated clusters` did not catch the exception, which leads to the compl

(pulsar) branch branch-3.2 updated: [fix][broker] Fix geo-replication admin client url (#22584)

2024-07-12 Thread yubiao
This is an automated email from the ASF dual-hosted git repository. yubiao pushed a commit to branch branch-3.2 in repository https://gitbox.apache.org/repos/asf/pulsar.git The following commit(s) were added to refs/heads/branch-3.2 by this push: new 56bdf7a58af [fix][broker] Fix geo-replic

(pulsar) branch branch-3.3 updated: [fix][broker] Fix geo-replication admin client url (#22584)

2024-07-12 Thread yubiao
This is an automated email from the ASF dual-hosted git repository. yubiao pushed a commit to branch branch-3.3 in repository https://gitbox.apache.org/repos/asf/pulsar.git The following commit(s) were added to refs/heads/branch-3.3 by this push: new 259a75af571 [fix][broker] Fix geo-replic

(pulsar) branch branch-3.0 updated: [fix][broker] Fix geo-replication admin client url (#22584)

2024-07-12 Thread yubiao
This is an automated email from the ASF dual-hosted git repository. yubiao pushed a commit to branch branch-3.0 in repository https://gitbox.apache.org/repos/asf/pulsar.git The following commit(s) were added to refs/heads/branch-3.0 by this push: new 3ccc2136ff0 [fix][broker] Fix geo-replic

Re: [I] Add ack timeout support [pulsar-client-go]

2024-07-12 Thread via GitHub
justinrixx commented on issue #403: URL: https://github.com/apache/pulsar-client-go/issues/403#issuecomment-2226402482 >No. You should either use `Nack` or `ReconsumeLater` to redelivery those messages. Is this the recommendation for handling errors from `Ack`? (processing is alread

[PR] fix: producer close was blocked [pulsar-client-go]

2024-07-12 Thread via GitHub
nodece opened a new pull request, #1249: URL: https://github.com/apache/pulsar-client-go/pull/1249 ### Motivation When the producer keeps reconnecting to the broker in the event loop, at the same time, the user calls `producer.Close`, the producer cannot be closed, because the event

Re: [PR] add topic naming note [pulsar-site]

2024-07-12 Thread via GitHub
tisonkun commented on code in PR #939: URL: https://github.com/apache/pulsar-site/pull/939#discussion_r1676189425 ## docs/admin-api-topics.md: ## @@ -34,6 +34,12 @@ Non-persistent topics are used in applications that only consume real-time publi non-persistent://tenant/namespa

Re: [PR] add topic naming note [pulsar-site]

2024-07-12 Thread via GitHub
tisonkun commented on code in PR #939: URL: https://github.com/apache/pulsar-site/pull/939#discussion_r1676188764 ## docs/admin-api-topics.md: ## @@ -34,6 +34,10 @@ Non-persistent topics are used in applications that only consume real-time publi non-persistent://tenant/namespa

(pulsar-site) branch main updated: Fix typos in concepts-broker-load-balancing-quick-start.md (#940)

2024-07-12 Thread tison
This is an automated email from the ASF dual-hosted git repository. tison pushed a commit to branch main in repository https://gitbox.apache.org/repos/asf/pulsar-site.git The following commit(s) were added to refs/heads/main by this push: new da4cd0945d6e Fix typos in concepts-broker-load-

Re: [PR] Fix typos in concepts-broker-load-balancing-quick-start.md [pulsar-site]

2024-07-12 Thread via GitHub
tisonkun merged PR #940: URL: https://github.com/apache/pulsar-site/pull/940 -- 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...@pulsar.

(pulsar-site) branch main updated: Bump zipp from 3.16.2 to 3.19.1 in /tools/pytools (#938)

2024-07-12 Thread tison
This is an automated email from the ASF dual-hosted git repository. tison pushed a commit to branch main in repository https://gitbox.apache.org/repos/asf/pulsar-site.git The following commit(s) were added to refs/heads/main by this push: new a5ef4cc3ab05 Bump zipp from 3.16.2 to 3.19.1 in

(pulsar-site) branch dependabot/pip/tools/pytools/zipp-3.19.1 deleted (was 1a39d355f41e)

2024-07-12 Thread tison
This is an automated email from the ASF dual-hosted git repository. tison pushed a change to branch dependabot/pip/tools/pytools/zipp-3.19.1 in repository https://gitbox.apache.org/repos/asf/pulsar-site.git was 1a39d355f41e Bump zipp from 3.16.2 to 3.19.1 in /tools/pytools The revisions th

Re: [PR] Bump zipp from 3.16.2 to 3.19.1 in /tools/pytools [pulsar-site]

2024-07-12 Thread via GitHub
tisonkun merged PR #938: URL: https://github.com/apache/pulsar-site/pull/938 -- 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...@pulsar.

(pulsar-client-go) branch master updated: fix: fix producer connection (#1243)

2024-07-12 Thread zixuan
This is an automated email from the ASF dual-hosted git repository. zixuan 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 29f27791 fix: fix producer connection

Re: [PR] fix: fix producer connection [pulsar-client-go]

2024-07-12 Thread via GitHub
nodece merged PR #1243: URL: https://github.com/apache/pulsar-client-go/pull/1243 -- 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...@pu

(pulsar-client-go) branch master updated: improve: install golang by image in the Dockerfile (#1246)

2024-07-12 Thread zixuan
This is an automated email from the ASF dual-hosted git repository. zixuan 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 f7e34f33 improve: install golang by im

Re: [PR] improve: install golang by image in the Dockerfile [pulsar-client-go]

2024-07-12 Thread via GitHub
nodece merged PR #1246: URL: https://github.com/apache/pulsar-client-go/pull/1246 -- 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...@pu

[PR] fix: failTimeoutMessages cannot delete outdated messages [pulsar-client-go]

2024-07-12 Thread via GitHub
nodece opened a new pull request, #1247: URL: https://github.com/apache/pulsar-client-go/pull/1247 Fixes #1236 ### Motivation When the producer reconnects to the broker, resending the pending messages, and changing the `sentAt`, this will break the `failTimeoutMessages` featur

Re: [PR] [fix] [broker] Internal reader of __change_events can not started after metadata store session rebuilt [pulsar]

2024-07-12 Thread via GitHub
merlimat commented on code in PR #23018: URL: https://github.com/apache/pulsar/pull/23018#discussion_r1675502556 ## pulsar-metadata/src/main/java/org/apache/pulsar/metadata/impl/AbstractMetadataStore.java: ## @@ -496,6 +496,17 @@ public void registerSessionListener(Consumer lis

Re: [PR] fix: fix producer connection [pulsar-client-go]

2024-07-12 Thread via GitHub
nodece commented on PR #1243: URL: https://github.com/apache/pulsar-client-go/pull/1243#issuecomment-2225042183 When the `test_extensible_load_manager` and `blue-green migration test` fail, it is difficult for us to debug the code, because this test runs on the container, not host. -- T

Re: [PR] Add changelog for 0.13.0 [pulsar-client-go]

2024-07-12 Thread via GitHub
nodece commented on PR #1245: URL: https://github.com/apache/pulsar-client-go/pull/1245#issuecomment-2225036847 Could you add the breaking changes section? -- 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

[PR] improve: install golang by image in the Dockerfile [pulsar-client-go]

2024-07-12 Thread via GitHub
nodece opened a new pull request, #1246: URL: https://github.com/apache/pulsar-client-go/pull/1246 ### Motivation The Dockerfile looks unsupport the ARM arch, which always downloads the golang of the AMD arch. ### Modifications - Use golang image to install the golang in

Re: [PR] [improve] [pip] PIP-363: Add callback parameters to the method: org.apache.pulsar.client.impl.SendCallback.sendComplete. [pulsar]

2024-07-12 Thread via GitHub
crossoverJie commented on PR #22940: URL: https://github.com/apache/pulsar/pull/22940#issuecomment-2224974140 @lhotari @Technoboy- Could you please vote [here](https://lists.apache.org/thread/t0olt3722j17gjtdxqqsl3cpy104ogpr)? Thank you. -- This is an automated message from the Apache Gi

[I] [improve][broker] cursor read entry would trigger readMoreEntry() one more time when addWaitingCursor and notify [pulsar]

2024-07-12 Thread via GitHub
TakaHiR07 opened a new issue, #23027: URL: https://github.com/apache/pulsar/issues/23027 ### Search before asking - [X] I searched in the [issues](https://github.com/apache/pulsar/issues) and found nothing similar. ### Motivation As the code shown, even if we disable

Re: [PR] fix: fix producer connection [pulsar-client-go]

2024-07-12 Thread via GitHub
nodece commented on code in PR #1243: URL: https://github.com/apache/pulsar-client-go/pull/1243#discussion_r1675408154 ## pulsar/producer_partition.go: ## @@ -292,12 +292,12 @@ func (p *partitionProducer) grabCnx(assignedBrokerURL string) error { } } -