mirrors/dendrite
1
0
Fork 0
mirror of https://github.com/matrix-org/dendrite.git synced 2025-12-26 08:13:09 -06:00
Code Issues Packages Projects Releases Wiki Activity

Reduce logging

Browse source
This commit is contained in:
Neil Alexander 2021-01-25 12:41:39 +00:00
parent 7c6238674d
commit de11c1bc47
No known key found for this signature in database
GPG key ID: A02A2019A2BB0944
1 changed files with 0 additions and 1 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

1
internal/consumers.go
View file

@ -107,7 +107,6 @@ func (c *ContinualConsumer) StartOffsets() ([]sqlutil.PartitionOffset, error) {
go c.consumePartition(pc)
if c.Process != nil {
c.Process.ComponentStarted()
logrus.Infof("Started consumer for %q topic %q", c.ComponentName, c.Topic)
go func(pc sarama.PartitionConsumer) {
<-c.Process.WaitForShutdown()
_ = pc.Close()