make format

grafana · Sep 10, 2024 · c6d6be2 · c6d6be2
1 parent 09e320d
commit c6d6be2
Showing 1 changed file with 4 additions and 0 deletions.
diff --git a/pkg/kafka/ingester/consumer.go b/pkg/kafka/ingester/consumer.go
@@ -19,6 +19,7 @@ import (
 	"google.golang.org/grpc"
 
 	"github.com/grafana/dskit/backoff"
+
 	"github.com/grafana/loki/v3/pkg/ingester-rf1/metastore/metastorepb"
 	"github.com/grafana/loki/v3/pkg/kafka"
 	"github.com/grafana/loki/v3/pkg/logproto"
@@ -190,6 +191,9 @@ func (c *consumer) appendRecords(records []record) error {
 
 // Flush writes the accumulated data to storage and updates the metadata store
 func (c *consumer) Flush() {
+	if c.writer.InputSize() == 0 {
+		return
+	}
 	if c.lastOffset == -1 {
 		return
 	}