fix(kafka): ConsumeClaim should not return err when retry recovery fa…

…iled
dapr · Aug 12, 2022 · 7d96898 · 7d96898
1 parent d30b773
commit 7d96898
Showing 1 changed file with 1 addition and 1 deletion.
diff --git 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("Error 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)