fix(partition-ingester): Add stream creation error logging (#15640)

grafana · Jan 8, 2025 · f63c16f · f63c16f
1 parent 8e52975
commit f63c16f
Showing 1 changed file with 8 additions and 2 deletions.
diff --git a/pkg/ingester/instance.go b/pkg/ingester/instance.go
@@ -326,8 +326,14 @@ func (i *instance) createStream(ctx context.Context, pushReqStream logproto.Stre
 }
 
 func (i *instance) onStreamCreationError(ctx context.Context, pushReqStream logproto.Stream, err error, labels labels.Labels) (*stream, error) {
-	if i.configs.LogStreamCreation(i.instanceID) {
-		level.Debug(util_log.Logger).Log(
+	if i.configs.LogStreamCreation(i.instanceID) || i.cfg.KafkaIngestion.Enabled {
+		l := level.Debug(util_log.Logger)
+
+		if i.cfg.KafkaIngestion.Enabled {
+			l = level.Warn(util_log.Logger)
+		}
+
+		l.Log(
 			"msg", "failed to create stream, exceeded limit",
 			"org_id", i.instanceID,
 			"err", err,