handle sync every compatible with old

youzan · Jul 18, 2018 · d5c949b · d5c949b
1 parent 60dff75
commit d5c949b
Showing 1 changed file with 4 additions and 0 deletions.
diff --git a/consistence/nsqlookup_coord_api.go b/consistence/nsqlookup_coord_api.go
@@ -599,6 +599,10 @@ func (self *NsqLookupCoordinator) CreateTopic(topic string, meta TopicMetaInfo)
 			return err
 		}
 		meta.MagicCode = oldMeta.MagicCode
+		// handle old topic with large sync every param
+		if oldMeta.SyncEvery >= MAX_SYNC_EVERY {
+			meta.SyncEvery = oldMeta.SyncEvery
+		}
 		if oldMeta != meta {
 			return ErrAlreadyExist
 		}