xuesongxs commented on a change in pull request #9999:
URL: https://github.com/apache/pulsar/pull/9999#discussion_r598447905
##########
File path:
pulsar-client/src/main/java/org/apache/pulsar/client/impl/MultiTopicsConsumerImpl.java
##########
@@ -170,6 +170,7 @@
if (conf.getTopicNames().isEmpty()) {
setState(State.Ready);
subscribeFuture().complete(MultiTopicsConsumerImpl.this);
+ conf.getTopicNames().add(singleTopic);
Review comment:
@codelipenghui , The topic in the topicNames is deleted. After the
consumer is created, the topic is not added to the topicNames, and the conf
object is not passed to the MultiTopicsConsumerImpl constructor. Therefore, the
original configuration of the consumer cannot be obtained in the
MultiTopicsConsumerImpl constructor, and only a single input topic can call the
MultiTopicsConsumerimpl < T > function Create partitioned consumer interface.
At this time, singleTopic is the input topic. If there are multiple input
topics, singleTopic is dummy topic.
--
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.
For queries about this service, please contact Infrastructure at:
[email protected]
