Skip to content

Commit

Permalink
Remove unneeded error log message
Browse files Browse the repository at this point in the history
  • Loading branch information
epapbak committed Aug 5, 2024
1 parent 6e121f1 commit 9ff138a
Showing 1 changed file with 0 additions and 2 deletions.
2 changes: 0 additions & 2 deletions consumer/processing.go
Original file line number Diff line number Diff line change
Expand Up @@ -181,8 +181,6 @@ func (consumer *KafkaConsumer) HandleMessage(msg *sarama.ConsumerMessage) error
if err := ocpStorage.WriteConsumerError(msg, err); err != nil {
log.Error().Err(err).Msg("Unable to write consumer error to storage")
}
} else {
logMessageError(consumer, msg, &message, unexpectedStorageType, errors.New("consumer error could not be stored"))
}
consumer.sendDeadLetter(msg)

Expand Down

0 comments on commit 9ff138a

Please sign in to comment.