Adding topic name to log fields.

artie-labs · Oct 22, 2024 · bab00d8 · bab00d8
1 parent 32186af
commit bab00d8
Showing 1 changed file with 1 addition and 1 deletion.
diff --git a/processes/consumer/kafka.go b/processes/consumer/kafka.go
@@ -105,7 +105,7 @@ func StartConsumer(ctx context.Context, cfg config.Config, inMemDB *models.Datab
 
 				tableName, processErr := args.process(ctx, cfg, inMemDB, dest, metricsClient)
 				if processErr != nil {
-					logger.Fatal("Failed to process message", slog.Any("err", processErr))
+					logger.Fatal("Failed to process message", slog.Any("err", processErr), slog.String("topic", kafkaMsg.Topic))
 				}
 
 				msg.EmitIngestionLag(metricsClient, cfg.Mode, kafkaConsumer.Config().GroupID, tableName)