Skip to content

Commit

Permalink
fix test innues
Browse files Browse the repository at this point in the history
Signed-off-by: axfor <aixiaoxiang2009@hotmail.com>
  • Loading branch information
axfor committed Apr 30, 2023
1 parent fb6eadc commit 7ff2980
Showing 1 changed file with 1 addition and 1 deletion.
2 changes: 1 addition & 1 deletion cmd/ingester/app/consumer/consumer.go
Original file line number Diff line number Diff line change
Expand Up @@ -289,7 +289,7 @@ func (c *Consumer) handleMessages(session sarama.ConsumerGroupSession, claim sar

// Note: Use 'defer' here to first return 'error' to Sarama error handling,
// and then wake up dead error detection, which helps test coverage `handleErrors`
defer c.markDeadlock()
go c.markDeadlock()

return fmt.Errorf("closing partition[%d] due to inactivity", claim.Partition())
}
Expand Down

0 comments on commit 7ff2980

Please sign in to comment.