From 349b991178cc96536fe87c5083999c5933c30ff4 Mon Sep 17 00:00:00 2001 From: Kegan Dougal Date: Fri, 24 Mar 2017 14:59:29 +0000 Subject: [PATCH] Fix comments --- src/github.com/matrix-org/dendrite/common/consumers.go | 3 +-- 1 file changed, 1 insertion(+), 2 deletions(-) diff --git a/src/github.com/matrix-org/dendrite/common/consumers.go b/src/github.com/matrix-org/dendrite/common/consumers.go index 8732eee97..390426082 100644 --- a/src/github.com/matrix-org/dendrite/common/consumers.go +++ b/src/github.com/matrix-org/dendrite/common/consumers.go @@ -29,7 +29,7 @@ type ContinualConsumer struct { Consumer sarama.Consumer PartitionStore PartitionStorer // ProcessMessage is a function which will be called for each message in the log. Return an error to - // stop processing messages. See ErrRetryMessage and ErrShutdown for specific control signals. + // stop processing messages. See ErrShutdown for specific control signals. ProcessMessage func(msg *sarama.ConsumerMessage) error // ShutdownCallback is called when ProcessMessage returns ErrShutdown, after the partition has been saved. // It is optional. @@ -44,7 +44,6 @@ var ErrShutdown = fmt.Errorf("shutdown") // Returns nil once all the goroutines are started. // Returns an error if it can't start consuming for any of the partitions. func (c *ContinualConsumer) Start() error { - // TODO: This is nearl offsets := map[int32]int64{} partitions, err := c.Consumer.Partitions(c.Topic)