You are viewing a plain text version of this content. The canonical link for it is here.

Posted to commits@pulsar.apache.org by GitBox <gi...@apache.org> on 2022/06/06 08:22:03 UTC

[GitHub] [pulsar] mattisonchao commented on a diff in pull request #15942: [feature][broker] Support HTTP endpoint consume messages

mattisonchao commented on code in PR #15942:
URL: https://github.com/apache/pulsar/pull/15942#discussion_r889927429


##########
pulsar-broker/src/main/java/org/apache/pulsar/broker/rest/TopicsBase.java:
##########
@@ -101,7 +117,11 @@
 @Slf4j
 public class TopicsBase extends PersistentTopicsBase {
 
+    private static final Map<String, Consumer<org.apache.pulsar.client.api.schema.GenericRecord>>

Review Comment:
   We will pin the consumer in the specific broker After consumer-created, We will return the consumer broker URL, and the user must use this URL to do the next action.
   So, After this, we will not affect by the topic moved.



-- 
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-unsubscribe@pulsar.apache.org

For queries about this service, please contact Infrastructure at:
users@infra.apache.org