Skip to content
This repository has been archived by the owner on Aug 25, 2022. It is now read-only.

Commit

Permalink
Merge pull request #19 from hellofresh/bugfix/iss-18
Browse files Browse the repository at this point in the history
Fixes #18. Add more info to logs
  • Loading branch information
iuriinedostup authored Nov 23, 2016
2 parents d2071c9 + db1fb80 commit 54e915c
Showing 1 changed file with 1 addition and 0 deletions.
1 change: 1 addition & 0 deletions workers/producer.go
Original file line number Diff line number Diff line change
Expand Up @@ -55,6 +55,7 @@ func (p *internalProducer) handleMessage(msg internalMessage) (err error) {
statsd.Instance().Increment("kafka.failed-messages")

logger.Instance().
WithError(err).
WithField("topic", msg.Topic).
Debug("An error occurred while sending message to kafka")
}
Expand Down

0 comments on commit 54e915c

Please sign in to comment.