diff --git a/net/server.go b/net/server.go
index 74cc16f22f..b69aa12868 100644
--- a/net/server.go
+++ b/net/server.go
@@ -273,9 +273,9 @@ func (s *server) publishLog(ctx context.Context, topic string, req *pushLogReque
 	t, ok := s.topics[topic]
 	s.mu.Unlock()
 	if !ok {
-		subscribe := true
-		if topic != req.SchemaRoot && s.hasPubSubTopic(req.SchemaRoot) {
-			subscribe = false
+		subscribe := false
+		if topic != req.SchemaRoot && !s.hasPubSubTopic(req.SchemaRoot) {
+			subscribe = true
 		}
 		err := s.addPubSubTopic(topic, subscribe, nil)
 		if err != nil {