下面代码路径 ：source->rocketmq->common->selector DefaultTopicSelector.java 类 public class DefaultTopicSelector<T> implements TopicSelector<T> { private final String topicName; private final String tagName; public DefaultTopicSelector(final String topicName) { this(topicName, ""); } public DefaultTopicSelector(String topicName, String tagName) { this.topicName = topicName; this.tagName = tagName; } @Override public String getTopic(T tuple) { return topicName; } @Override public String getTag(T...
