codelipenghui commented on issue #6785: URL: https://github.com/apache/pulsar/issues/6785#issuecomment-618142274
@zyllt Thanks for your feedback, It looks this is obvious bug of method `public static MessageId fromByteArrayWithTopic(byte[] data, TopicName topicName)`. > In addition, I would like to make a suggestion. If the topic is a partitioned-topic, the Message#getTopicName API get the name of the partitioned topic. Is it possible to provide an API to get the original topic name. Because when the partition topic and non-partition topic exist in MultiTopicConsumerImpl at the same time, if you want to obtain the original topicName, you can only manually handle the partition suffix of Message#getTopicName. You can use `TopicName.get(message.getTopicName).getPartitionedTopicName()`. I have no objection to add a method to get partitioned topic name in the `Message`. Are you interested in pushing a PR for the issue? ---------------------------------------------------------------- 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]
