skip io.EOF

weed/mq/broker/broker_grpc_sub.go

@@ -144,9 +144,11 @@ func (b *MessageQueueBroker) SubscribeMessage(stream mq_pb.SeaweedMessaging_Subs
 					Close: &mq_pb.SubscribeFollowMeRequest_CloseMessage{},
 				},
 			}); err != nil {
+				if err != io.EOF {
 					glog.Errorf("Error sending close to follower: %v", err)
 				}
 			}
+		}
 	}()
 
 	return localTopicPartition.Subscribe(clientName, startPosition, func() bool {