Re: [PR] [fix][broker]One topic can be close multiple times concurrently [pulsar]

2024-04-15 Thread via GitHub
lhotari commented on PR #17524: URL: https://github.com/apache/pulsar/pull/17524#issuecomment-2056971640 @poorbarcode Isn't this PR still relevant? please rebase this PR. -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and

Re: [PR] [fix][sec] Upgrade Bouncycastle to 1.78 [pulsar]

2024-04-15 Thread via GitHub
lhotari merged PR #22509: URL: https://github.com/apache/pulsar/pull/22509 -- 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:

(pulsar) branch master updated: [fix][sec] Upgrade Bouncycastle to 1.78 (#22509)

2024-04-15 Thread lhotari
This is an automated email from the ASF dual-hosted git repository. lhotari 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 20915d1c438 [fix][sec] Upgrade Bouncycastle to

Re: [PR] Admin API: stream internal topic stats [pulsar]

2024-04-15 Thread via GitHub
eolivelli commented on code in PR #22510: URL: https://github.com/apache/pulsar/pull/22510#discussion_r1566023240 ## pulsar-broker/src/main/java/org/apache/pulsar/broker/admin/v2/PersistentTopics.java: ## @@ -1232,6 +1239,8 @@ public void getStats( }); }

Re: [PR] [improve][cli] PIP-343: Refactor pulsar-perf to subcommand [pulsar]

2024-04-15 Thread via GitHub
nodece commented on code in PR #22388: URL: https://github.com/apache/pulsar/pull/22388#discussion_r1566016191 ## pulsar-testclient/src/main/java/org/apache/pulsar/testclient/ManagedLedgerWriter.java: ## @@ -79,86 +78,69 @@ public class ManagedLedgerWriter { private static

Re: [PR] Admin API: stream internal topic stats [pulsar]

2024-04-15 Thread via GitHub
lhotari commented on PR #22510: URL: https://github.com/apache/pulsar/pull/22510#issuecomment-2056861012 @eolivelli have you had a chance to check if #22464 helps with large responses? the broker side changes are in #21667, #22463 and #22370 . -- This is an automated message from the

Re: [PR] Admin API: stream internal topic stats [pulsar]

2024-04-15 Thread via GitHub
lhotari commented on code in PR #22510: URL: https://github.com/apache/pulsar/pull/22510#discussion_r1565828920 ## pulsar-broker/src/main/java/org/apache/pulsar/broker/admin/v2/PersistentTopics.java: ## @@ -1232,6 +1239,8 @@ public void getStats( }); } +

(pulsar) branch branch-3.2 updated: [fix][sec] Upgrade Bouncycastle to 1.78 (#22509)

2024-04-15 Thread lhotari
This is an automated email from the ASF dual-hosted git repository. lhotari 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 3bae7515f52 [fix][sec] Upgrade

(pulsar) branch branch-3.1 updated: [fix][sec] Upgrade Bouncycastle to 1.78 (#22509)

2024-04-15 Thread lhotari
This is an automated email from the ASF dual-hosted git repository. lhotari pushed a commit to branch branch-3.1 in repository https://gitbox.apache.org/repos/asf/pulsar.git The following commit(s) were added to refs/heads/branch-3.1 by this push: new fd562178b4b [fix][sec] Upgrade

(pulsar) branch branch-3.0 updated: [fix][sec] Upgrade Bouncycastle to 1.78 (#22509)

2024-04-15 Thread lhotari
This is an automated email from the ASF dual-hosted git repository. lhotari 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 ef9b28fc27d [fix][sec] Upgrade

svn commit: r68537 - /dev/pulsar/ /release/pulsar/pulsar-client-reactive-0.5.4/

2024-04-15 Thread lhotari
Author: lhotari Date: Mon Apr 15 15:30:01 2024 New Revision: 68537 Log: fix invalid moving of files Added: dev/pulsar/ - copied from r68536, release/pulsar/pulsar-client-reactive-0.5.4/ Removed: release/pulsar/pulsar-client-reactive-0.5.4/

svn commit: r68536 - /dev/pulsar/ /release/pulsar/pulsar-client-reactive-0.5.4/

2024-04-15 Thread lhotari
Author: lhotari Date: Mon Apr 15 15:27:14 2024 New Revision: 68536 Log: Release Reactive client for Apache Pulsar 0.5.4 Added: release/pulsar/pulsar-client-reactive-0.5.4/ - copied from r68535, dev/pulsar/ Removed: dev/pulsar/

Re: [PR] Admin API: stream internal topic stats [pulsar]

2024-04-15 Thread via GitHub
eolivelli commented on PR #22510: URL: https://github.com/apache/pulsar/pull/22510#issuecomment-2057202628 > @eolivelli have you had a chance to check if Gzip compression helps with large responses? Pulsar admin client changes: #22464, broker side changes: #21667, #22463 and #22370 .

Re: [PR] [fix][broker] avoid offload system topic [pulsar]

2024-04-15 Thread via GitHub
heesung-sn commented on code in PR #22497: URL: https://github.com/apache/pulsar/pull/22497#discussion_r1566147507 ## pulsar-broker/src/main/java/org/apache/pulsar/broker/service/BrokerService.java: ## @@ -1944,7 +1944,13 @@ private CompletableFuture

[PR] [fix][io] Kafka Source connector maybe stuck [pulsar]

2024-04-15 Thread via GitHub
shibd opened a new pull request, #22511: URL: https://github.com/apache/pulsar/pull/22511 ### Motivation The current implementation of Kafka source connector, that `KafkaRecord` does not implement the `fail()` method.

Re: [PR] [fix][io] Kafka Source connector maybe stuck [pulsar]

2024-04-15 Thread via GitHub
lhotari commented on code in PR #22511: URL: https://github.com/apache/pulsar/pull/22511#discussion_r1565846411 ## pulsar-io/kafka/src/main/java/org/apache/pulsar/io/kafka/KafkaAbstractSource.java: ## @@ -253,6 +265,12 @@ public void ack() {

Re: [PR] [improve][cli] PIP-343: Refactor pulsar-perf to subcommand [pulsar]

2024-04-15 Thread via GitHub
nodece commented on code in PR #22388: URL: https://github.com/apache/pulsar/pull/22388#discussion_r1565986690 ## pulsar-testclient/src/main/java/org/apache/pulsar/testclient/PerformanceReader.java: ## @@ -60,72 +59,65 @@ public class PerformanceReader { private static

Re: [PR] [improve][cli] PIP-343: Refactor pulsar-perf to subcommand [pulsar]

2024-04-15 Thread via GitHub
nodece commented on code in PR #22388: URL: https://github.com/apache/pulsar/pull/22388#discussion_r1565989921 ## pulsar-testclient/src/main/java/org/apache/pulsar/testclient/PerformanceProducer.java: ## @@ -105,192 +103,173 @@ public class PerformanceProducer { private

Re: [PR] [improve][cli] PIP-343: Refactor pulsar-perf to subcommand [pulsar]

2024-04-15 Thread via GitHub
nodece commented on code in PR #22388: URL: https://github.com/apache/pulsar/pull/22388#discussion_r1565982237 ## pulsar-testclient/src/main/java/org/apache/pulsar/testclient/PerformanceTransaction.java: ## @@ -90,154 +88,142 @@ public class PerformanceTransaction {

Re: [PR] [improve][cli] PIP-343: Refactor pulsar-perf to subcommand [pulsar]

2024-04-15 Thread via GitHub
nodece commented on code in PR #22388: URL: https://github.com/apache/pulsar/pull/22388#discussion_r1566011718 ## pulsar-testclient/src/main/java/org/apache/pulsar/testclient/LoadSimulationClient.java: ## @@ -312,54 +306,42 @@ private void handle(final byte command, final

Re: [PR] [improve][cli] PIP-343: Refactor pulsar-perf to subcommand [pulsar]

2024-04-15 Thread via GitHub
nodece commented on code in PR #22388: URL: https://github.com/apache/pulsar/pull/22388#discussion_r1566012999 ## pulsar-testclient/src/main/java/org/apache/pulsar/testclient/LoadSimulationController.java: ## @@ -713,20 +688,22 @@ public void run() throws Exception { /**

Re: [PR] [fix][sec] Upgrade Bouncycastle to 1.78 [pulsar]

2024-04-15 Thread via GitHub
lhotari commented on PR #22509: URL: https://github.com/apache/pulsar/pull/22509#issuecomment-2056920976 Thanks for the contribution @izumo27 -- 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

[I] [improve] Parse the XFF header to get real client IP when behind reverse proxy [pulsar]

2024-04-15 Thread via GitHub
ci opened a new issue, #22512: URL: https://github.com/apache/pulsar/issues/22512 ### Search before asking - [X] I searched in the [issues](https://github.com/apache/pulsar/issues) and found nothing similar. ### Motivation When a broker or proxy is deployed

Re: [PR] [fix][fn]make sure the classloader for ContextImpl is `functionClassLoader` in different runtimes [pulsar]

2024-04-15 Thread via GitHub
lhotari commented on PR #22501: URL: https://github.com/apache/pulsar/pull/22501#issuecomment-2057459790 > 2024-04-15T06:18:32,716+ [public/default/demo-function-las-auth-0] ERROR org.apache.pulsar.functions.instance.JavaInstanceRunnable - Sink open produced uncaught exception: >

Re: [PR] [improve][cli] PIP-343: Refactor pulsar-perf to subcommand [pulsar]

2024-04-15 Thread via GitHub
nodece commented on code in PR #22388: URL: https://github.com/apache/pulsar/pull/22388#discussion_r1566064279 ## pulsar-testclient/src/main/java/org/apache/pulsar/testclient/PulsarPerfTestTool.java: ## @@ -0,0 +1,139 @@ +/* + * Licensed to the Apache Software Foundation (ASF)

Re: [PR] [improve][cli] PIP-343: Refactor pulsar-perf to subcommand [pulsar]

2024-04-15 Thread via GitHub
nodece commented on code in PR #22388: URL: https://github.com/apache/pulsar/pull/22388#discussion_r1565999431 ## pulsar-testclient/src/test/java/org/apache/pulsar/testclient/PerformanceBaseArgumentsTest.java: ## @@ -196,33 +215,39 @@ public void

Re: [PR] [improve][cli] PIP-343: Refactor pulsar-perf to subcommand [pulsar]

2024-04-15 Thread via GitHub
nodece commented on code in PR #22388: URL: https://github.com/apache/pulsar/pull/22388#discussion_r1566007716 ## pulsar-testclient/src/main/java/org/apache/pulsar/proxy/socket/client/PerformanceClient.java: ## @@ -61,172 +62,153 @@ import picocli.CommandLine; import

Re: [PR] [fix][broker] avoid offload system topic [pulsar]

2024-04-15 Thread via GitHub
lhotari commented on code in PR #22497: URL: https://github.com/apache/pulsar/pull/22497#discussion_r1566114943 ## pulsar-broker/src/main/java/org/apache/pulsar/broker/service/BrokerService.java: ## @@ -1944,7 +1944,13 @@ private CompletableFuture

(pulsar-client-reactive) annotated tag v0.5.4 updated (1139dd8 -> 8bd65fe)

2024-04-15 Thread onobc
This is an automated email from the ASF dual-hosted git repository. onobc pushed a change to annotated tag v0.5.4 in repository https://gitbox.apache.org/repos/asf/pulsar-client-reactive.git *** WARNING: tag v0.5.4 was modified! *** from 1139dd8 (commit) to 8bd65fe (tag) tagging

svn commit: r68538 - /dev/pulsar/pulsar-client-reactive-0.5.4-candidate-1/ /release/pulsar/pulsar-client-reactive-0.5.4/

2024-04-15 Thread lhotari
Author: lhotari Date: Mon Apr 15 15:31:02 2024 New Revision: 68538 Log: Release Reactive client for Apache Pulsar 0.5.4 Added: release/pulsar/pulsar-client-reactive-0.5.4/ - copied from r68537, dev/pulsar/pulsar-client-reactive-0.5.4-candidate-1/ Removed:

Re: [PR] [improve][broker] Recover susbcription creation on the broken schema ledger topic [pulsar]

2024-04-15 Thread via GitHub
Denovo1998 commented on PR #22469: URL: https://github.com/apache/pulsar/pull/22469#issuecomment-2057198666 @rdhabalia @lhotari @Technoboy- This pr may cause some problems, please look at the third part of this test. For example, we want to evolve schema from PersonTwo to PersonOne.

Re: [PR] [improve][cli] PIP-343: Refactor pulsar-perf to subcommand [pulsar]

2024-04-15 Thread via GitHub
nodece commented on code in PR #22388: URL: https://github.com/apache/pulsar/pull/22388#discussion_r1566043648 ## pulsar-testclient/src/main/java/org/apache/pulsar/testclient/ManagedLedgerWriter.java: ## @@ -79,86 +78,69 @@ public class ManagedLedgerWriter { private static

Re: [PR] [improve][cli] PIP-343: Refactor pulsar-perf to subcommand [pulsar]

2024-04-15 Thread via GitHub
nodece commented on PR #22388: URL: https://github.com/apache/pulsar/pull/22388#issuecomment-2057253744 This PR is a bit large and not easy to review. We may need to review multiple times to reach an agreement, thanks. -- This is an automated message from the Apache Git Service. To

Re: [PR] Admin API: stream internal topic stats [pulsar]

2024-04-15 Thread via GitHub
lhotari commented on PR #22510: URL: https://github.com/apache/pulsar/pull/22510#issuecomment-2057416045 > I have seen those PRs, great stuff, but the problem here is about the serialization happening in some upgredictable place, like this: Trying to understand this more deeper. What

Re: [PR] Admin API: stream internal topic stats [pulsar]

2024-04-15 Thread via GitHub
lhotari commented on PR #22510: URL: https://github.com/apache/pulsar/pull/22510#issuecomment-2056864579 > The JSON may be huge when individuallyDeletedMessages inside ManagedLedgerInternalStats$CursorStats contains many ranges @eolivelli do you have any figures to share? How large

Re: [PR] [fix][io] Kafka Source connector maybe stuck [pulsar]

2024-04-15 Thread via GitHub
shibd commented on code in PR #22511: URL: https://github.com/apache/pulsar/pull/22511#discussion_r1565864860 ## pulsar-io/kafka/src/main/java/org/apache/pulsar/io/kafka/KafkaAbstractSource.java: ## @@ -253,6 +265,12 @@ public void ack() {

Re: [PR] Added a split example [pulsar-site]

2024-04-15 Thread via GitHub
dragosvictor commented on code in PR #884: URL: https://github.com/apache/pulsar-site/pull/884#discussion_r1566204604 ## docs/concepts-broker-load-balancing-concepts.md: ## @@ -173,7 +173,14 @@ Based on the broker resource usage (for example, the number of topics or session

Re: [PR] [fix][fn]make sure the classloader for ContextImpl is `functionClassLoader` in different runtimes [pulsar]

2024-04-15 Thread via GitHub
lhotari commented on code in PR #22501: URL: https://github.com/apache/pulsar/pull/22501#discussion_r1566204680 ## pulsar-functions/instance/src/main/java/org/apache/pulsar/functions/instance/JavaInstanceRunnable.java: ## @@ -283,13 +283,17 @@ ContextImpl setupContext() throws

Re: [PR] [improve][cli] PIP-343: Refactor pulsar-perf to subcommand [pulsar]

2024-04-15 Thread via GitHub
nodece commented on code in PR #22388: URL: https://github.com/apache/pulsar/pull/22388#discussion_r1566037656 ## pulsar-testclient/src/main/java/org/apache/pulsar/testclient/PerformanceBaseArguments.java: ## @@ -19,53 +19,44 @@ package org.apache.pulsar.testclient; import

Re: [PR] [fix] [broker] Part-1: Replicator can not created successfully due to an orphan replicator in the previous topic owner [pulsar]

2024-04-15 Thread via GitHub
poorbarcode commented on PR #21946: URL: https://github.com/apache/pulsar/pull/21946#issuecomment-2057331440 Rebase master -- 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.

Re: [PR] [fix][io] Kafka Source connector maybe stuck [pulsar]

2024-04-15 Thread via GitHub
github-actions[bot] commented on PR #22511: URL: https://github.com/apache/pulsar/pull/22511#issuecomment-2056854059 @shibd Please add the following content to your PR description and select a checkbox: ``` - [ ] `doc` - [ ] `doc-required` - [ ] `doc-not-needed` - [ ]

Re: [PR] Admin API: stream internal topic stats [pulsar]

2024-04-15 Thread via GitHub
eolivelli commented on PR #22510: URL: https://github.com/apache/pulsar/pull/22510#issuecomment-2057204237 > How many individuallyDeletedMessages are there? more than 100.000 -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub

Re: [PR] Admin API: stream internal topic stats [pulsar]

2024-04-15 Thread via GitHub
dao-jun commented on PR #22510: URL: https://github.com/apache/pulsar/pull/22510#issuecomment-2057918401 > > I have seen those PRs, great stuff, but the problem here is about the serialization happening in some upgredictable place, like this: > > Trying to understand this more

(pulsar-site) branch heesung-sn-patch-1 updated (5197655389cb -> cf34dd8952db)

2024-04-15 Thread heesung
This is an automated email from the ASF dual-hosted git repository. heesung pushed a change to branch heesung-sn-patch-1 in repository https://gitbox.apache.org/repos/asf/pulsar-site.git from 5197655389cb Update concepts-broker-load-balancing-concepts.md add cf34dd8952db Update

[PR] [Release 0.5.4] Update latest version in README.adoc to 0.5.4 [pulsar-client-reactive]

2024-04-15 Thread via GitHub
onobc opened a new pull request, #168: URL: https://github.com/apache/pulsar-client-reactive/pull/168 (no comment) -- 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

(pulsar-site) branch heesung-sn-patch-1 updated (11257a3e54d7 -> ee0965a8e29c)

2024-04-15 Thread heesung
This is an automated email from the ASF dual-hosted git repository. heesung pushed a change to branch heesung-sn-patch-1 in repository https://gitbox.apache.org/repos/asf/pulsar-site.git from 11257a3e54d7 Update concepts-broker-load-balancing-concepts.md add ee0965a8e29c Update

Re: [PR] [improve][admin][broker] Admin API: stream internal topic stats [pulsar]

2024-04-15 Thread via GitHub
dao-jun closed pull request #22510: [improve][admin][broker] Admin API: stream internal topic stats URL: https://github.com/apache/pulsar/pull/22510 -- 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

Re: [PR] Added a split example [pulsar-site]

2024-04-15 Thread via GitHub
heesung-sn merged PR #884: URL: https://github.com/apache/pulsar-site/pull/884 -- 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:

(pulsar-site) branch heesung-sn-patch-1 updated (ee0965a8e29c -> c800f682068f)

2024-04-15 Thread heesung
This is an automated email from the ASF dual-hosted git repository. heesung pushed a change to branch heesung-sn-patch-1 in repository https://gitbox.apache.org/repos/asf/pulsar-site.git from ee0965a8e29c Update concepts-broker-load-balancing-concepts.md add c800f682068f Update

(pulsar-site) branch main updated: Added split and unload command example (#884)

2024-04-15 Thread heesung
This is an automated email from the ASF dual-hosted git repository. heesung 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 f5692585aa9f Added split and unload command

(pulsar) branch master updated: [fix][io] Kafka Source connector maybe stuck (#22511)

2024-04-15 Thread baodi
This is an automated email from the ASF dual-hosted git repository. baodi 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 bbff29d8ecc [fix][io] Kafka Source connector

Re: [PR] [fix][io] Kafka Source connector maybe stuck [pulsar]

2024-04-15 Thread via GitHub
shibd merged PR #22511: URL: https://github.com/apache/pulsar/pull/22511 -- 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:

[PR] [Release 0.5.4] Update next snapshot version to 0.5.5-SNAPSHOT [pulsar-client-reactive]

2024-04-15 Thread via GitHub
onobc opened a new pull request, #169: URL: https://github.com/apache/pulsar-client-reactive/pull/169 (no comment) -- 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

(pulsar-site) branch heesung-sn-patch-1 updated (cf34dd8952db -> 11257a3e54d7)

2024-04-15 Thread heesung
This is an automated email from the ASF dual-hosted git repository. heesung pushed a change to branch heesung-sn-patch-1 in repository https://gitbox.apache.org/repos/asf/pulsar-site.git from cf34dd8952db Update docs/concepts-broker-load-balancing-concepts.md add 11257a3e54d7 Update

Re: [I] [Bug] Partitioned topic deletion by topic GC [pulsar]

2024-04-15 Thread via GitHub
zzzming commented on issue #22471: URL: https://github.com/apache/pulsar/issues/22471#issuecomment-2057702631 May not be a bug. Check the broker.conf, this should be true but the default is false. ``` # Metadata of inactive partitioned topic will not be cleaned up automatically by

(pulsar) branch branch-2.11 updated: [fix][io] Kafka Source connector maybe stuck (#22511)

2024-04-15 Thread baodi
This is an automated email from the ASF dual-hosted git repository. baodi pushed a commit to branch branch-2.11 in repository https://gitbox.apache.org/repos/asf/pulsar.git The following commit(s) were added to refs/heads/branch-2.11 by this push: new 1eafb06d23a [fix][io] Kafka Source

Re: [PR] [fix][fn]make sure the classloader for ContextImpl is `functionClassLoader` in different runtimes [pulsar]

2024-04-15 Thread via GitHub
freeznet commented on code in PR #22501: URL: https://github.com/apache/pulsar/pull/22501#discussion_r1566619911 ## pulsar-functions/instance/src/main/java/org/apache/pulsar/functions/instance/JavaInstanceRunnable.java: ## @@ -283,13 +283,17 @@ ContextImpl setupContext() throws

Re: [PR] [fix][fn]make sure the classloader for ContextImpl is `functionClassLoader` in different runtimes [pulsar]

2024-04-15 Thread via GitHub
freeznet commented on PR #22501: URL: https://github.com/apache/pulsar/pull/22501#issuecomment-2058104594 @Awsmsniper it should be another issue, could you please create a new issue first? -- This is an automated message from the Apache Git Service. To respond to the message, please log

Re: [PR] [fix][broker] Fix the applying of namespace policies [pulsar]

2024-04-15 Thread via GitHub
nodece commented on PR #22504: URL: https://github.com/apache/pulsar/pull/22504#issuecomment-2058160022 /pulsarbot rerun-failure-checks -- 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-site) branch heesung-sn-patch-2 created (now 1909da09f868)

2024-04-15 Thread heesung
This is an automated email from the ASF dual-hosted git repository. heesung pushed a change to branch heesung-sn-patch-2 in repository https://gitbox.apache.org/repos/asf/pulsar-site.git at 1909da09f868 Update concepts-broker-load-balancing-concepts.md This branch includes the following

(pulsar-site) 01/01: Update concepts-broker-load-balancing-concepts.md

2024-04-15 Thread heesung
This is an automated email from the ASF dual-hosted git repository. heesung pushed a commit to branch heesung-sn-patch-2 in repository https://gitbox.apache.org/repos/asf/pulsar-site.git commit 1909da09f868f51d5e30c3cd06c225beccd100ee Author: Heesung Sohn

[PR] [improve][fn] expose `RuntimeFlags` as CLI option for Pulsar Functions and Connectors [pulsar]

2024-04-15 Thread via GitHub
freeznet opened a new pull request, #22514: URL: https://github.com/apache/pulsar/pull/22514 Fixes #xyz Main Issue: #xyz PIP: #xyz ### Motivation The `runtimeFlags` is been used to allow user to customize the java options

Re: [PR] [fix][broker] Fix the applying of namespace policies [pulsar]

2024-04-15 Thread via GitHub
liudezhi2098 commented on PR #22504: URL: https://github.com/apache/pulsar/pull/22504#issuecomment-2058054390 Check CI errors first -- 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

(pulsar) branch branch-3.1 updated: [fix][io] Kafka Source connector maybe stuck (#22511)

2024-04-15 Thread baodi
This is an automated email from the ASF dual-hosted git repository. baodi pushed a commit to branch branch-3.1 in repository https://gitbox.apache.org/repos/asf/pulsar.git The following commit(s) were added to refs/heads/branch-3.1 by this push: new 3a2fb4e7c4d [fix][io] Kafka Source

Re: [PR] [improve][broker] Recover susbcription creation on the broken schema ledger topic [pulsar]

2024-04-15 Thread via GitHub
Denovo1998 commented on PR #22469: URL: https://github.com/apache/pulsar/pull/22469#issuecomment-2058079889 Compared with #18010, there is no configuration control. The default behavior is to automatically skip when the integrity of the schema is destroyed. Even after this error

Re: [PR] [improve][broker] Supplement schema ledger if schema ledger is lost [pulsar]

2024-04-15 Thread via GitHub
Denovo1998 commented on PR #20415: URL: https://github.com/apache/pulsar/pull/20415#issuecomment-2058079142 Compared with https://github.com/apache/pulsar/pull/18010, there is no configuration control. The default behavior is to automatically skip when the integrity of the schema is

(pulsar-site) 01/01: Update concepts-broker-load-balancing-concepts.md

2024-04-15 Thread heesung
This is an automated email from the ASF dual-hosted git repository. heesung pushed a commit to branch heesung-sn-patch-3 in repository https://gitbox.apache.org/repos/asf/pulsar-site.git commit 1073e52018b5bafc20c087c1ac3e66fa66a4b43c Author: Heesung Sohn

(pulsar-site) branch heesung-sn-patch-3 created (now 1073e52018b5)

2024-04-15 Thread heesung
This is an automated email from the ASF dual-hosted git repository. heesung pushed a change to branch heesung-sn-patch-3 in repository https://gitbox.apache.org/repos/asf/pulsar-site.git at 1073e52018b5 Update concepts-broker-load-balancing-concepts.md This branch includes the following

[PR] Update concepts-broker-load-balancing-concepts.md [pulsar-site]

2024-04-15 Thread via GitHub
heesung-sn opened a new pull request, #885: URL: https://github.com/apache/pulsar-site/pull/885 ### ✅ Contribution Checklist - [ ] I read the [contribution guide](https://pulsar.apache.org/contribute/document-contribution/) - [ ] I updated the [versioned

Re: [PR] [Release 0.5.4] Update latest version in README.adoc to 0.5.4 [pulsar-client-reactive]

2024-04-15 Thread via GitHub
lhotari merged PR #168: URL: https://github.com/apache/pulsar-client-reactive/pull/168 -- 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:

(pulsar-client-reactive) branch main updated: [Release 0.5.4] Update next snapshot version to 0.5.5-SNAPSHOT (#169)

2024-04-15 Thread lhotari
This is an automated email from the ASF dual-hosted git repository. lhotari pushed a commit to branch main in repository https://gitbox.apache.org/repos/asf/pulsar-client-reactive.git The following commit(s) were added to refs/heads/main by this push: new 447b052 [Release 0.5.4] Update

(pulsar-client-reactive) branch main updated: [Release 0.5.4] Update latest version in README.adoc to 0.5.4 (#168)

2024-04-15 Thread lhotari
This is an automated email from the ASF dual-hosted git repository. lhotari pushed a commit to branch main in repository https://gitbox.apache.org/repos/asf/pulsar-client-reactive.git The following commit(s) were added to refs/heads/main by this push: new 7d70d6a [Release 0.5.4] Update

Re: [PR] [Release 0.5.4] Update next snapshot version to 0.5.5-SNAPSHOT [pulsar-client-reactive]

2024-04-15 Thread via GitHub
lhotari merged PR #169: URL: https://github.com/apache/pulsar-client-reactive/pull/169 -- 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:

(pulsar) branch branch-3.2 updated: [fix][io] Kafka Source connector maybe stuck (#22511)

2024-04-15 Thread baodi
This is an automated email from the ASF dual-hosted git repository. baodi 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 df6a18241eb [fix][io] Kafka Source

(pulsar) branch branch-3.0 updated: [fix][io] Kafka Source connector maybe stuck (#22511)

2024-04-15 Thread baodi
This is an automated email from the ASF dual-hosted git repository. baodi 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 a0120d00cad [fix][io] Kafka Source

Re: [PR] [fix][broker] Support lookup options for extensible load manager [pulsar]

2024-04-15 Thread via GitHub
Demogorgon314 commented on code in PR #22487: URL: https://github.com/apache/pulsar/pull/22487#discussion_r1566617744 ## pulsar-broker/src/main/java/org/apache/pulsar/broker/loadbalance/extensions/ExtensibleLoadManagerImpl.java: ## @@ -544,22 +550,19 @@ private

[I] [Bug] ClassNotFoundException error occurred when using Function development in the kubernetes cluster [pulsar]

2024-04-15 Thread via GitHub
Awsmsniper opened a new issue, #22513: URL: https://github.com/apache/pulsar/issues/22513 ### Search before asking - [X] I searched in the [issues](https://github.com/apache/pulsar/issues) and found nothing similar. ### Read release policy - [X] I understand that

Re: [I] [Bug] ClassNotFoundException error occurred when using Function development in the kubernetes cluster [pulsar]

2024-04-15 Thread via GitHub
Awsmsniper commented on issue #22513: URL: https://github.com/apache/pulsar/issues/22513#issuecomment-2058133221 @lhotari @nlu90 -- 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

Re: [I] [Bug] ClassNotFoundException error occurred when using Function development in the kubernetes cluster [pulsar]

2024-04-15 Thread via GitHub
Awsmsniper commented on issue #22513: URL: https://github.com/apache/pulsar/issues/22513#issuecomment-2058133839 @lhotari @nlu90 Hope to receive help, thank you very much! -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and

Re: [PR] [fix][broker] Fix the applying of namespace policies [pulsar]

2024-04-15 Thread via GitHub
nodece commented on PR #22504: URL: https://github.com/apache/pulsar/pull/22504#issuecomment-2058147664 /pulsarbot rerun-failure-checks -- 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-site) branch main updated: Update concepts-broker-load-balancing-concepts.md (#885)

2024-04-15 Thread heesung
This is an automated email from the ASF dual-hosted git repository. heesung 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 0fbbc4662713 Update

Re: [PR] Update concepts-broker-load-balancing-concepts.md [pulsar-site]

2024-04-15 Thread via GitHub
heesung-sn merged PR #885: URL: https://github.com/apache/pulsar-site/pull/885 -- 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:

Re: [I] [Bug] Partitioned topic deletion by topic GC [pulsar]

2024-04-15 Thread via GitHub
mukesh154 commented on issue #22471: URL: https://github.com/apache/pulsar/issues/22471#issuecomment-2058257488 It seems to be working with enabling the flag on `broker.conf`: `brokerDeleteInactivePartitionedTopicMetadataEnabled=true` The same flag is not there on `standalone.conf`

Re: [PR] [fix][fn]make sure the classloader for ContextImpl is `functionClassLoader` in different runtimes [pulsar]

2024-04-15 Thread via GitHub
Awsmsniper commented on PR #22501: URL: https://github.com/apache/pulsar/pull/22501#issuecomment-2058085824 > > #20115 fixes the classloader in TopicSchema, but for Kubernetes Runtime, the classloader may be different from the other runtimes. Which caused the SerDe to fail to init in

[PR] [improve] expose RuntimeFlags for Pulsar Functions and Connectors [pulsar-client-go]

2024-04-15 Thread via GitHub
freeznet opened a new pull request, #1204: URL: https://github.com/apache/pulsar-client-go/pull/1204 *(If this PR fixes a github issue, please add `Fixes #`.)* Fixes # *(or if this PR is one task of a github issue, please add `Master Issue: #` to link to the master

Re: [PR] [fix][broker] Fix Replicated Topic unload bug when ExtensibleLoadManager is enabled [pulsar]

2024-04-15 Thread via GitHub
heesung-sn commented on PR #22496: URL: https://github.com/apache/pulsar/pull/22496#issuecomment-2058272178 > Can we also check the other place such as producer.close(), looks like it may also get stuck forever. I understand the producer.flush might get stuck if no leader broker is

(pulsar) branch branch-3.1 updated: [fix][broker] Create new ledger after the current ledger is closed (#22034)

2024-04-15 Thread baodi
This is an automated email from the ASF dual-hosted git repository. baodi pushed a commit to branch branch-3.1 in repository https://gitbox.apache.org/repos/asf/pulsar.git The following commit(s) were added to refs/heads/branch-3.1 by this push: new 97de5dd51ee [fix][broker] Create new

(pulsar) branch branch-3.2 updated (f5c853a4e8a -> 8182edd7b50)

2024-04-15 Thread lhotari
This is an automated email from the ASF dual-hosted git repository. lhotari pushed a change to branch branch-3.2 in repository https://gitbox.apache.org/repos/asf/pulsar.git from f5c853a4e8a [fix] [broker] Prevent long deduplication cursor backlog so that topic loading wouldn't timeout

(pulsar) 01/03: [improve][test] Replace usage of curl in Java test and fix stream leaks (#22463)

2024-04-15 Thread lhotari
This is an automated email from the ASF dual-hosted git repository. lhotari pushed a commit to branch branch-3.2 in repository https://gitbox.apache.org/repos/asf/pulsar.git commit aa5af23abca451c83504d98d6fc02a799750af54 Author: Lari Hotari AuthorDate: Tue Apr 9 07:48:57 2024 -0700

(pulsar) 03/03: [fix][broker] Optimize /metrics, fix unbounded request queue issue and fix race conditions in metricsBufferResponse mode (#22494)

2024-04-15 Thread lhotari
This is an automated email from the ASF dual-hosted git repository. lhotari pushed a commit to branch branch-3.2 in repository https://gitbox.apache.org/repos/asf/pulsar.git commit 8182edd7b50ef3ca5add36c5eadebeaf0c75c8e7 Author: Lari Hotari AuthorDate: Mon Apr 15 09:55:24 2024 +0300

(pulsar) 02/03: [improve][broker] Improve Gzip compression, allow excluding specific paths or disabling it (#22370)

2024-04-15 Thread lhotari
This is an automated email from the ASF dual-hosted git repository. lhotari pushed a commit to branch branch-3.2 in repository https://gitbox.apache.org/repos/asf/pulsar.git commit f036250817d979e7e248ba7ce8ad97e2250ba779 Author: Lari Hotari AuthorDate: Fri Apr 12 10:35:09 2024 -0700

(pulsar) 04/04: [fix][broker] Optimize /metrics, fix unbounded request queue issue and fix race conditions in metricsBufferResponse mode (#22494)

2024-04-15 Thread lhotari
This is an automated email from the ASF dual-hosted git repository. lhotari pushed a commit to branch branch-3.1 in repository https://gitbox.apache.org/repos/asf/pulsar.git commit bfa4d75e8bceeaf9c10809b9164dd38e91653dde Author: Lari Hotari AuthorDate: Sat Apr 13 10:00:23 2024 -0700

(pulsar) branch branch-3.1 updated (ce99a96bb5b -> bfa4d75e8bc)

2024-04-15 Thread lhotari
This is an automated email from the ASF dual-hosted git repository. lhotari pushed a change to branch branch-3.1 in repository https://gitbox.apache.org/repos/asf/pulsar.git from ce99a96bb5b [fix][txn]Handle exceptions in the transaction pending ack init (#21274) new 9b247d9510f

(pulsar) 02/04: [improve][test] Replace usage of curl in Java test and fix stream leaks (#22463)

2024-04-15 Thread lhotari
This is an automated email from the ASF dual-hosted git repository. lhotari pushed a commit to branch branch-3.1 in repository https://gitbox.apache.org/repos/asf/pulsar.git commit 7ad7dedc0f723b677a197e03c6580dd7ded619ed Author: Lari Hotari AuthorDate: Tue Apr 9 07:48:57 2024 -0700

(pulsar) 04/04: [fix][broker] Optimize /metrics, fix unbounded request queue issue and fix race conditions in metricsBufferResponse mode (#22494)

2024-04-15 Thread lhotari
This is an automated email from the ASF dual-hosted git repository. lhotari pushed a commit to branch branch-3.0 in repository https://gitbox.apache.org/repos/asf/pulsar.git commit 5f9d7c5d6234f7a51f2a8412ad96ae7a0547632b Author: Lari Hotari AuthorDate: Sat Apr 13 10:00:23 2024 -0700

(pulsar) 01/04: [improve] [broker] Servlet support response compression (#21667)

2024-04-15 Thread lhotari
This is an automated email from the ASF dual-hosted git repository. lhotari pushed a commit to branch branch-3.1 in repository https://gitbox.apache.org/repos/asf/pulsar.git commit 9b247d9510fec3f6961ab77ffbe4d89136473747 Author: Hang Chen AuthorDate: Wed Mar 13 14:52:43 2024 +0800

(pulsar) 03/04: [improve][broker] Improve Gzip compression, allow excluding specific paths or disabling it (#22370)

2024-04-15 Thread lhotari
This is an automated email from the ASF dual-hosted git repository. lhotari pushed a commit to branch branch-3.1 in repository https://gitbox.apache.org/repos/asf/pulsar.git commit 02a8e4586ca8730748da8a1a13414f0ddb2d3654 Author: Lari Hotari AuthorDate: Fri Apr 12 10:35:09 2024 -0700

(pulsar) branch branch-3.0 updated (0fbcbb24039 -> 5f9d7c5d623)

2024-04-15 Thread lhotari
This is an automated email from the ASF dual-hosted git repository. lhotari pushed a change to branch branch-3.0 in repository https://gitbox.apache.org/repos/asf/pulsar.git from 0fbcbb24039 [fix] [broker] Prevent long deduplication cursor backlog so that topic loading wouldn't timeout

(pulsar) 03/04: [improve][broker] Improve Gzip compression, allow excluding specific paths or disabling it (#22370)

2024-04-15 Thread lhotari
This is an automated email from the ASF dual-hosted git repository. lhotari pushed a commit to branch branch-3.0 in repository https://gitbox.apache.org/repos/asf/pulsar.git commit cdc5af157754bbcb7a44559189e16a5438d294cd Author: Lari Hotari AuthorDate: Fri Apr 12 10:35:09 2024 -0700

(pulsar) 01/04: [improve] [broker] Servlet support response compression (#21667)

2024-04-15 Thread lhotari
This is an automated email from the ASF dual-hosted git repository. lhotari pushed a commit to branch branch-3.0 in repository https://gitbox.apache.org/repos/asf/pulsar.git commit 93664d769cbf32869daf6a1f216c5a8fed3625dc Author: Hang Chen AuthorDate: Wed Mar 13 14:52:43 2024 +0800

  1   2   >