codelipenghui merged PR #22854:
URL: https://github.com/apache/pulsar/pull/22854
--
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
poorbarcode commented on code in PR #22854:
URL: https://github.com/apache/pulsar/pull/22854#discussion_r1668787772
##
pulsar-client/src/main/java/org/apache/pulsar/client/impl/MultiTopicsConsumerImpl.java:
##
@@ -1573,4 +1548,51 @@ protected void setCurrentReceiverQueueSize(int
codelipenghui commented on code in PR #22854:
URL: https://github.com/apache/pulsar/pull/22854#discussion_r1668712267
##
pulsar-client/src/main/java/org/apache/pulsar/client/impl/MultiTopicsConsumerImpl.java:
##
@@ -1573,4 +1548,51 @@ protected void setCurrentReceiverQueueSize(i
poorbarcode commented on code in PR #22854:
URL: https://github.com/apache/pulsar/pull/22854#discussion_r1665801286
##
pulsar-client/src/main/java/org/apache/pulsar/client/impl/PulsarClientImpl.java:
##
@@ -585,19 +585,28 @@ private CompletableFuture>
patternTopicSubscribeAsyn
poorbarcode commented on code in PR #22854:
URL: https://github.com/apache/pulsar/pull/22854#discussion_r1665797519
##
pulsar-broker/src/test/java/org/apache/pulsar/client/impl/LookupServiceTest.java:
##
@@ -108,8 +108,8 @@ public void testGetTopicsOfGetTopicsResult(boolean
isU
mattisonchao commented on code in PR #22854:
URL: https://github.com/apache/pulsar/pull/22854#discussion_r1665793987
##
pulsar-client/src/main/java/org/apache/pulsar/client/impl/PulsarClientImpl.java:
##
@@ -585,19 +585,28 @@ private CompletableFuture>
patternTopicSubscribeAsy
mattisonchao commented on code in PR #22854:
URL: https://github.com/apache/pulsar/pull/22854#discussion_r1665793987
##
pulsar-client/src/main/java/org/apache/pulsar/client/impl/PulsarClientImpl.java:
##
@@ -585,19 +585,28 @@ private CompletableFuture>
patternTopicSubscribeAsy
mattisonchao commented on code in PR #22854:
URL: https://github.com/apache/pulsar/pull/22854#discussion_r1665785500
##
pulsar-broker/src/test/java/org/apache/pulsar/client/impl/LookupServiceTest.java:
##
@@ -108,8 +108,8 @@ public void testGetTopicsOfGetTopicsResult(boolean
is
codecov-commenter commented on PR #22854:
URL: https://github.com/apache/pulsar/pull/22854#issuecomment-2208505903
##
[Codecov](https://app.codecov.io/gh/apache/pulsar/pull/22854?dropdown=coverage&src=pr&el=h1&utm_medium=referral&utm_source=github&utm_content=comment&utm_campaign=pr+comments
poorbarcode commented on PR #22854:
URL: https://github.com/apache/pulsar/pull/22854#issuecomment-2173950941
Rebased master
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.
poorbarcode commented on code in PR #22854:
URL: https://github.com/apache/pulsar/pull/22854#discussion_r1643157512
##
pulsar-client/src/main/java/org/apache/pulsar/client/impl/PatternMultiTopicsConsumerImpl.java:
##
@@ -69,6 +69,31 @@ public class PatternMultiTopicsConsumerImpl
poorbarcode commented on code in PR #22854:
URL: https://github.com/apache/pulsar/pull/22854#discussion_r1639675959
##
pulsar-client/src/main/java/org/apache/pulsar/client/impl/MultiTopicsConsumerImpl.java:
##
@@ -1067,30 +1074,43 @@ private void doSubscribeTopicPartitions(Schem
poorbarcode commented on code in PR #22854:
URL: https://github.com/apache/pulsar/pull/22854#discussion_r1639672682
##
pulsar-client/src/main/java/org/apache/pulsar/client/impl/MultiTopicsConsumerImpl.java:
##
@@ -1573,4 +1541,51 @@ protected void setCurrentReceiverQueueSize(int
poorbarcode commented on code in PR #22854:
URL: https://github.com/apache/pulsar/pull/22854#discussion_r1639672447
##
pulsar-common/src/main/java/org/apache/pulsar/common/naming/TopicName.java:
##
@@ -102,6 +102,10 @@ public static boolean isValid(String topic) {
}
poorbarcode commented on PR #22854:
URL: https://github.com/apache/pulsar/pull/22854#issuecomment-2160140265
/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 sp
lhotari commented on code in PR #22854:
URL: https://github.com/apache/pulsar/pull/22854#discussion_r1628929247
##
pulsar-client/src/main/java/org/apache/pulsar/client/impl/PatternMultiTopicsConsumerImpl.java:
##
@@ -69,6 +69,31 @@ public class PatternMultiTopicsConsumerImpl ext
lhotari commented on code in PR #22854:
URL: https://github.com/apache/pulsar/pull/22854#discussion_r1628923187
##
pulsar-client/src/main/java/org/apache/pulsar/client/impl/MultiTopicsConsumerImpl.java:
##
@@ -1067,30 +1074,43 @@ private void doSubscribeTopicPartitions(Schema
s
lhotari commented on code in PR #22854:
URL: https://github.com/apache/pulsar/pull/22854#discussion_r1628920203
##
pulsar-client/src/main/java/org/apache/pulsar/client/impl/PatternMultiTopicsConsumerImpl.java:
##
@@ -69,6 +69,31 @@ public class PatternMultiTopicsConsumerImpl ext
lhotari commented on code in PR #22854:
URL: https://github.com/apache/pulsar/pull/22854#discussion_r1628364294
##
pulsar-common/src/main/java/org/apache/pulsar/common/naming/TopicName.java:
##
@@ -102,6 +102,10 @@ public static boolean isValid(String topic) {
}
}
lhotari commented on code in PR #22854:
URL: https://github.com/apache/pulsar/pull/22854#discussion_r1628361663
##
pulsar-client/src/main/java/org/apache/pulsar/client/impl/MultiTopicsConsumerImpl.java:
##
@@ -1573,4 +1541,51 @@ protected void setCurrentReceiverQueueSize(int new
poorbarcode opened a new pull request, #22854:
URL: https://github.com/apache/pulsar/pull/22854
### Motivation
Background
**1.Regarding the API getting topics by regexp pattern, there are two
implementations:***
- `List HttpLookupService.getPartitionedTopicMetadata(...)
21 matches
Mail list logo