rdhabalia opened a new pull request, #21687:
URL: https://github.com/apache/pulsar/pull/21687
PIP: #21452
### Motivation
As discussed in Issue: https://github.com/apache/pulsar/issues/21451
Apache Pulsar provides a messaging queue using a Shared subscription to
proc
zymap commented on PR #21686:
URL: https://github.com/apache/pulsar/pull/21686#issuecomment-1844892858
/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 specific
codelipenghui commented on code in PR #21657:
URL: https://github.com/apache/pulsar/pull/21657#discussion_r1418634507
##
pulsar-broker/src/main/java/org/apache/pulsar/broker/service/persistent/PersistentStickyKeyDispatcherMultipleConsumers.java:
##
@@ -388,6 +376,17 @@ private i
zymap merged PR #21084:
URL: https://github.com/apache/pulsar/pull/21084
--
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.apac
This is an automated email from the ASF dual-hosted git repository.
yong 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 f25b082125e [improve][sec] Add group pulsar and ad
dragosvictor commented on code in PR #21682:
URL: https://github.com/apache/pulsar/pull/21682#discussion_r1418641046
##
pulsar-broker/src/test/java/org/apache/pulsar/broker/loadbalance/extensions/ExtensibleLoadManagerImplTest.java:
##
@@ -410,111 +426,240 @@ public boolean test(
codelipenghui commented on code in PR #21657:
URL: https://github.com/apache/pulsar/pull/21657#discussion_r1418641605
##
pulsar-broker/src/main/java/org/apache/pulsar/broker/service/persistent/PersistentStickyKeyDispatcherMultipleConsumers.java:
##
@@ -269,7 +269,12 @@ protected
dragosvictor commented on code in PR #21682:
URL: https://github.com/apache/pulsar/pull/21682#discussion_r1418641716
##
pulsar-broker/src/main/java/org/apache/pulsar/broker/service/persistent/PersistentTopic.java:
##
@@ -1509,14 +1508,15 @@ public CompletableFuture close(
codelipenghui commented on code in PR #21657:
URL: https://github.com/apache/pulsar/pull/21657#discussion_r1418641605
##
pulsar-broker/src/main/java/org/apache/pulsar/broker/service/persistent/PersistentStickyKeyDispatcherMultipleConsumers.java:
##
@@ -269,7 +269,12 @@ protected
zhaoyajun2009 opened a new issue, #21688:
URL: https://github.com/apache/pulsar/issues/21688
### Search before asking
- [X] I searched in the [issues](https://github.com/apache/pulsar/issues)
and found nothing similar.
### Version
Can not offloading the data to HDFS.
gaoran10 commented on code in PR #21686:
URL: https://github.com/apache/pulsar/pull/21686#discussion_r1418674208
##
managed-ledger/src/test/java/org/apache/bookkeeper/mledger/impl/ManagedLedgerTest.java:
##
@@ -4152,4 +4156,53 @@ private long calculatePendingTaskCount(OrderedSch
gaoran10 commented on code in PR #21686:
URL: https://github.com/apache/pulsar/pull/21686#discussion_r1418674208
##
managed-ledger/src/test/java/org/apache/bookkeeper/mledger/impl/ManagedLedgerTest.java:
##
@@ -4152,4 +4156,53 @@ private long calculatePendingTaskCount(OrderedSch
gaoran10 commented on code in PR #21686:
URL: https://github.com/apache/pulsar/pull/21686#discussion_r1418679536
##
managed-ledger/src/test/java/org/apache/bookkeeper/mledger/impl/ManagedLedgerTest.java:
##
@@ -4152,4 +4156,53 @@ private long calculatePendingTaskCount(OrderedSch
coderzc commented on code in PR #21684:
URL: https://github.com/apache/pulsar/pull/21684#discussion_r1418734575
##
pulsar-common/src/main/java/org/apache/pulsar/common/protocol/OptionalProxyProtocolDecoder.java:
##
@@ -19,35 +19,67 @@
package org.apache.pulsar.common.protocol;
RobertIndie commented on issue #1142:
URL:
https://github.com/apache/pulsar-client-go/issues/1142#issuecomment-1845090349
Thanks for reporting it.
I'm +1 for this. Just to make sure we need to handle the backward
compatibility carefully.
--
This is an automated message from the Ap
tisonkun commented on issue #1142:
URL:
https://github.com/apache/pulsar-client-go/issues/1142#issuecomment-1845114696
> compare errors (errors.Is/As)
A rough approach is sorting out all the errors we return now and move them
to a public package (`pulsar/error.go`) and gradually expo
zymap commented on code in PR #21686:
URL: https://github.com/apache/pulsar/pull/21686#discussion_r1418792990
##
managed-ledger/src/test/java/org/apache/bookkeeper/mledger/impl/ManagedLedgerTest.java:
##
@@ -4152,4 +4156,53 @@ private long calculatePendingTaskCount(OrderedSchedu
coderzc commented on code in PR #21684:
URL: https://github.com/apache/pulsar/pull/21684#discussion_r1418798687
##
pulsar-common/src/main/java/org/apache/pulsar/common/protocol/OptionalProxyProtocolDecoder.java:
##
@@ -19,35 +19,67 @@
package org.apache.pulsar.common.protocol;
coderzc commented on code in PR #21684:
URL: https://github.com/apache/pulsar/pull/21684#discussion_r1418798687
##
pulsar-common/src/main/java/org/apache/pulsar/common/protocol/OptionalProxyProtocolDecoder.java:
##
@@ -19,35 +19,67 @@
package org.apache.pulsar.common.protocol;
zymap commented on code in PR #21686:
URL: https://github.com/apache/pulsar/pull/21686#discussion_r1418810224
##
managed-ledger/src/test/java/org/apache/bookkeeper/mledger/impl/ManagedLedgerTest.java:
##
@@ -4152,4 +4156,53 @@ private long calculatePendingTaskCount(OrderedSchedu
coderzc commented on code in PR #21684:
URL: https://github.com/apache/pulsar/pull/21684#discussion_r1418798687
##
pulsar-common/src/main/java/org/apache/pulsar/common/protocol/OptionalProxyProtocolDecoder.java:
##
@@ -19,35 +19,67 @@
package org.apache.pulsar.common.protocol;
codecov-commenter commented on PR #21686:
URL: https://github.com/apache/pulsar/pull/21686#issuecomment-1845181157
##
[Codecov](https://app.codecov.io/gh/apache/pulsar/pull/21686?src=pr&el=h1&utm_medium=referral&utm_source=github&utm_content=comment&utm_campaign=pr+comments&utm_term=apache)
codelipenghui commented on code in PR #21684:
URL: https://github.com/apache/pulsar/pull/21684#discussion_r1418819587
##
pulsar-common/src/main/java/org/apache/pulsar/common/protocol/OptionalProxyProtocolDecoder.java:
##
@@ -19,36 +19,61 @@
package org.apache.pulsar.common.prot
Technoboy- commented on code in PR #21684:
URL: https://github.com/apache/pulsar/pull/21684#discussion_r1418855601
##
pulsar-common/src/main/java/org/apache/pulsar/common/protocol/OptionalProxyProtocolDecoder.java:
##
@@ -19,36 +19,61 @@
package org.apache.pulsar.common.protoco
poorbarcode commented on code in PR #21684:
URL: https://github.com/apache/pulsar/pull/21684#discussion_r1418863294
##
pulsar-common/src/main/java/org/apache/pulsar/common/protocol/OptionalProxyProtocolDecoder.java:
##
@@ -19,36 +19,61 @@
package org.apache.pulsar.common.protoc
poorbarcode commented on code in PR #21684:
URL: https://github.com/apache/pulsar/pull/21684#discussion_r1418865258
##
pulsar-common/src/main/java/org/apache/pulsar/common/protocol/OptionalProxyProtocolDecoder.java:
##
@@ -19,36 +19,61 @@
package org.apache.pulsar.common.protoc
poorbarcode commented on code in PR #21684:
URL: https://github.com/apache/pulsar/pull/21684#discussion_r1418866629
##
pulsar-common/src/main/java/org/apache/pulsar/common/protocol/OptionalProxyProtocolDecoder.java:
##
@@ -19,35 +19,67 @@
package org.apache.pulsar.common.protoc
poorbarcode commented on code in PR #21684:
URL: https://github.com/apache/pulsar/pull/21684#discussion_r1418863294
##
pulsar-common/src/main/java/org/apache/pulsar/common/protocol/OptionalProxyProtocolDecoder.java:
##
@@ -19,36 +19,61 @@
package org.apache.pulsar.common.protoc
gaoran10 opened a new pull request, #21689:
URL: https://github.com/apache/pulsar/pull/21689
### Motivation
There are some non-existing methods in branch-2.10, they are introduced by
PRs from the latest version.
### Modifications
Remove non-existing and useless methods i
github-actions[bot] commented on PR #21689:
URL: https://github.com/apache/pulsar/pull/21689#issuecomment-1845236277
@gaoran10 Please add the following content to your PR description and select
a checkbox:
```
- [ ] `doc`
- [ ] `doc-required`
- [ ] `doc-not-needed`
- [ ] `d
coderzc commented on code in PR #21684:
URL: https://github.com/apache/pulsar/pull/21684#discussion_r1418889787
##
pulsar-common/src/main/java/org/apache/pulsar/common/protocol/OptionalProxyProtocolDecoder.java:
##
@@ -19,35 +19,67 @@
package org.apache.pulsar.common.protocol;
miton18 commented on issue #21628:
URL: https://github.com/apache/pulsar/issues/21628#issuecomment-1845263476
Yes, the connection never succeed
--
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
coderzc commented on code in PR #21684:
URL: https://github.com/apache/pulsar/pull/21684#discussion_r1418889787
##
pulsar-common/src/main/java/org/apache/pulsar/common/protocol/OptionalProxyProtocolDecoder.java:
##
@@ -19,35 +19,67 @@
package org.apache.pulsar.common.protocol;
gaoran10 closed pull request #21689: [branch-2.10][test] Remove non-existing
and useless methods in tests
URL: https://github.com/apache/pulsar/pull/21689
--
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 g
poorbarcode commented on code in PR #21684:
URL: https://github.com/apache/pulsar/pull/21684#discussion_r1418977159
##
pulsar-common/src/main/java/org/apache/pulsar/common/protocol/OptionalProxyProtocolDecoder.java:
##
@@ -19,35 +19,67 @@
package org.apache.pulsar.common.protoc
coderzc opened a new pull request, #21690:
URL: https://github.com/apache/pulsar/pull/21690
Fixes #xyz
Main Issue: #xyz
PIP: #xyz
### Motivation
There hasn't been a release since #21578 merged, so we can just fix it.
coderzc commented on code in PR #21578:
URL: https://github.com/apache/pulsar/pull/21578#discussion_r1418988388
##
conf/broker.conf:
##
@@ -538,6 +538,9 @@ brokerServiceCompactionThresholdInBytes=0
# If the execution time of the compaction phase one loop exceeds this time,
the
coderzc closed pull request #21690: [fix][broker] Fix typo in the config key
URL: https://github.com/apache/pulsar/pull/21690
--
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
coderzc commented on code in PR #21684:
URL: https://github.com/apache/pulsar/pull/21684#discussion_r1418999660
##
pulsar-common/src/main/java/org/apache/pulsar/common/protocol/OptionalProxyProtocolDecoder.java:
##
@@ -19,35 +19,67 @@
package org.apache.pulsar.common.protocol;
codecov-commenter commented on PR #21684:
URL: https://github.com/apache/pulsar/pull/21684#issuecomment-1845395950
##
[Codecov](https://app.codecov.io/gh/apache/pulsar/pull/21684?src=pr&el=h1&utm_medium=referral&utm_source=github&utm_content=comment&utm_campaign=pr+comments&utm_term=apache)
Technoboy- commented on code in PR #21684:
URL: https://github.com/apache/pulsar/pull/21684#discussion_r1419035617
##
pulsar-common/src/main/java/org/apache/pulsar/common/protocol/OptionalProxyProtocolDecoder.java:
##
@@ -19,36 +19,63 @@
package org.apache.pulsar.common.protoco
poorbarcode commented on code in PR #21684:
URL: https://github.com/apache/pulsar/pull/21684#discussion_r1419157675
##
pulsar-common/src/main/java/org/apache/pulsar/common/protocol/OptionalProxyProtocolDecoder.java:
##
@@ -19,36 +19,63 @@
package org.apache.pulsar.common.protoc
codecov-commenter commented on PR #21690:
URL: https://github.com/apache/pulsar/pull/21690#issuecomment-1845600785
##
[Codecov](https://app.codecov.io/gh/apache/pulsar/pull/21690?src=pr&el=h1&utm_medium=referral&utm_source=github&utm_content=comment&utm_campaign=pr+comments&utm_term=apache)
onobc commented on code in PR #21681:
URL: https://github.com/apache/pulsar/pull/21681#discussion_r1419209100
##
pulsar-broker/src/main/java/org/apache/pulsar/broker/service/AbstractTopic.java:
##
@@ -898,57 +888,35 @@ public long increasePublishLimitedTimes() {
.re
onobc commented on code in PR #21681:
URL: https://github.com/apache/pulsar/pull/21681#discussion_r1419217417
##
pulsar-broker/src/main/java/org/apache/pulsar/broker/service/Producer.java:
##
@@ -852,4 +852,25 @@ public boolean isDisconnecting() {
private static final Log
onobc commented on code in PR #21681:
URL: https://github.com/apache/pulsar/pull/21681#discussion_r1419235949
##
pulsar-broker/src/main/java/org/apache/pulsar/broker/service/PublishRateLimiterImpl.java:
##
@@ -16,70 +16,133 @@
* specific language governing permissions and limi
onobc commented on code in PR #21681:
URL: https://github.com/apache/pulsar/pull/21681#discussion_r1419241987
##
pulsar-broker/src/main/java/org/apache/pulsar/broker/service/PublishRateLimiterImpl.java:
##
@@ -16,70 +16,133 @@
* specific language governing permissions and limi
onobc commented on code in PR #21681:
URL: https://github.com/apache/pulsar/pull/21681#discussion_r1419244684
##
pulsar-broker/src/main/java/org/apache/pulsar/broker/service/PublishRateLimiterImpl.java:
##
@@ -16,70 +16,133 @@
* specific language governing permissions and limi
rdhabalia commented on code in PR #21657:
URL: https://github.com/apache/pulsar/pull/21657#discussion_r1419421668
##
pulsar-broker/src/main/java/org/apache/pulsar/broker/service/persistent/PersistentStickyKeyDispatcherMultipleConsumers.java:
##
@@ -388,6 +376,17 @@ private int g
lhotari commented on code in PR #21681:
URL: https://github.com/apache/pulsar/pull/21681#discussion_r1419462440
##
pulsar-broker/src/main/java/org/apache/pulsar/broker/service/AbstractTopic.java:
##
@@ -898,57 +888,35 @@ public long increasePublishLimitedTimes() {
.
onobc commented on code in PR #21681:
URL: https://github.com/apache/pulsar/pull/21681#discussion_r1419483803
##
pulsar-broker/src/main/java/org/apache/pulsar/broker/service/AbstractTopic.java:
##
@@ -898,57 +888,35 @@ public long increasePublishLimitedTimes() {
.re
lhotari commented on PR #21084:
URL: https://github.com/apache/pulsar/pull/21084#issuecomment-1845972457
> Currently, the user pulsar is in the root group, it would be better to use
the non-root group to keep more safety.
I think we need to revert and first do a PIP if we are doing th
lhotari commented on PR #21084:
URL: https://github.com/apache/pulsar/pull/21084#issuecomment-1845982713
This PR #13376 provides more context and the reference about why root group
must be used for OpenShift support:
*
https://engineering.bitnami.com/articles/running-non-root-containers-
asafm commented on code in PR #21635:
URL: https://github.com/apache/pulsar/pull/21635#discussion_r1419529311
##
pip/pip-320.md:
##
@@ -0,0 +1,241 @@
+# PIP-320 OpenTelemetry Scaffolding
+
+# Background knowledge
+
+## PIP-264 - parent PIP titled "Enhanced OTel-based metric sys
asafm commented on code in PR #21635:
URL: https://github.com/apache/pulsar/pull/21635#discussion_r1419530990
##
pip/pip-320.md:
##
@@ -0,0 +1,241 @@
+# PIP-320 OpenTelemetry Scaffolding
+
+# Background knowledge
+
+## PIP-264 - parent PIP titled "Enhanced OTel-based metric sys
asafm commented on code in PR #21635:
URL: https://github.com/apache/pulsar/pull/21635#discussion_r1419533017
##
pip/pip-320.md:
##
@@ -0,0 +1,241 @@
+# PIP-320 OpenTelemetry Scaffolding
+
+# Background knowledge
+
+## PIP-264 - parent PIP titled "Enhanced OTel-based metric sys
asafm commented on code in PR #21452:
URL: https://github.com/apache/pulsar/pull/21452#discussion_r1419546710
##
pip/pip_313.md:
##
@@ -0,0 +1,74 @@
+# PIP-313: Support force unsubscribe using consumer api
Review Comment:
filename should be pip-313.md
--
This is an autom
merlimat merged PR #21686:
URL: https://github.com/apache/pulsar/pull/21686
--
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.a
This is an automated email from the ASF dual-hosted git repository.
mmerli 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 1ccf90d95a7 [fix][offload] Don't cleanup data wh
This is an automated email from the ASF dual-hosted git repository.
mmerli 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 16e6c462211 [fix][offload] Don't cleanup
This is an automated email from the ASF dual-hosted git repository.
mmerli 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 17c3bc8312f [fix][offload] Don't cleanup
merlimat merged PR #21690:
URL: https://github.com/apache/pulsar/pull/21690
--
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.a
This is an automated email from the ASF dual-hosted git repository.
mmerli 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 822b7f434e0 [fix][broker] Fix typo in the config
This is an automated email from the ASF dual-hosted git repository.
mmerli 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 89b56a1abf0 [fix][broker] Fix typo in th
This is an automated email from the ASF dual-hosted git repository.
mmerli 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 44131f98110 [fix][broker] Fix typo in th
heesung-sn commented on code in PR #21682:
URL: https://github.com/apache/pulsar/pull/21682#discussion_r1418044228
##
pulsar-broker/src/main/java/org/apache/pulsar/broker/service/persistent/PersistentDispatcherMultipleConsumers.java:
##
@@ -542,6 +544,10 @@ public SubType getTyp
frankjkelly opened a new pull request, #412:
URL: https://github.com/apache/pulsar-helm-chart/pull/412
### Motivation
Before tackling upgrade testing I want to make sure that the Helm chart
works with the latest Kind node image
### Modifications
Hard-coded the default Ki
heesung-sn commented on code in PR #21682:
URL: https://github.com/apache/pulsar/pull/21682#discussion_r1419600767
##
pulsar-broker/src/main/java/org/apache/pulsar/broker/service/nonpersistent/NonPersistentDispatcherMultipleConsumers.java:
##
@@ -147,12 +151,13 @@ public synchro
Apurva007 commented on code in PR #21635:
URL: https://github.com/apache/pulsar/pull/21635#discussion_r1419708455
##
pip/pip-320.md:
##
@@ -0,0 +1,241 @@
+# PIP-320 OpenTelemetry Scaffolding
+
+# Background knowledge
+
+## PIP-264 - parent PIP titled "Enhanced OTel-based metric
Apurva007 commented on code in PR #21635:
URL: https://github.com/apache/pulsar/pull/21635#discussion_r1419703835
##
pip/pip-320.md:
##
@@ -0,0 +1,241 @@
+# PIP-320 OpenTelemetry Scaffolding
+
+# Background knowledge
+
+## PIP-264 - parent PIP titled "Enhanced OTel-based metric
hrsakai opened a new pull request, #358:
URL: https://github.com/apache/pulsar-client-node/pull/358
### Motivation
Athenz support x.509 certificate and `tokenExpirationTime` param has been
removed at https://github.com/apache/pulsar-client-cpp/pull/274 .
### Modifications
dragosvictor commented on code in PR #21682:
URL: https://github.com/apache/pulsar/pull/21682#discussion_r1419798231
##
pulsar-broker/src/main/java/org/apache/pulsar/broker/service/persistent/PersistentSubscription.java:
##
@@ -308,7 +309,7 @@ public synchronized void removeCons
keyboardbobo closed issue #21672: [Bug] all broker FullGC and shutdown when a
large number of producers concurrently update schema
URL: https://github.com/apache/pulsar/issues/21672
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub
Technoboy- commented on code in PR #21684:
URL: https://github.com/apache/pulsar/pull/21684#discussion_r1419816952
##
pulsar-common/src/main/java/org/apache/pulsar/common/protocol/OptionalProxyProtocolDecoder.java:
##
@@ -19,36 +19,63 @@
package org.apache.pulsar.common.protoco
Technoboy- commented on issue #21688:
URL: https://github.com/apache/pulsar/issues/21688#issuecomment-1846396713
Ah, please keep all the version 3.0.1
--
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
This is an automated email from the ASF dual-hosted git repository.
urfree 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 835fa692da73 Docs sync done from apache/pulsar
Technoboy- commented on issue #21631:
URL: https://github.com/apache/pulsar/issues/21631#issuecomment-1846421665
> > > but I am not sure if this will break the original design
> >
> >
> > I think it breaks
>
> If the behavior is expected, then maybe we should improve the doc
Technoboy- commented on code in PR #21687:
URL: https://github.com/apache/pulsar/pull/21687#discussion_r1419848062
##
pulsar-broker/src/main/java/org/apache/pulsar/broker/service/persistent/PersistentSubscription.java:
##
@@ -1038,11 +1038,24 @@ private CompletableFuture delete(
jiangpengcheng commented on code in PR #21675:
URL: https://github.com/apache/pulsar/pull/21675#discussion_r1419849262
##
pulsar-io/kafka/src/main/java/org/apache/pulsar/io/kafka/KafkaSourceConfig.java:
##
@@ -152,8 +153,13 @@ public static KafkaSourceConfig load(String yamlFile
yaalsn opened a new pull request, #21691:
URL: https://github.com/apache/pulsar/pull/21691
### Motivation
Reverts apache/pulsar#21084. Because the change breaks OpenShift support.
### Modifications
### Verifying this change
- [x] Make sure that the change passe
yaalsn closed pull request #21691: [improve][sec] Revert "Add group pulsar and
add user pulsar to it instead of root"
URL: https://github.com/apache/pulsar/pull/21691
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
UR
jiangpengcheng commented on code in PR #21675:
URL: https://github.com/apache/pulsar/pull/21675#discussion_r1419860526
##
pulsar-io/kafka/src/main/java/org/apache/pulsar/io/kafka/KafkaSourceConfig.java:
##
@@ -152,8 +153,13 @@ public static KafkaSourceConfig load(String yamlFile
coderzc commented on code in PR #21684:
URL: https://github.com/apache/pulsar/pull/21684#discussion_r1418999660
##
pulsar-common/src/main/java/org/apache/pulsar/common/protocol/OptionalProxyProtocolDecoder.java:
##
@@ -19,35 +19,67 @@
package org.apache.pulsar.common.protocol;
jiangpengcheng commented on code in PR #21675:
URL: https://github.com/apache/pulsar/pull/21675#discussion_r1419861713
##
pulsar-io/influxdb/src/test/java/org/apache/pulsar/io/influxdb/v1/InfluxDBSinkConfigTest.java:
##
@@ -85,12 +123,13 @@ public final void validValidateTest()
coderzc commented on code in PR #21684:
URL: https://github.com/apache/pulsar/pull/21684#discussion_r1419862355
##
pulsar-common/src/main/java/org/apache/pulsar/common/protocol/OptionalProxyProtocolDecoder.java:
##
@@ -19,35 +19,67 @@
package org.apache.pulsar.common.protocol;
jiangpengcheng commented on code in PR #21675:
URL: https://github.com/apache/pulsar/pull/21675#discussion_r1419862313
##
pulsar-io/common/src/main/java/org/apache/pulsar/io/common/IOConfigUtils.java:
##
@@ -77,13 +77,14 @@ private static T loadWithSecrets(Map
map, Class clazz
Technoboy- closed issue #21685: [Doc] pulsar v3.0.2 lacks release notes
URL: https://github.com/apache/pulsar/issues/21685
--
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 un
Technoboy- commented on issue #21685:
URL: https://github.com/apache/pulsar/issues/21685#issuecomment-1846457084
Added
--
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 un
Technoboy- merged PR #21673:
URL: https://github.com/apache/pulsar/pull/21673
--
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
This is an automated email from the ASF dual-hosted git repository.
technoboy pushed a change to branch master
in repository https://gitbox.apache.org/repos/asf/pulsar.git
from 822b7f434e0 [fix][broker] Fix typo in the config key (#21690)
add 61098ee2552 [fix][broker] Record GeoPersiste
poorbarcode commented on code in PR #21684:
URL: https://github.com/apache/pulsar/pull/21684#discussion_r1419866930
##
pulsar-common/src/main/java/org/apache/pulsar/common/protocol/OptionalProxyProtocolDecoder.java:
##
@@ -19,35 +19,67 @@
package org.apache.pulsar.common.protoc
poorbarcode commented on code in PR #21498:
URL: https://github.com/apache/pulsar/pull/21498#discussion_r1419868582
##
pulsar-broker/src/test/java/org/apache/pulsar/client/api/DispatcherLockTest.java:
##
@@ -0,0 +1,133 @@
+/*
+ * Licensed to the Apache Software Foundation (ASF)
poorbarcode commented on code in PR #21664:
URL: https://github.com/apache/pulsar/pull/21664#discussion_r1419875489
##
pulsar-client-tools/src/test/java/org/apache/pulsar/admin/cli/TestCmdTopics.java:
##
@@ -160,4 +168,59 @@ public void testPartitionedLookupSortByBroker() throws
shuoqingding commented on issue #21631:
URL: https://github.com/apache/pulsar/issues/21631#issuecomment-1846481859
Got it, I will work on a PR soon.
--
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 t
BewareMyPower commented on code in PR #21635:
URL: https://github.com/apache/pulsar/pull/21635#discussion_r1419877816
##
pip/pip-320.md:
##
@@ -0,0 +1,241 @@
+# PIP-320 OpenTelemetry Scaffolding
+
+# Background knowledge
+
+## PIP-264 - parent PIP titled "Enhanced OTel-based me
BewareMyPower commented on PR #21635:
URL: https://github.com/apache/pulsar/pull/21635#issuecomment-1846483526
LGTM
--
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 unsub
This is an automated email from the ASF dual-hosted git repository.
technoboy 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 2393ca7c3f9 [improve][broker] Print r
This is an automated email from the ASF dual-hosted git repository.
technoboy 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 c4196fba3ae [fix][broker] Record GeoP
codecov-commenter commented on PR #21691:
URL: https://github.com/apache/pulsar/pull/21691#issuecomment-1846495927
##
[Codecov](https://app.codecov.io/gh/apache/pulsar/pull/21691?src=pr&el=h1&utm_medium=referral&utm_source=github&utm_content=comment&utm_campaign=pr+comments&utm_term=apache)
keyboardbobo commented on PR #16319:
URL: https://github.com/apache/pulsar/pull/16319#issuecomment-1846506274
@lordcheng10 @heesung-sn @HQebupt @eolivelli @Jason918 Is there any
progress on this PR? If different dimensions are considered when bundle
unloading and assigning, there may be f
1 - 100 of 120 matches
Mail list logo
