Skip to content

Commit

Permalink
chore: fix lint
Browse files Browse the repository at this point in the history
  • Loading branch information
Abdulsametileri committed Sep 4, 2024
1 parent 9acc868 commit a226fba
Showing 1 changed file with 1 addition and 0 deletions.
1 change: 1 addition & 0 deletions internal/cronsumer.go
Original file line number Diff line number Diff line change
Expand Up @@ -136,6 +136,7 @@ func (k *cronsumer) recoverMessage(msg MessageWrapper) {

func (k *cronsumer) produce(msg MessageWrapper) {
if msg.IsGteMaxRetryCount(k.maxRetry) {
//nolint:lll
k.cfg.Logger.Infof("Message from %s exceeds to retry limit %d. KafkaMessage: %s, Headers=%v", k.cfg.Consumer.Topic, k.maxRetry, msg.Value, msg.Headers.Pretty())

if k.isDeadLetterTopicFeatureEnabled() {
Expand Down

0 comments on commit a226fba

Please sign in to comment.