Clean up.

artie-labs · May 13, 2024 · b58613a · b58613a
1 parent 7471006
commit b58613a
Showing 1 changed file with 1 addition and 0 deletions.
diff --git a/processes/consumer/kafka.go b/processes/consumer/kafka.go
@@ -110,6 +110,7 @@ func StartConsumer(ctx context.Context, cfg config.Config, inMemDB *models.Datab
 				kafkaMsg, err := kafkaConsumer.FetchMessage(ctx)
 				if err != nil {
 					slog.With(artie.KafkaMsgLogFields(kafkaMsg)...).Warn("Failed to read kafka message", slog.Any("err", err))
+					time.Sleep(500 * time.Millisecond)
 					continue
 				}