Demogorgon314 opened a new pull request, #15708:
URL: https://github.com/apache/pulsar/pull/15708
### Motivation
Currently, the oauth2 curl example doc has the wrong URL, if we use the
command, we will get error code 1020.
```shell
curl --request POST \
--url
vinz2714 commented on issue #14660:
URL: https://github.com/apache/pulsar/issues/14660#issuecomment-1134205528
As this is not yet marked fixed we haven't tried 2.10.0 yet. The linked
ticket is marked for fix with netto update on 2.10.1 release. We are at 2.8.3
right now
--
This is an
AnonHxy commented on PR #15695:
URL: https://github.com/apache/pulsar/pull/15695#issuecomment-1134193561
/pulsarbot run-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
Demogorgon314 commented on code in PR #15707:
URL: https://github.com/apache/pulsar/pull/15707#discussion_r879031781
##
managed-ledger/src/main/java/org/apache/bookkeeper/mledger/util/RangeCache.java:
##
@@ -73,12 +74,13 @@ public RangeCache(Weighter weighter,
mattisonchao commented on code in PR #15707:
URL: https://github.com/apache/pulsar/pull/15707#discussion_r879027523
##
managed-ledger/src/main/java/org/apache/bookkeeper/mledger/util/RangeCache.java:
##
@@ -73,12 +73,11 @@ public RangeCache(Weighter weighter,
This is an automated email from the ASF dual-hosted git repository.
rxl pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/pulsar-client-go.git
The following commit(s) were added to refs/heads/master by this push:
new 67e2075 Revert "Fix stuck when
wolfstudy closed issue #766: pulsar-client-go marks the connection closed when
a "producer close" or "consumer close" message is received.
URL: https://github.com/apache/pulsar-client-go/issues/766
--
This is an automated message from the Apache Git Service.
To respond to the message, please
wolfstudy commented on PR #767:
URL: https://github.com/apache/pulsar-client-go/pull/767#issuecomment-1134139915
Closing the TCP connection here is indeed an inelegant operation, I merge
the change first, and then use state management to fix the problem
--
This is an automated message
wolfstudy merged PR #767:
URL: https://github.com/apache/pulsar-client-go/pull/767
--
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:
BewareMyPower commented on issue #15704:
URL: https://github.com/apache/pulsar/issues/15704#issuecomment-1134139573
Got it. For zero queue consumer, there is no way to determine which internal
consumer (on a specific partition) should be chosen to call `receive`.
--
This is an automated
Anonymitaet commented on issue #15705:
URL: https://github.com/apache/pulsar/issues/15705#issuecomment-1134129609
Hi @momo-jun can you help add that note? 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
wolfstudy merged PR #775:
URL: https://github.com/apache/pulsar-client-go/pull/775
--
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:
This is an automated email from the ASF dual-hosted git repository.
rxl pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/pulsar-client-go.git
The following commit(s) were added to refs/heads/master by this push:
new 5108332 Add error response for Ack func
Demogorgon314 commented on code in PR #15707:
URL: https://github.com/apache/pulsar/pull/15707#discussion_r878992514
##
managed-ledger/src/main/java/org/apache/bookkeeper/mledger/util/RangeCache.java:
##
@@ -73,12 +73,11 @@ public RangeCache(Weighter weighter,
liudezhi2098 commented on issue #15688:
URL: https://github.com/apache/pulsar/issues/15688#issuecomment-1134114808
If there are too many topics subscribed using regular mode, the size limit
may be exceeded when acquiring topic information. We can reduce the number of
subscription topics.
AnonHxy commented on PR #15695:
URL: https://github.com/apache/pulsar/pull/15695#issuecomment-1134101035
/pulsarbot run-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
github-actions[bot] commented on issue #14285:
URL: https://github.com/apache/pulsar/issues/14285#issuecomment-1134092103
The issue had no activity for 30 days, mark with Stale label.
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to
github-actions[bot] commented on issue #14732:
URL: https://github.com/apache/pulsar/issues/14732#issuecomment-1134091887
The issue had no activity for 30 days, mark with Stale label.
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to
github-actions[bot] commented on issue #15205:
URL: https://github.com/apache/pulsar/issues/15205#issuecomment-1134091613
The issue had no activity for 30 days, mark with Stale label.
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to
github-actions[bot] commented on issue #15232:
URL: https://github.com/apache/pulsar/issues/15232#issuecomment-1134091588
The issue had no activity for 30 days, mark with Stale label.
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to
github-actions[bot] commented on PR #15253:
URL: https://github.com/apache/pulsar/pull/15253#issuecomment-1134091568
The pr had no activity for 30 days, mark with Stale label.
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub
Technoboy- commented on PR #15619:
URL: https://github.com/apache/pulsar/pull/15619#issuecomment-1134090976
> Great work! I found some tests must disable the system topic and topic
level policies, I'm not sure if there are break changes or if the test requires
disabling topic level
Technoboy- commented on PR #15680:
URL: https://github.com/apache/pulsar/pull/15680#issuecomment-1134085984
> Now every resource close process is sync wait. The total wait time maybe
over `BrokerShutdownTimeoutMs`. Maybe should use Future.ofAll() to sync wait
the total future, but I'm not
Technoboy- commented on PR #15707:
URL: https://github.com/apache/pulsar/pull/15707#issuecomment-1134085574
This may be a core cause of topic fenced, but we are still confirming.
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to
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
commit f6eb92653b36d28026cd63520793137cd2914aab
Merge: 65643b9a174 8493d403339
Author: Li Li
AuthorDate: Mon May 23
This is an automated email from the ASF dual-hosted git repository.
urfree pushed a change to branch main
in repository https://gitbox.apache.org/repos/asf/pulsar-site.git
from 65643b9a174 Docs sync done from apache/pulsar(#84fecf1)
add 8493d403339 Make Algolia DocSearch configuration
AnonHxy commented on PR #15599:
URL: https://github.com/apache/pulsar/pull/15599#issuecomment-1134084026
@gaozhangmin PTAL
--
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.
AnonHxy commented on PR #15695:
URL: https://github.com/apache/pulsar/pull/15695#issuecomment-1134082187
/pulsarbot run-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
This is an automated email from the ASF dual-hosted git repository.
penghui 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 e7dff4b5136 [fix][broker-common] expose
codelipenghui merged PR #15661:
URL: https://github.com/apache/pulsar/pull/15661
--
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:
codelipenghui commented on PR #15706:
URL: https://github.com/apache/pulsar/pull/15706#issuecomment-1134074733
@Anonymitaet Please help review this PR. I noticed there are the format
changes.
--
This is an automated message from the Apache Git Service.
To respond to the message, please
codelipenghui commented on issue #15705:
URL: https://github.com/apache/pulsar/issues/15705#issuecomment-1134068161
> If a topic has no consumers, and a backlog of message index:key pairs 0:a,
1:a, 2:a, 3:b, 4:b, 5:b, and a KeyShared consumer c1 joins with a receiver
queue size of 1 and
jiazhai commented on issue #15688:
URL: https://github.com/apache/pulsar/issues/15688#issuecomment-1134059857
Seems the error happened when the matched topic names are returned in a
single package by the protocol.
--
This is an automated message from the Apache Git Service.
To respond
codelipenghui commented on issue #15702:
URL: https://github.com/apache/pulsar/issues/15702#issuecomment-1134059546
@zbentley
Yes, looks like the doc is incorrect
> How do those two settings interact?
Here is the code snippet
```
config.setReceiverQueueSize(
codelipenghui commented on issue #15701:
URL: https://github.com/apache/pulsar/issues/15701#issuecomment-1134055829
@zbentley
> In a second terminal, start another consumer on the topic with the below
code.
Does the second consumer use the same subscription name as the first
codelipenghui commented on issue #15704:
URL: https://github.com/apache/pulsar/issues/15704#issuecomment-1134050431
@zbentley @BewareMyPower
> It’s not enabled because we cannot know which partition the next message
will be coming from. Any suggestion on how to achieve that?
mattisonchao opened a new pull request, #15707:
URL: https://github.com/apache/pulsar/pull/15707
### Motivation
When `ReferenceCounted` object overrides the method `deallocate` to make the
`getLength` value equal null will cause NPE because the `RangeCache#put` method
is not
This is an automated email from the ASF dual-hosted git repository.
wave pushed a commit to branch dave2wave-patch-1
in repository https://gitbox.apache.org/repos/asf/pulsar-site.git
commit 8493d403339462af8038a476830d8f79446b0fa0
Author: Dave Fisher
AuthorDate: Sun May 22 13:19:03 2022 -0700
This is an automated email from the ASF dual-hosted git repository.
wave pushed a change to branch dave2wave-patch-1
in repository https://gitbox.apache.org/repos/asf/pulsar-site.git
at 8493d403339 Make Algolia DocSearch configuration simple
This branch includes the following new
AnonHxy commented on PR #15695:
URL: https://github.com/apache/pulsar/pull/15695#issuecomment-1133951054
Add UT, PTAL @codelipenghui
--
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
zbentley closed issue #15610: Python pulsar-client 2.8 is not compatible with
broker 2.10.0
URL: https://github.com/apache/pulsar/issues/15610
--
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
zbentley commented on issue #15702:
URL: https://github.com/apache/pulsar/issues/15702#issuecomment-1133920374
@codelipenghui I don't think this is affected by batching being enabled or
disabled; see my reply to your other comment.
Additionally, when you say:
> The queue size
zbentley commented on issue #15705:
URL: https://github.com/apache/pulsar/issues/15705#issuecomment-1133918270
@codelipenghui if I'm reading that correctly, that's really concerning
behavior.
If a topic has no consumers, and a backlog of message index:key pairs `0:a,
1:a, 2:a, 3:b,
BewareMyPower commented on issue #15704:
URL: https://github.com/apache/pulsar/issues/15704#issuecomment-1133917552
I think it's a common problem for clients of all languages. This check was
introduced in https://github.com/apache/pulsar/pull/1103.
```java
BewareMyPower commented on issue #15704:
URL: https://github.com/apache/pulsar/issues/15704#issuecomment-1133916247
It looks like zero queue consumer cannot be used on a partitioned topic. I
tested the Java code as well.
```java
var topic = "my-topic";
var admin
zbentley commented on issue #15704:
URL: https://github.com/apache/pulsar/issues/15704#issuecomment-1133914531
Update (and updated issue title): this only happens with *partitioned*
topics. While [I'm not quite sure what receiver queue size
zbentley commented on issue #15704:
URL: https://github.com/apache/pulsar/issues/15704#issuecomment-1133914341
@BewareMyPower thanks, can that be added to the client documentation for
receiver-queue related flags?
--
This is an automated message from the Apache Git Service.
To
zbentley commented on issue #15703:
URL: https://github.com/apache/pulsar/issues/15703#issuecomment-1133913611
@codelipenghui I have reproduced with batching both enabled and disabled.
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to
zbentley commented on issue #15701:
URL: https://github.com/apache/pulsar/issues/15701#issuecomment-1133912650
I edited the code in the example to print out ledger/entry/partition/batch
so that it is evident that the batch index is `-1` for messages received.
--
This is an automated
zbentley commented on issue #15701:
URL: https://github.com/apache/pulsar/issues/15701#issuecomment-1133912589
@codelipenghui this issue occurs with and without `batching_enabled` in the
producer. Additionally, with `batching_enabled=True` it occurs regardless of
which batching strategy is
BewareMyPower commented on issue #15704:
URL: https://github.com/apache/pulsar/issues/15704#issuecomment-1133911202
@zbentley The common behavior between 0 and 1 receiver queue size is that
the permits of FLOW request is 1.
However, if the receiver queue size is 0, only when
tjiuming commented on PR #15692:
URL: https://github.com/apache/pulsar/pull/15692#issuecomment-1133910584
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
BewareMyPower commented on issue #15704:
URL: https://github.com/apache/pulsar/issues/15704#issuecomment-1133910273
@codelipenghui See
https://github.com/apache/pulsar/blob/defeec0e84a63ea865f3a2790bc61b66a02254c5/pulsar-client-cpp/python/pulsar_test.py#L289-L306
This test was
zbentley commented on issue #15704:
URL: https://github.com/apache/pulsar/issues/15704#issuecomment-1133907613
Could you clarify the difference between a setting of 0 and a setting of 1?
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on
zbentley commented on issue #15704:
URL: https://github.com/apache/pulsar/issues/15704#issuecomment-1133907534
@BewareMyPower
> It's better to show your Python client version and paste your code.
See https://github.com/apache/pulsar/issues/15701; that contains
minchowang commented on issue #15688:
URL: https://github.com/apache/pulsar/issues/15688#issuecomment-1133887806
Hi, @sijie I had found out about `netty` setting in `conf/bookkeeper.conf`,
whether recommend increasing this size to the solution?
```
# The maximum netty frame size in
codelipenghui commented on PR #15694:
URL: https://github.com/apache/pulsar/pull/15694#issuecomment-1133875106
/pulsarbot run-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
codelipenghui commented on issue #15704:
URL: https://github.com/apache/pulsar/issues/15704#issuecomment-1133874905
@BewareMyPower Do we have a test for the zero queue consumer of the Python
client? If we have a test, please share the test in this issue.
--
This is an automated message
BewareMyPower commented on issue #15704:
URL: https://github.com/apache/pulsar/issues/15704#issuecomment-1133870339
> is 0 equivalent to 1?
No.
--
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
BewareMyPower commented on issue #15704:
URL: https://github.com/apache/pulsar/issues/15704#issuecomment-1133869495
I think zero queue size consumer has already been supported from a very
early version. I've also fixed a related bug last year, see
github-actions[bot] commented on PR #15706:
URL: https://github.com/apache/pulsar/pull/15706#issuecomment-1133843602
@asafm:Thanks for providing doc info!
--
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
github-actions[bot] commented on PR #15706:
URL: https://github.com/apache/pulsar/pull/15706#issuecomment-1133843573
@asafm:Thanks for your contribution. For this PR, do we need to update docs?
(The [PR template contains info about
asafm opened a new pull request, #15706:
URL: https://github.com/apache/pulsar/pull/15706
### Modifications
Fix wrong text in Full and Full Transitive schema compatibility
### Verifying this change
- [ ] Make sure that the change passes the CI checks.
This change is
HQebupt commented on PR #15627:
URL: https://github.com/apache/pulsar/pull/15627#issuecomment-1133836344
/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
liangyuanpeng commented on PR #15270:
URL: https://github.com/apache/pulsar/pull/15270#issuecomment-1133831454
@Technoboy-PTAL,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
Shoothzj commented on PR #13785:
URL: https://github.com/apache/pulsar/pull/13785#issuecomment-1133830252
/pulsarbot run-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
66 matches
Mail list logo
