in topic_manager.go [69:83]
func (p *MNSTopicManager) SetTopicAttributes(topicName string, maxMessageSize int32, loggingEnabled bool) (err error) {
topicName = strings.TrimSpace(topicName)
if err = checkTopicName(topicName); err != nil {
return
}
message := CreateTopicRequest{
MaxMessageSize: maxMessageSize,
LoggingEnabled: loggingEnabled,
}
_, err = send(p.cli, p.decoder, PUT, nil, &message, fmt.Sprintf("topics/%s?metaoverride=true", topicName), nil)
return
}