diff --git a/nsqd/topic.go b/nsqd/topic.go index c13b64914..d28717b12 100644 --- a/nsqd/topic.go +++ b/nsqd/topic.go @@ -148,7 +148,7 @@ func (t *Topic) Pub(data [][]byte, crc []uint32) error { if atomic.LoadInt32(&t.exitFlag) == 1 { return errors.New("exiting") } - // TODO: health + // TODO: (WAL) health startIdx, endIdx, err := t.wal.Append(data, crc) if err != nil { return err