diff --git a/internal/component/kafka/consumer.go b/internal/component/kafka/consumer.go
index 2f1faed702..a3d94a9366 100644
--- a/internal/component/kafka/consumer.go
+++ b/internal/component/kafka/consumer.go
@@ -44,7 +44,7 @@ func (consumer *consumer) ConsumeClaim(session sarama.ConsumerGroupSession, clai
 			}, func() {
 				consumer.k.logger.Infof("Successfully processed Kafka message after it previously failed: %s/%d/%d [key=%s]", message.Topic, message.Partition, message.Offset, asBase64String(message.Key))
 			}); err != nil {
-				return err
+				consumer.k.logger.Errorf("Too many failed attempts at processing Kafka message: %s/%d/%d [key=%s]. Error: %v.", message.Topic, message.Partition, message.Offset, asBase64String(message.Key), err)
 			}
 		} else {
 			err := consumer.doCallback(session, message)