diff --git a/weed/mq/topic/local_partition.go b/weed/mq/topic/local_partition.go index 145b1a450..d72c86fcd 100644 --- a/weed/mq/topic/local_partition.go +++ b/weed/mq/topic/local_partition.go @@ -136,4 +136,5 @@ func (p *LocalPartition) Shutdown() { p.closeSubscribers() p.LogBuffer.ShutdownLogBuffer() atomic.StoreInt32(&p.FollowerId, 0) + glog.V(0).Infof("local partition %v shutting down", p.Partition) }