mirror of
https://github.com/apache/rocketmq.git
synced 2026-08-28 20:09:14 +08:00
Fix : the topic attribute will be replace by null (#5527)
This commit is contained in:
@@ -1651,7 +1651,7 @@ public class DefaultMQAdminExtImpl implements MQAdminExt, MQAdminExtInner {
|
||||
@Override
|
||||
public void createTopic(String key, String newTopic, int queueNum,
|
||||
Map<String, String> attributes) throws MQClientException {
|
||||
createTopic(key, newTopic, queueNum, 0, null);
|
||||
createTopic(key, newTopic, queueNum, 0, attributes);
|
||||
}
|
||||
|
||||
@Override
|
||||
|
||||
Reference in New Issue
Block a user