[GitHub] [pulsar-site] shibd opened a new pull request, #690: Add the release note for Python client 3.3.0

shibd opened a new pull request, #690: URL: https://github.com/apache/pulsar-site/pull/690 ### Preview https://github.com/apache/pulsar-site/assets/33416836/d3256373-5657-4e97-be43-893bbfb9963c";> https://github.com/apache/pulsar-site/assets/33416836/f6ca44aa-fcd0-4645-9493-43aecfa3

[GitHub] [pulsar] poorbarcode opened a new issue, #21092: [Doc] PIP-290 Provide a way to implement WSS E2E encryption and not need to expose the private key to the WebSocket Proxy

poorbarcode opened a new issue, #21092: URL: https://github.com/apache/pulsar/issues/21092 ### Search before asking - [X] I searched in the [issues](https://github.com/apache/pulsar/issues) and found nothing similar. ### What issue do you find in Pulsar docs? After [

[GitHub] [pulsar] Demogorgon314 opened a new pull request, #21091: [fix][broker] Avoid send batch message to loadbalancer service unit state topic to avoid split message to two batches

Demogorgon314 opened a new pull request, #21091: URL: https://github.com/apache/pulsar/pull/21091 ### Motivation Currently, the `ServiceUnitStateChannelImpl` will send batch messages to `loadbalancer-service-unit-state` topic, and the `StrategicTwoPhaseCompactor` will consume the m

[GitHub] [pulsar] massakam commented on pull request #21090: [fix][build] Upgrade Guava to 32.1.2-jre

massakam commented on PR #21090: URL: https://github.com/apache/pulsar/pull/21090#issuecomment-1698506446 @tisonkun At our company, a user's application (this is a project using Gradle) that included pulsar-client as a dependency failed to build. -- This is an automated message from the A

[GitHub] [pulsar] tisonkun commented on pull request #21090: [fix][build] Upgrade Guava to 32.1.2-jre

tisonkun commented on PR #21090: URL: https://github.com/apache/pulsar/pull/21090#issuecomment-1698497565 > where building with Gradle But we don't use Gradle for building. May you share more background here why we need this version bump? -- This is an automated message from th

[GitHub] [pulsar] massakam opened a new pull request, #21090: [fix][build] Upgrade Guava to 32.1.2-jre

massakam opened a new pull request, #21090: URL: https://github.com/apache/pulsar/pull/21090 ### Motivation Upgraded Guava to `32.1.2-jre`. This version includes a fix for an issue where building with Gradle may fail. https://github.com/google/guava/commit/9ed0fa65ab0ecdf2f10d506e

[GitHub] [pulsar] Technoboy- closed pull request #21037: [fix][fn] Fix ProducerConfig cannot update error

Technoboy- closed pull request #21037: [fix][fn] Fix ProducerConfig cannot update error URL: https://github.com/apache/pulsar/pull/21037 -- 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-client-python] annotated tag v3.3.0 updated (f445ceb -> f9463c5)

This is an automated email from the ASF dual-hosted git repository. baodi pushed a change to annotated tag v3.3.0 in repository https://gitbox.apache.org/repos/asf/pulsar-client-python.git *** WARNING: tag v3.3.0 was modified! *** from f445ceb (commit) to f9463c5 (tag) tagging f445

[GitHub] [pulsar] thetumbled commented on a diff in pull request #21085: [improve] [broker] apply topK machanism to ModularLoadManagerImpl.

thetumbled commented on code in PR #21085: URL: https://github.com/apache/pulsar/pull/21085#discussion_r1309531265 ## pulsar-broker/src/main/java/org/apache/pulsar/broker/loadbalance/impl/ModularLoadManagerImpl.java: ## @@ -1139,6 +1143,23 @@ public void writeBrokerDataOnZooKeep

[GitHub] [pulsar] thetumbled commented on a diff in pull request #21085: [improve] [broker] apply topK machanism to ModularLoadManagerImpl.

thetumbled commented on code in PR #21085: URL: https://github.com/apache/pulsar/pull/21085#discussion_r1309572714 ## pulsar-broker/src/main/java/org/apache/pulsar/broker/loadbalance/impl/ModularLoadManagerImpl.java: ## @@ -1139,6 +1143,23 @@ public void writeBrokerDataOnZooKeep

[pulsar] branch security-policy-on-readme deleted (was 37034e6bad7)

This is an automated email from the ASF dual-hosted git repository. mmarshall pushed a change to branch security-policy-on-readme in repository https://gitbox.apache.org/repos/asf/pulsar.git was 37034e6bad7 Add stronger Security Policy Language to README The revisions that were on this bra

[pulsar] branch master updated (eb2e3a258b9 -> eded9f107c4)

This is an automated email from the ASF dual-hosted git repository. mmarshall pushed a change to branch master in repository https://gitbox.apache.org/repos/asf/pulsar.git from eb2e3a258b9 [fix][client] Fix consumer can't consume resent chunked messages (#21070) add eded9f107c4 [improv

[GitHub] [pulsar] thetumbled commented on a diff in pull request #21085: [improve] [broker] apply topK machanism to ModularLoadManagerImpl.

thetumbled commented on code in PR #21085: URL: https://github.com/apache/pulsar/pull/21085#discussion_r1309554504 ## pulsar-common/src/main/java/org/apache/pulsar/policies/data/loadbalancer/BundleData.java: ## @@ -103,4 +97,13 @@ public int getTopics() { public void setTop

[GitHub] [pulsar] thetumbled commented on a diff in pull request #21085: [improve] [broker] apply topK machanism to ModularLoadManagerImpl.

thetumbled commented on code in PR #21085: URL: https://github.com/apache/pulsar/pull/21085#discussion_r1309554504 ## pulsar-common/src/main/java/org/apache/pulsar/policies/data/loadbalancer/BundleData.java: ## @@ -103,4 +97,13 @@ public int getTopics() { public void setTop

[GitHub] [pulsar] thetumbled commented on a diff in pull request #21085: [improve] [broker] apply topK machanism to ModularLoadManagerImpl.

thetumbled commented on code in PR #21085: URL: https://github.com/apache/pulsar/pull/21085#discussion_r1309554504 ## pulsar-common/src/main/java/org/apache/pulsar/policies/data/loadbalancer/BundleData.java: ## @@ -103,4 +97,13 @@ public int getTopics() { public void setTop

[GitHub] [pulsar] thetumbled commented on a diff in pull request #21085: [improve] [broker] apply topK machanism to ModularLoadManagerImpl.

thetumbled commented on code in PR #21085: URL: https://github.com/apache/pulsar/pull/21085#discussion_r1309554504 ## pulsar-common/src/main/java/org/apache/pulsar/policies/data/loadbalancer/BundleData.java: ## @@ -103,4 +97,13 @@ public int getTopics() { public void setTop

[GitHub] [pulsar] thetumbled commented on a diff in pull request #21085: [improve] [broker] apply topK machanism to ModularLoadManagerImpl.

thetumbled commented on code in PR #21085: URL: https://github.com/apache/pulsar/pull/21085#discussion_r1309554504 ## pulsar-common/src/main/java/org/apache/pulsar/policies/data/loadbalancer/BundleData.java: ## @@ -103,4 +97,13 @@ public int getTopics() { public void setTop

[GitHub] [pulsar] thetumbled commented on a diff in pull request #21085: [improve] [broker] apply topK machanism to ModularLoadManagerImpl.

thetumbled commented on code in PR #21085: URL: https://github.com/apache/pulsar/pull/21085#discussion_r1309554504 ## pulsar-common/src/main/java/org/apache/pulsar/policies/data/loadbalancer/BundleData.java: ## @@ -103,4 +97,13 @@ public int getTopics() { public void setTop

[pulsar-client-python] branch main updated: Bumped version to 3.4.0a1 (#151)

This is an automated email from the ASF dual-hosted git repository. xyz pushed a commit to branch main in repository https://gitbox.apache.org/repos/asf/pulsar-client-python.git The following commit(s) were added to refs/heads/main by this push: new 8c36eb7 Bumped version to 3.4.0a1 (#151)

[GitHub] [pulsar-client-python] BewareMyPower merged pull request #151: Bumped version to 3.4.0a1

BewareMyPower merged PR #151: URL: https://github.com/apache/pulsar-client-python/pull/151 -- 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-unsub

[GitHub] [pulsar] Technoboy- commented on a diff in pull request #21081: [fix][broker] Fix write duplicate entries into the compacted ledger after RawReader reconnects

Technoboy- commented on code in PR #21081: URL: https://github.com/apache/pulsar/pull/21081#discussion_r1309543104 ## pulsar-broker/src/test/java/org/apache/pulsar/compaction/CompactionTest.java: ## @@ -1877,4 +1877,68 @@ public void testReceiverQueueSize() throws Exception {

[GitHub] [pulsar] thetumbled commented on a diff in pull request #21085: [improve] [broker] apply topK machanism to ModularLoadManagerImpl.

thetumbled commented on code in PR #21085: URL: https://github.com/apache/pulsar/pull/21085#discussion_r1309540812 ## pulsar-broker/src/main/java/org/apache/pulsar/broker/loadbalance/impl/ModularLoadManagerImpl.java: ## @@ -1139,6 +1143,23 @@ public void writeBrokerDataOnZooKeep

[GitHub] [pulsar] thetumbled commented on a diff in pull request #21085: [improve] [broker] apply topK machanism to ModularLoadManagerImpl.

thetumbled commented on code in PR #21085: URL: https://github.com/apache/pulsar/pull/21085#discussion_r1309539694 ## pulsar-broker/src/main/java/org/apache/pulsar/broker/loadbalance/impl/ModularLoadManagerImpl.java: ## @@ -1139,6 +1143,23 @@ public void writeBrokerDataOnZooKeep

[GitHub] [pulsar] thetumbled commented on a diff in pull request #21085: [improve] [broker] apply topK machanism to ModularLoadManagerImpl.

thetumbled commented on code in PR #21085: URL: https://github.com/apache/pulsar/pull/21085#discussion_r1309536646 ## pulsar-common/src/main/java/org/apache/pulsar/policies/data/loadbalancer/TimeAverageMessageData.java: ## @@ -177,4 +175,40 @@ public double totalMsgRate() {

[GitHub] [pulsar] thetumbled commented on a diff in pull request #21085: [improve] [broker] apply topK machanism to ModularLoadManagerImpl.

thetumbled commented on code in PR #21085: URL: https://github.com/apache/pulsar/pull/21085#discussion_r1309538255 ## pulsar-common/src/main/java/org/apache/pulsar/policies/data/loadbalancer/TimeAverageMessageData.java: ## @@ -41,15 +41,20 @@ public class TimeAverageMessageData

[GitHub] [pulsar] thetumbled commented on a diff in pull request #21085: [improve] [broker] apply topK machanism to ModularLoadManagerImpl.

thetumbled commented on code in PR #21085: URL: https://github.com/apache/pulsar/pull/21085#discussion_r1309536646 ## pulsar-common/src/main/java/org/apache/pulsar/policies/data/loadbalancer/TimeAverageMessageData.java: ## @@ -177,4 +175,40 @@ public double totalMsgRate() {

[GitHub] [pulsar] thetumbled commented on a diff in pull request #21085: [improve] [broker] apply topK machanism to ModularLoadManagerImpl.

thetumbled commented on code in PR #21085: URL: https://github.com/apache/pulsar/pull/21085#discussion_r1309531265 ## pulsar-broker/src/main/java/org/apache/pulsar/broker/loadbalance/impl/ModularLoadManagerImpl.java: ## @@ -1139,6 +1143,23 @@ public void writeBrokerDataOnZooKeep

[GitHub] [pulsar] poorbarcode commented on pull request #18518: [improve] Introduce the sync() API to ensure consistency on reads during critical metadata operation paths

poorbarcode commented on PR #18518: URL: https://github.com/apache/pulsar/pull/18518#issuecomment-1698380103 > @eolivelli I want to cherry-pick this PR to 2.10 and 2.11 to solve the issue, which https://github.com/apache/pulsar/pull/21063 fixed. Do you feel okay? I sent a discuss to

[GitHub] [pulsar] michalcukierman commented on issue #21082: [Bug] one topic suddenly cannot be consumed,others is ok

michalcukierman commented on issue #21082: URL: https://github.com/apache/pulsar/issues/21082#issuecomment-1698236271 I've faced similar problem today. With a shared subscription, ackTimeout and receivers queue=8. I was able to read some of the messages (around 100, and the consumer g

[GitHub] [pulsar] heesung-sn commented on a diff in pull request #21085: [improve] [broker] apply topK machanism to ModularLoadManagerImpl.

heesung-sn commented on code in PR #21085: URL: https://github.com/apache/pulsar/pull/21085#discussion_r1309112337 ## pulsar-broker/src/main/java/org/apache/pulsar/broker/loadbalance/impl/ModularLoadManagerImpl.java: ## @@ -1139,6 +1143,23 @@ public void writeBrokerDataOnZooKeep

[GitHub] [pulsar] heesung-sn commented on a diff in pull request #21085: [improve] [broker] apply topK machanism to ModularLoadManagerImpl.

heesung-sn commented on code in PR #21085: URL: https://github.com/apache/pulsar/pull/21085#discussion_r1309137447 ## pulsar-broker/src/main/java/org/apache/pulsar/broker/loadbalance/impl/ModularLoadManagerImpl.java: ## @@ -1139,6 +1143,23 @@ public void writeBrokerDataOnZooKeep

[GitHub] [pulsar] heesung-sn commented on a diff in pull request #21085: [improve] [broker] apply topK machanism to ModularLoadManagerImpl.

heesung-sn commented on code in PR #21085: URL: https://github.com/apache/pulsar/pull/21085#discussion_r1309136466 ## pulsar-broker/src/main/java/org/apache/pulsar/broker/loadbalance/impl/ModularLoadManagerImpl.java: ## @@ -1139,6 +1143,23 @@ public void writeBrokerDataOnZooKeep

[GitHub] [pulsar] heesung-sn commented on a diff in pull request #21085: [improve] [broker] apply topK machanism to ModularLoadManagerImpl.

heesung-sn commented on code in PR #21085: URL: https://github.com/apache/pulsar/pull/21085#discussion_r1309134566 ## pulsar-common/src/main/java/org/apache/pulsar/policies/data/loadbalancer/BundleData.java: ## @@ -103,4 +97,13 @@ public int getTopics() { public void setTop

[GitHub] [pulsar-helm-chart] tsteinholz commented on issue #389: Pulsar Broker JVM Arguments are Ignored

tsteinholz commented on issue #389: URL: https://github.com/apache/pulsar-helm-chart/issues/389#issuecomment-1697822482 Using the `@deprecated` config map field in the values.yaml also fails ``` broker: configData: PULSAR_MEM: > -Xms2g -Xmx2g -X

[GitHub] [pulsar-helm-chart] tsteinholz opened a new issue, #389: Pulsar Broker JVM Arguments are Ignored

tsteinholz opened a new issue, #389: URL: https://github.com/apache/pulsar-helm-chart/issues/389 **Describe the bug** Increasing pods requests / limits and even manually specifying the JVM memoryOptions has no affect on the pod JVM allocation. **To Reproduce** Attempt to

[GitHub] [pulsar] RobertIndie merged pull request #21070: [fix][client] Fix consumer can't consume resent chunked messages

RobertIndie merged PR #21070: URL: https://github.com/apache/pulsar/pull/21070 -- 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...@pulsa

[pulsar] branch master updated (6ff83b6f8ab -> eb2e3a258b9)

This is an automated email from the ASF dual-hosted git repository. zike pushed a change to branch master in repository https://gitbox.apache.org/repos/asf/pulsar.git from 6ff83b6f8ab [fix][misc] Bump GRPC version to 1.55.3 to fix CVE (#21057) add eb2e3a258b9 [fix][client] Fix consumer

[GitHub] [pulsar] tsteinholz added a comment to the discussion: Kafka Source Connector Example fails to run

GitHub user tsteinholz added a comment to the discussion: Kafka Source Connector Example fails to run Versions Tested: - streamnative/pulsar-io-kafka:2.9.2.9 - streamnative/pulsar-io-kafka:2.11.2.5 GitHub link: https://github.com/apache/pulsar/discussions/21089#discussioncomment-6854307 --

svn commit: r63687 - /dev/pulsar/pulsar-client-python-3.3.0-candidate-1/ /release/pulsar/pulsar-client-python-3.3.0/

Author: xyz Date: Tue Aug 29 14:50:02 2023 New Revision: 63687 Log: Release Apache Pulsar Client Python 3.3.0 Added: release/pulsar/pulsar-client-python-3.3.0/ - copied from r63686, dev/pulsar/pulsar-client-python-3.3.0-candidate-1/ Removed: dev/pulsar/pulsar-client-python-3.3.0-can

[GitHub] [pulsar-client-python] shibd opened a new pull request, #151: Bumped version to 3.4.0a1

shibd opened a new pull request, #151: URL: https://github.com/apache/pulsar-client-python/pull/151 (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 unsubscr

[GitHub] [pulsar] Mortom123 opened a new issue, #21088: [Bug] Sink Connector not respecting client.conf brokerServiceUrl

Mortom123 opened a new issue, #21088: URL: https://github.com/apache/pulsar/issues/21088 ### Search before asking - [X] I searched in the [issues](https://github.com/apache/pulsar/issues) and found nothing similar. ### Version OS: Win10 (Dockerhost), RHEL 8.8 (Contai

[GitHub] [pulsar] thetumbled closed pull request #20972: [improve][pip] PIP-294: Filter out the bundles with low throughput in Bundle load report

thetumbled closed pull request #20972: [improve][pip] PIP-294: Filter out the bundles with low throughput in Bundle load report URL: https://github.com/apache/pulsar/pull/20972 -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and

[GitHub] [pulsar] thetumbled commented on pull request #20972: [improve][pip] PIP-294: Filter out the bundles with low throughput in Bundle load report

thetumbled commented on PR #20972: URL: https://github.com/apache/pulsar/pull/20972#issuecomment-1697379149 closed as i have submitted a new PR: https://github.com/apache/pulsar/pull/21085. -- This is an automated message from the Apache Git Service. To respond to the message, please log

[GitHub] [pulsar] thetumbled commented on pull request #21085: [improve] [broker] apply topK machanism to ModularLoadManagerImpl.

thetumbled commented on PR #21085: URL: https://github.com/apache/pulsar/pull/21085#issuecomment-1697373367 PTAL, thanks. @codelipenghui @hangc0276 @heesung-sn @Demogorgon314 -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub an

[GitHub] [pulsar] TakaHiR07 opened a new pull request, #21087: [fix][broker] revert remove duplicate topics name when deleteNamespace

TakaHiR07 opened a new pull request, #21087: URL: https://github.com/apache/pulsar/pull/21087 ### Motivation Related to https://github.com/apache/pulsar/pull/20683. When reading the code of master-branch and branch-2.10, I found we can not remove duplicate topics name when deleteName

[GitHub] [pulsar] thetumbled opened a new pull request, #21085: [improve] [broker] apply topK machanism to ModularLoadManagerImpl.

thetumbled opened a new pull request, #21085: URL: https://github.com/apache/pulsar/pull/21085 ### Motivation As the discussion of https://github.com/apache/pulsar/pull/21011 , we can reuse the configuration `loadBalancerMaxNumberOfBundlesInBundleLoadReport` in `ExtensibleLoadMan

[pulsar] branch branch-3.0 updated: [fix][misc] Bump GRPC version to 1.55.3 to fix CVE (#21057)

This is an automated email from the ASF dual-hosted git repository. mattisonchao 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 d4224635695 [fix][misc] Bump GRPC

[pulsar] branch branch-3.0 updated: [fix][misc] Bump broker okio version to 3.4.0 (#21064)

This is an automated email from the ASF dual-hosted git repository. mattisonchao 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 c6c84969762 [fix][misc] Bump broke

[pulsar] branch master updated (d099ac4fa2f -> 6ff83b6f8ab)

This is an automated email from the ASF dual-hosted git repository. mattisonchao pushed a change to branch master in repository https://gitbox.apache.org/repos/asf/pulsar.git from d099ac4fa2f [improve] [broker] Improve cache handling for partitioned topic metadata when doing lookup (#21063)

[GitHub] [pulsar] mattisonchao merged pull request #21057: [fix][misc] Bump GRPC version to 1.55.3 to fix CVE

mattisonchao merged PR #21057: URL: https://github.com/apache/pulsar/pull/21057 -- 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...@puls

[GitHub] [pulsar] codecov-commenter commented on pull request #21057: [fix][misc] Bump GRPC version to 1.55.3 to fix CVE

codecov-commenter commented on PR #21057: URL: https://github.com/apache/pulsar/pull/21057#issuecomment-1697202848 ## [Codecov](https://app.codecov.io/gh/apache/pulsar/pull/21057?src=pr&el=h1&utm_medium=referral&utm_source=github&utm_content=comment&utm_campaign=pr+comments&utm_term=apache)

[GitHub] [pulsar] RobertIndie commented on a diff in pull request #21079: [improve][pip] PIP-297: Support raising exceptions using Function & Connector context

RobertIndie commented on code in PR #21079: URL: https://github.com/apache/pulsar/pull/21079#discussion_r1308559001 ## pip/pip-297.md: ## @@ -0,0 +1,168 @@ +# Title: Support raising exceptions using Function & Connector context + +# Background knowledge + +The **Pulsar Function*

[GitHub] [pulsar] RobertIndie commented on a diff in pull request #21079: [improve][pip] PIP-297: Support raising exceptions using Function & Connector context

RobertIndie commented on code in PR #21079: URL: https://github.com/apache/pulsar/pull/21079#discussion_r1308560484 ## pip/pip-297.md: ## @@ -0,0 +1,168 @@ +# Title: Support raising exceptions using Function & Connector context + +# Background knowledge + +The **Pulsar Function*

[GitHub] [pulsar] RobertIndie commented on a diff in pull request #21079: [improve][pip] PIP-297: Support raising exceptions using Function & Connector context

RobertIndie commented on code in PR #21079: URL: https://github.com/apache/pulsar/pull/21079#discussion_r1308559001 ## pip/pip-297.md: ## @@ -0,0 +1,168 @@ +# Title: Support raising exceptions using Function & Connector context + +# Background knowledge + +The **Pulsar Function*

[GitHub] [pulsar] RobertIndie commented on a diff in pull request #21079: [improve][pip] PIP-297: Support raising exceptions using Function & Connector context

RobertIndie commented on code in PR #21079: URL: https://github.com/apache/pulsar/pull/21079#discussion_r1308556733 ## pip/pip-297.md: ## @@ -0,0 +1,168 @@ +# Title: Support raising exceptions using Function & Connector context + +# Background knowledge + +The **Pulsar Function*

[GitHub] [pulsar] RobertIndie commented on a diff in pull request #21079: [improve][pip] PIP-297: Support raising exceptions using Function & Connector context

RobertIndie commented on code in PR #21079: URL: https://github.com/apache/pulsar/pull/21079#discussion_r1308553985 ## pip/pip-297.md: ## @@ -0,0 +1,168 @@ +# Title: Support raising exceptions using Function & Connector context + +# Background knowledge + +The **Pulsar Function*

[GitHub] [pulsar] RobertIndie commented on a diff in pull request #21079: [improve][pip] PIP-297: Support raising exceptions using Function & Connector context

RobertIndie commented on code in PR #21079: URL: https://github.com/apache/pulsar/pull/21079#discussion_r1308547161 ## pip/pip-297.md: ## @@ -0,0 +1,168 @@ +# Title: Support raising exceptions using Function & Connector context + +# Background knowledge + +The **Pulsar Function*

[GitHub] [pulsar] RobertIndie commented on a diff in pull request #21079: [improve][pip] PIP-297: Support raising exceptions using Function & Connector context

RobertIndie commented on code in PR #21079: URL: https://github.com/apache/pulsar/pull/21079#discussion_r1308541649 ## pip/pip-297.md: ## @@ -0,0 +1,168 @@ +# Title: Support raising exceptions using Function & Connector context + +# Background knowledge + +The **Pulsar Function*

[GitHub] [pulsar] RobertIndie commented on a diff in pull request #21079: [improve][pip] PIP-297: Support raising exceptions using Function & Connector context

RobertIndie commented on code in PR #21079: URL: https://github.com/apache/pulsar/pull/21079#discussion_r1308540953 ## pip/pip-297.md: ## @@ -0,0 +1,168 @@ +# Title: Support raising exceptions using Function & Connector context + +# Background knowledge + +The **Pulsar Function*

[GitHub] [pulsar-client-cpp] BewareMyPower commented on pull request #309: Avoid calling serializeSingleMessageInBatchWithPayload each time a message is added

BewareMyPower commented on PR #309: URL: https://github.com/apache/pulsar-client-cpp/pull/309#issuecomment-1697089822 This PR is based on https://github.com/apache/pulsar-client-cpp/pull/308, please review #308 first. 3.3.0, the `SharedBuffer::allocate` takes 5.47% CPU in `sendAsync`

[GitHub] [pulsar] thetumbled closed pull request #21011: [improve][pip] PIP-294: Filter out the bundles with low throughput in Bundle load report

thetumbled closed pull request #21011: [improve][pip] PIP-294: Filter out the bundles with low throughput in Bundle load report URL: https://github.com/apache/pulsar/pull/21011 -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and

[GitHub] [pulsar-client-python] dengshaochun commented on issue #150: [BUG] use celery task send data to pulsar, init pulsar client error

dengshaochun commented on issue #150: URL: https://github.com/apache/pulsar-client-python/issues/150#issuecomment-1697043714 It cannot be fully reproduced, but the online environment has always been problematic. The test of a separate celery + pulsar code is normal. At present, there is no

[GitHub] [pulsar] poorbarcode commented on pull request #21078: [fix] [broker] remove bundle-data in local metadata store.

poorbarcode commented on PR #21078: URL: https://github.com/apache/pulsar/pull/21078#issuecomment-1697029692 @heesung-sn @Demogorgon314 Could you take a look? Thanks -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use th

[GitHub] [pulsar] thetumbled commented on a diff in pull request #21078: [fix] [broker] remove bundle-data in local metadata store.

thetumbled commented on code in PR #21078: URL: https://github.com/apache/pulsar/pull/21078#discussion_r1308356451 ## pulsar-broker-common/src/main/java/org/apache/pulsar/broker/resources/NamespaceResources.java: ## @@ -49,16 +49,18 @@ public class NamespaceResources extends Ba

[pulsar] branch branch-3.0 updated: [improve] [broker] Improve cache handling for partitioned topic metadata when doing lookup (#21063)

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 2e534d236bb [improve] [broker] Improve c

[GitHub] [pulsar] shibd commented on issue #21069: [Bug] (Kotlin) Sink-Connector not correctly loaded

shibd commented on issue #21069: URL: https://github.com/apache/pulsar/issues/21069#issuecomment-1696963750 > To prevent other people from having this issue, some clarification might be needed there. Yes, we need to update the document. > To prevent other people from having

[pulsar] 02/02: [fix][broker] Fix potential case cause retention policy not working on topic level (#21041)

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 commit dd151a5a5323076d2faa733bd96182ff685b56ee Author: Jiwei Guo AuthorDate: Tue Aug 22 22:08:09 2023 +0800 [fix][bro

[pulsar] 01/02: [fix] [broker] Producer is blocked on creation because backlog exceeded on topic, when dedup is enabled and no producer is there (#20951)

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 commit f68589ea280eea63ee786236d2c2023b7001ecb6 Author: Heesung Sohn <103456639+heesung...@users.noreply.github.com> AuthorD

[pulsar] branch branch-3.0 updated (25f76efee83 -> dd151a5a532)

This is an automated email from the ASF dual-hosted git repository. yubiao pushed a change to branch branch-3.0 in repository https://gitbox.apache.org/repos/asf/pulsar.git from 25f76efee83 [fix][broker] Make sure all inflight writes have finished before completion of compaction (#21067)

[GitHub] [pulsar] thetumbled commented on a diff in pull request #21078: [fix] [broker] remove bundle-data in local metadata store.

thetumbled commented on code in PR #21078: URL: https://github.com/apache/pulsar/pull/21078#discussion_r1308356451 ## pulsar-broker-common/src/main/java/org/apache/pulsar/broker/resources/NamespaceResources.java: ## @@ -49,16 +49,18 @@ public class NamespaceResources extends Ba

[GitHub] [pulsar] hangc0276 commented on pull request #21011: [improve][pip] PIP-294: Filter out the bundles with low throughput in Bundle load report

hangc0276 commented on PR #21011: URL: https://github.com/apache/pulsar/pull/21011#issuecomment-1696901552 > loadBalancerMaxNumberOfBundlesInBundleLoadReport @thetumbled +1 for applying the topK filter to the existing load-balancer logic. -- This is an automated message from the A