dependabot[bot] opened a new pull request, #575:
URL: https://github.com/apache/pulsar-manager/pull/575
Bumps [serve-static](https://github.com/expressjs/serve-static) from 1.13.2
to 1.16.0.
Release notes
Sourced from https://github.com/expressjs/serve-static/releases";>serve-stati
Technoboy- merged PR #23278:
URL: https://github.com/apache/pulsar/pull/23278
--
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
BewareMyPower opened a new issue, #226:
URL: https://github.com/apache/pulsar-client-python/issues/226
Output of that with pulsar-client v.2.10.2:
```
Sent 1000 messages in 2.70 seconds
Sent 2000 messages in 5.40 seconds
Sent 3000 messages in 8.16 seconds
Sent 4000 messages
codecov-commenter commented on PR #23278:
URL: https://github.com/apache/pulsar/pull/23278#issuecomment-2340313710
##
[Codecov](https://app.codecov.io/gh/apache/pulsar/pull/23278?dropdown=coverage&src=pr&el=h1&utm_medium=referral&utm_source=github&utm_content=comment&utm_campaign=pr+comments
mattisonchao commented on code in PR #23279:
URL: https://github.com/apache/pulsar/pull/23279#discussion_r1751545915
##
managed-ledger/src/main/java/org/apache/bookkeeper/mledger/impl/ManagedLedgerImpl.java:
##
@@ -2587,10 +2596,7 @@ void internalTrimLedgers(boolean isTruncate,
ethqunzhong opened a new issue, #23280:
URL: https://github.com/apache/pulsar/issues/23280
### 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 un
poorbarcode commented on code in PR #23279:
URL: https://github.com/apache/pulsar/pull/23279#discussion_r1751537917
##
managed-ledger/src/main/java/org/apache/bookkeeper/mledger/impl/ManagedLedgerImpl.java:
##
@@ -3117,8 +3125,11 @@ public void offloadFailed(ManagedLedgerExcepti
poorbarcode commented on code in PR #23279:
URL: https://github.com/apache/pulsar/pull/23279#discussion_r1751536898
##
managed-ledger/src/main/java/org/apache/bookkeeper/mledger/impl/ReadonlyWrapperLedgerOffloader.java:
##
@@ -0,0 +1,69 @@
+/*
+ * Licensed to the Apache Software
mattisonchao commented on code in PR #23279:
URL: https://github.com/apache/pulsar/pull/23279#discussion_r1751500211
##
managed-ledger/src/main/java/org/apache/bookkeeper/mledger/impl/ReadonlyWrapperLedgerOffloader.java:
##
@@ -0,0 +1,69 @@
+/*
+ * Licensed to the Apache Softwar
codecov-commenter commented on PR #23277:
URL: https://github.com/apache/pulsar/pull/23277#issuecomment-2339992534
##
[Codecov](https://app.codecov.io/gh/apache/pulsar/pull/23277?dropdown=coverage&src=pr&el=h1&utm_medium=referral&utm_source=github&utm_content=comment&utm_campaign=pr+comments
mattisonchao commented on code in PR #23279:
URL: https://github.com/apache/pulsar/pull/23279#discussion_r1751491517
##
managed-ledger/src/main/java/org/apache/bookkeeper/mledger/impl/ManagedLedgerImpl.java:
##
@@ -2572,6 +2572,17 @@ void internalTrimConsumedLedgers(CompletableF
GitHub user lhotari edited a comment on the discussion: Key_Shared consumer
scale behavior with a partitioned topic
I'm currently working on a new design for Key_Shared AUTO_SPLIT mode which
would cover the requirement of individual hash tracking. The goal is that a
message will only get bloc
poorbarcode opened a new pull request, #23279:
URL: https://github.com/apache/pulsar/pull/23279
### Motivation
After https://github.com/apache/pulsar/pull/22497, the broker will not
offload data or read data from offloaded for the system topic, the PR has not
considered compatibility
RobertIndie opened a new pull request, #23278:
URL: https://github.com/apache/pulsar/pull/23278
## Motivation
The log message in `AdminResource` was missing a parameter. The `topicName`
was not being included in the success log message when creating partitioned
topics for rem
mattisonchao opened a new pull request, #23277:
URL: https://github.com/apache/pulsar/pull/23277
### Motivation
Bump oxia java version from 0.3.2 to 0.4.5
### Modifications
- Bump oxia java version from 0.3.2 to 0.4.5
### Verifying this change
- [x] Make s
mattisonchao merged PR #23276:
URL: https://github.com/apache/pulsar/pull/23276
--
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
mattisonchao commented on PR #23276:
URL: https://github.com/apache/pulsar/pull/23276#issuecomment-2339694346
>Please share the context to others about why this is important for Pulsar.
Pulsar is pluggable messaging system. For some plugins that is using GRPC as
the RPC framework will
lhotari commented on PR #23276:
URL: https://github.com/apache/pulsar/pull/23276#issuecomment-2339677171
> Bump io.grpc from 1.56.0 to 1.56.1 to address this super important fix.
[grpc/grpc-java#10328](https://github.com/grpc/grpc-java/pull/10328)
@mattisonchao Please share the contex
mattisonchao opened a new pull request, #23276:
URL: https://github.com/apache/pulsar/pull/23276
### Motivation
Bump io.grpc from 1.56.0 to 1.56.1 to address this super important fix.
https://github.com/grpc/grpc-java/pull/10328
### Modifications
- Bump io.grpc from 1.56
rdhabalia merged PR #23251:
URL: https://github.com/apache/pulsar/pull/23251
--
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.
rdhabalia closed issue #23250: [Bug] Broker seeing high latency, high CPU and
high GC Pauses
URL: https://github.com/apache/pulsar/issues/23250
--
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 sp
geniusjoe opened a new issue, #1282:
URL: https://github.com/apache/pulsar-client-go/issues/1282
**Is your feature request related to a problem? Please describe.**
When I ran `make test`, every test case worked fine except one error from
`test_extensible_load_manager` :
```
✔ Netwo
Denovo1998 commented on code in PR #6:
URL: https://github.com/apache/pulsar-java-contrib/pull/6#discussion_r1750283332
##
pulsar-rpc-contrib/src/main/java/org/apache/pulsar/rpc/contrib/client/PulsarRpcClient.java:
##
@@ -0,0 +1,180 @@
+/*
+ * Licensed under the Apache License,
Denovo1998 commented on code in PR #6:
URL: https://github.com/apache/pulsar-java-contrib/pull/6#discussion_r1750297371
##
pulsar-rpc-contrib/src/main/java/org/apache/pulsar/rpc/contrib/client/ReplyListener.java:
##
@@ -0,0 +1,74 @@
+/*
+ * Licensed under the Apache License, Ver
Denovo1998 commented on code in PR #6:
URL: https://github.com/apache/pulsar-java-contrib/pull/6#discussion_r1750283847
##
pulsar-rpc-contrib/src/main/java/org/apache/pulsar/rpc/contrib/server/RequestListener.java:
##
@@ -0,0 +1,88 @@
+/*
+ * Licensed under the Apache License, V
Denovo1998 commented on code in PR #6:
URL: https://github.com/apache/pulsar-java-contrib/pull/6#discussion_r1750283332
##
pulsar-rpc-contrib/src/main/java/org/apache/pulsar/rpc/contrib/client/PulsarRpcClient.java:
##
@@ -0,0 +1,180 @@
+/*
+ * Licensed under the Apache License,
Denovo1998 commented on code in PR #6:
URL: https://github.com/apache/pulsar-java-contrib/pull/6#discussion_r1750279670
##
pulsar-rpc-contrib/src/test/java/org/apache/pulsar/rpc/contrib/SimpleRpcCallTest.java:
##
@@ -0,0 +1,476 @@
+/*
+ * Licensed under the Apache License, Versi
nikhilerigila09 commented on code in PR #23274:
URL: https://github.com/apache/pulsar/pull/23274#discussion_r1750129564
##
pulsar-common/src/main/java/org/apache/pulsar/common/nar/NarUnpacker.java:
##
@@ -83,22 +83,31 @@ static File doUnpackNar(final File nar, final File
baseWo
nikhilerigila09 commented on code in PR #23274:
URL: https://github.com/apache/pulsar/pull/23274#discussion_r1750129564
##
pulsar-common/src/main/java/org/apache/pulsar/common/nar/NarUnpacker.java:
##
@@ -83,22 +83,31 @@ static File doUnpackNar(final File nar, final File
baseWo
ttys3 commented on PR #819:
URL: https://github.com/apache/pulsar-client-go/pull/819#issuecomment-2337878682
> +1 to upgrading the cobra dependency However, I'm not sure if it's a good
idea to split pulsar-perf-go to a separate module. In general it's recommended
to have a single go module
lhotari commented on issue #23273:
URL: https://github.com/apache/pulsar/issues/23273#issuecomment-2337766524
> * Suggested fix: Implement a mechanism that writes a ".success" file after
successful NAR extraction and ensures this file is present before using the
directory.
An alterna
GitHub user lhotari added a comment to the discussion: Key_Shared consumer
scale behavior with a partitioned topic
There's yet another aspect of the individual hash tracking.
Currently, when new consumers join, all message delivery is blocked for the
consumer until the inflight messages that
lhotari opened a new issue, #23272:
URL: https://github.com/apache/pulsar/issues/23272
### 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 unsupp
codecov-commenter commented on PR #23258:
URL: https://github.com/apache/pulsar/pull/23258#issuecomment-2337718462
##
[Codecov](https://app.codecov.io/gh/apache/pulsar/pull/23258?dropdown=coverage&src=pr&el=h1&utm_medium=referral&utm_source=github&utm_content=comment&utm_campaign=pr+comments
lhotari opened a new issue, #23271:
URL: https://github.com/apache/pulsar/issues/23271
### 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 unsupp
lhotari commented on PR #23269:
URL: https://github.com/apache/pulsar/pull/23269#issuecomment-2337589985
It seems that this is related to PIP-366 #23033 and should go only in master
branch?
--
This is an automated message from the Apache Git Service.
To respond to the message, please log
poorbarcode commented on code in PR #23258:
URL: https://github.com/apache/pulsar/pull/23258#discussion_r1749751058
##
pulsar-broker/src/main/java/org/apache/pulsar/compaction/CompactedTopicImpl.java:
##
@@ -304,8 +306,10 @@ static CompletableFuture>
readEntries(LedgerHandle lh
liangyepianzhou commented on code in PR #6:
URL: https://github.com/apache/pulsar-java-contrib/pull/6#discussion_r1749628176
##
pulsar-rpc-contrib/src/main/java/org/apache/pulsar/rpc/contrib/client/PulsarRpcClient.java:
##
@@ -0,0 +1,180 @@
+/*
+ * Licensed under the Apache Lice
Denovo1998 commented on code in PR #6:
URL: https://github.com/apache/pulsar-java-contrib/pull/6#discussion_r1749529755
##
pulsar-rpc-contrib/src/main/java/org/apache/pulsar/rpc/contrib/client/PulsarRpcClient.java:
##
@@ -0,0 +1,180 @@
+/*
+ * Licensed under the Apache License,
liangyepianzhou commented on PR #6:
URL:
https://github.com/apache/pulsar-java-contrib/pull/6#issuecomment-2337002045
> **Feedback is not positive due to PIP-371.**
[apache/pulsar#23143](https://github.com/apache/pulsar/pull/23143)
[apache/pulsar#23194](https://github.com/apache/pulsar/pul
BewareMyPower merged PR #23266:
URL: https://github.com/apache/pulsar/pull/23266
--
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...@pul
codecov-commenter commented on PR #23266:
URL: https://github.com/apache/pulsar/pull/23266#issuecomment-2336679392
##
[Codecov](https://app.codecov.io/gh/apache/pulsar/pull/23266?dropdown=coverage&src=pr&el=h1&utm_medium=referral&utm_source=github&utm_content=comment&utm_campaign=pr+comments
lhotari commented on code in PR #23266:
URL: https://github.com/apache/pulsar/pull/23266#discussion_r1748053636
##
pulsar-broker/src/main/java/org/apache/pulsar/broker/PulsarService.java:
##
@@ -1082,7 +1087,16 @@ public void start() throws PulsarServerException {
}
lhotari commented on code in PR #23266:
URL: https://github.com/apache/pulsar/pull/23266#discussion_r1748053363
##
pulsar-broker/src/main/java/org/apache/pulsar/broker/PulsarService.java:
##
@@ -1023,7 +1024,11 @@ public void start() throws PulsarServerException {
t
BewareMyPower commented on code in PR #23266:
URL: https://github.com/apache/pulsar/pull/23266#discussion_r1748049579
##
pulsar-broker/src/main/java/org/apache/pulsar/broker/PulsarService.java:
##
@@ -1082,7 +1087,16 @@ public void start() throws PulsarServerException {
}
lhotari commented on issue #21958:
URL: https://github.com/apache/pulsar/issues/21958#issuecomment-2335126309
I have created a proposal "PIP-377: Automatic retry for failed
acknowledgements", https://github.com/apache/pulsar/pull/23267 ([rendered
doc](https://github.com/lhotari/pulsar/blob/
lhotari commented on issue #22709:
URL: https://github.com/apache/pulsar/issues/22709#issuecomment-2335126220
I have created a proposal "PIP-377: Automatic retry for failed
acknowledgements", https://github.com/apache/pulsar/pull/23267 ([rendered
doc](https://github.com/lhotari/pulsar/blob/
lhotari commented on issue #22709:
URL: https://github.com/apache/pulsar/issues/22709#issuecomment-2335104724
Acknowledgements will get lost in broker restarts. That's part of current
design. That will cause Key_Shared consumers to "get stuck" and the messages
aren't delivered (not technica
lhotari commented on issue #21199:
URL: https://github.com/apache/pulsar/issues/21199#issuecomment-2335103456
It seems that this issue might be addressed together with PIP-282 changes
#21953 and other PRs #23226 (merged) and #23231 (in-progress).
A remaining challenge is the lost acknowl
KennyChenFight commented on PR #1277:
URL:
https://github.com/apache/pulsar-client-go/pull/1277#issuecomment-2335051805
> > the messages added to ack_grouping_tracker are considered ready to be
acknowledged.
>
> You can create a map to record the batch message, such as
`batchMessage
lhotari commented on code in PR #23231:
URL: https://github.com/apache/pulsar/pull/23231#discussion_r1747682951
##
pulsar-broker/src/main/java/org/apache/pulsar/broker/service/persistent/PersistentStickyKeyDispatcherMultipleConsumers.java:
##
@@ -274,96 +251,58 @@ protected sync
lhotari commented on code in PR #23231:
URL: https://github.com/apache/pulsar/pull/23231#discussion_r1747644825
##
conf/broker.conf:
##
@@ -355,6 +355,25 @@ maxUnackedMessagesPerBroker=0
# limit/2 messages
maxUnackedMessagesPerSubscriptionOnBrokerBlocked=0.16
+# For Key_Shar
lhotari commented on code in PR #23231:
URL: https://github.com/apache/pulsar/pull/23231#discussion_r1747336861
##
pulsar-broker/src/main/java/org/apache/pulsar/broker/service/persistent/PersistentStickyKeyDispatcherMultipleConsumers.java:
##
@@ -183,22 +180,6 @@ public synchron
lhotari commented on code in PR #23266:
URL: https://github.com/apache/pulsar/pull/23266#discussion_r1747293258
##
pulsar-broker/src/main/java/org/apache/pulsar/broker/PulsarService.java:
##
@@ -1082,7 +1087,16 @@ public void start() throws PulsarServerException {
}
lhotari commented on PR #23231:
URL: https://github.com/apache/pulsar/pull/23231#issuecomment-2334013781
Noticing more challenges to cover while getting into the tests. Setting this
to draft mode until the concerns are addressed and tests have been added. Some
of the concerns are related to
GitHub user lhotari added a comment to the discussion: Key_Shared consumer
scale behavior with a partitioned topic
> Perhaps a future improvement could be to allow tracking an individual hash
> value in the range 0-65535.
@niriven This is being implemented as part of #23231. It makes improvem
lhotari closed pull request #23265: [improve][broker] Log warning when chunked
messages appear with Key_Shared subscriptions
URL: https://github.com/apache/pulsar/pull/23265
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use
lhotari commented on code in PR #23231:
URL: https://github.com/apache/pulsar/pull/23231#discussion_r1746810620
##
pulsar-broker-common/src/main/java/org/apache/pulsar/broker/ServiceConfiguration.java:
##
@@ -949,6 +949,48 @@ The max allowed delay for delayed delivery (in
milli
lhotari opened a new issue, #23264:
URL: https://github.com/apache/pulsar/issues/23264
### 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 unsupp
RobertIndie commented on code in PR #23248:
URL: https://github.com/apache/pulsar/pull/23248#discussion_r1746723342
##
pip/pip-376.md:
##
@@ -0,0 +1,222 @@
+# PIP-376: Make Topic Policies Service Pluggable
+
+## Background
+
+### Topic Policies Service and System Topics
+
+[PIP-
shibd merged PR #392:
URL: https://github.com/apache/pulsar-client-node/pull/392
--
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...@pul
lhotari commented on code in PR #23231:
URL: https://github.com/apache/pulsar/pull/23231#discussion_r1746637488
##
pulsar-broker-common/src/main/java/org/apache/pulsar/broker/ServiceConfiguration.java:
##
@@ -949,6 +949,48 @@ The max allowed delay for delayed delivery (in
milli
lhotari opened a new issue, #23263:
URL: https://github.com/apache/pulsar/issues/23263
### 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 unsupp
lhotari commented on code in PR #23231:
URL: https://github.com/apache/pulsar/pull/23231#discussion_r1746590301
##
pulsar-broker/src/main/java/org/apache/pulsar/broker/service/persistent/PersistentStickyKeyDispatcherMultipleConsumers.java:
##
@@ -439,36 +372,162 @@ protected syn
poorbarcode commented on code in PR #23231:
URL: https://github.com/apache/pulsar/pull/23231#discussion_r1746574854
##
pulsar-broker/src/main/java/org/apache/pulsar/broker/service/persistent/PersistentStickyKeyDispatcherMultipleConsumers.java:
##
@@ -439,36 +372,162 @@ protected
hanmz commented on code in PR #23259:
URL: https://github.com/apache/pulsar/pull/23259#discussion_r1746514685
##
pulsar-broker/src/test/java/org/apache/pulsar/broker/admin/GetPartitionMetadataMultiBrokerTest.java:
##
@@ -256,8 +256,8 @@ public void
testCompatibilityDifferentBro
lhotari commented on code in PR #23231:
URL: https://github.com/apache/pulsar/pull/23231#discussion_r1746499955
##
pulsar-broker/src/main/java/org/apache/pulsar/broker/service/persistent/PersistentStickyKeyDispatcherMultipleConsumers.java:
##
@@ -439,36 +372,162 @@ protected syn
visortelle merged PR #960:
URL: https://github.com/apache/pulsar-site/pull/960
--
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
visortelle commented on PR #955:
URL: https://github.com/apache/pulsar-site/pull/955#issuecomment-2333205652
Thanks!
--
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 unsu
dependabot[bot] opened a new pull request, #960:
URL: https://github.com/apache/pulsar-site/pull/960
Bumps [twisted](https://github.com/twisted/twisted) from 23.10.0 to 24.7.0.
Release notes
Sourced from https://github.com/twisted/twisted/releases";>twisted's
releases.
Twist
visortelle merged PR #956:
URL: https://github.com/apache/pulsar-site/pull/956
--
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
visortelle merged PR #957:
URL: https://github.com/apache/pulsar-site/pull/957
--
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
shibd merged PR #958:
URL: https://github.com/apache/pulsar-site/pull/958
--
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.apa
shibd opened a new pull request, #392:
URL: https://github.com/apache/pulsar-client-node/pull/392
### Motivation
Bump cpp client version to v3.6.0
### Modifications
Bump cpp client version to v3.6.0
### Documentation
- [ ] `doc-required`
(Your PR nee
shibd merged PR #959:
URL: https://github.com/apache/pulsar-site/pull/959
--
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.apa
shibd opened a new pull request, #959:
URL: https://github.com/apache/pulsar-site/pull/959
### ✅ Contribution Checklist
- [ ] I read the [contribution
guide](https://pulsar.apache.org/contribute/document-contribution/)
- [ ] I updated the [versioned
docs](https://pulsar.ap
poorbarcode commented on code in PR #23231:
URL: https://github.com/apache/pulsar/pull/23231#discussion_r1746465968
##
pulsar-broker-common/src/main/java/org/apache/pulsar/broker/ServiceConfiguration.java:
##
@@ -949,6 +949,48 @@ The max allowed delay for delayed delivery (in
m
poorbarcode commented on code in PR #23231:
URL: https://github.com/apache/pulsar/pull/23231#discussion_r1746465968
##
pulsar-broker-common/src/main/java/org/apache/pulsar/broker/ServiceConfiguration.java:
##
@@ -949,6 +949,48 @@ The max allowed delay for delayed delivery (in
m
shibd opened a new pull request, #958:
URL: https://github.com/apache/pulsar-site/pull/958
### ✅ Contribution Checklist
- [ ] I read the [contribution
guide](https://pulsar.apache.org/contribute/document-contribution/)
- [ ] I updated the [versioned
docs](https://pulsar.ap
poorbarcode commented on code in PR #23231:
URL: https://github.com/apache/pulsar/pull/23231#discussion_r1746447330
##
pulsar-broker/src/main/java/org/apache/pulsar/broker/service/persistent/PersistentStickyKeyDispatcherMultipleConsumers.java:
##
@@ -439,36 +372,162 @@ protected
poorbarcode commented on code in PR #23231:
URL: https://github.com/apache/pulsar/pull/23231#discussion_r1746466858
##
pulsar-broker/src/main/java/org/apache/pulsar/broker/service/persistent/PersistentStickyKeyDispatcherMultipleConsumers.java:
##
@@ -183,22 +180,6 @@ public sync
coderzc commented on code in PR #23235:
URL: https://github.com/apache/pulsar/pull/23235#discussion_r1746388781
##
pip/pip-374.md:
##
@@ -0,0 +1,71 @@
+# PIP-374: Visibility of messages in receiverQueue for the consumers
+
+# Background knowledge
+
+When a consumer connects to t
rdhabalia commented on PR #23251:
URL: https://github.com/apache/pulsar/pull/23251#issuecomment-2332815671
done. I have sent email and will wait for 1-2 days before merging this PR.
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to Git
lhotari commented on PR #23231:
URL: https://github.com/apache/pulsar/pull/23231#issuecomment-2332320966
> Please do not merge this PR fast, I will finish my review tomorrow
Thanks @poorbarcode. The tests are also pending. I'm planning to finish them
tomorrow and hopefully your feedba
lhotari commented on PR #22972:
URL: https://github.com/apache/pulsar/pull/22972#issuecomment-2332207319
Checked again and perhaps minimizing the risk is worthwhile if it's not
needed in 3.3.x. It's not a big deal to backport #23236 to branch-3.3.
--
This is an automated message from the
dragosvictor commented on PR #22972:
URL: https://github.com/apache/pulsar/pull/22972#issuecomment-2332202801
It's not intended for 3.3, but it won't hurt either. No problem
cherry-picking it.
--
This is an automated message from the Apache Git Service.
To respond to the message, please l
lhotari opened a new issue, #23261:
URL: https://github.com/apache/pulsar/issues/23261
### 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 unsupp
lhotari commented on issue #23249:
URL: https://github.com/apache/pulsar/issues/23249#issuecomment-2332019991
Opened an ack receipt related bug report #23261
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL abo
grssam commented on PR #23253:
URL: https://github.com/apache/pulsar/pull/23253#issuecomment-2331793700
I just noticed. Why is the codecov diff comparing against a 6 months old
commit rather than master's head?
--
This is an automated message from the Apache Git Service.
To respond to the
lhotari merged PR #187:
URL: https://github.com/apache/pulsar-client-reactive/pull/187
--
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.
grssam commented on PR #23253:
URL: https://github.com/apache/pulsar/pull/23253#issuecomment-2331646302
/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 specifi
lhotari commented on PR #23236:
URL: https://github.com/apache/pulsar/pull/23236#issuecomment-2331325529
It looks like this would require #22972 changes for applying this cleanly to
branch-3.2 .
--
This is an automated message from the Apache Git Service.
To respond to the message, pleas
GitHub user huxiyu added a comment to the discussion: How to determine if a
message was consumed and the consumer details ？
oh my god！这么重要的特性一直没有答案。我也需要...
GitHub link:
https://github.com/apache/pulsar/discussions/18342#discussioncomment-1020
This is an automatically sent email for
Technoboy- commented on code in PR #23258:
URL: https://github.com/apache/pulsar/pull/23258#discussion_r1745075593
##
pulsar-broker/src/main/java/org/apache/pulsar/compaction/CompactedTopicImpl.java:
##
@@ -304,8 +306,10 @@ static CompletableFuture>
readEntries(LedgerHandle lh,
lhotari commented on issue #21958:
URL: https://github.com/apache/pulsar/issues/21958#issuecomment-2330962995
> let me check tomrrow.
@semistone thanks, that you be helpful. If it reproduces only within a
cluster with multiple nodes and other traffic that could mean that a load
balan
BewareMyPower opened a new pull request, #23260:
URL: https://github.com/apache/pulsar/pull/23260
### Motivation
When the lookup properties are modified, the previous pending lookup might
use the modified properties for lookup.
### Modifications
- Combine the properties
nodece commented on code in PR #23256:
URL: https://github.com/apache/pulsar/pull/23256#discussion_r1744971767
##
pulsar-client-messagecrypto-bc/src/main/java/org/apache/pulsar/client/impl/crypto/MessageCryptoBc.java:
##
@@ -525,6 +525,10 @@ private boolean decryptDataKey(String
BewareMyPower merged PR #444:
URL: https://github.com/apache/pulsar-client-cpp/pull/444
--
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
rdhabalia commented on code in PR #23256:
URL: https://github.com/apache/pulsar/pull/23256#discussion_r1744885413
##
pulsar-client-messagecrypto-bc/src/main/java/org/apache/pulsar/client/impl/crypto/MessageCryptoBc.java:
##
@@ -525,6 +525,10 @@ private boolean decryptDataKey(Str
hanmz opened a new pull request, #23259:
URL: https://github.com/apache/pulsar/pull/23259
### Motivation
The root cause of this problem is that the `getBroker` method is
asynchronous. When th
701 - 800 of 3009 matches
Mail list logo
