diff --git a/pkg/limits/ingest_limits.go b/pkg/limits/ingest_limits.go
index e82b2a240889c..fafcc6f2aa896 100644
--- a/pkg/limits/ingest_limits.go
+++ b/pkg/limits/ingest_limits.go
@@ -242,7 +242,7 @@ func (s *IngestLimits) onPartitionsAssigned(_ context.Context, _ *kgo.Client, pa
 	}
 }
 
-func (s *IngestLimits) onPartitionsRevoked(_ context.Context, c *kgo.Client, partitions map[string][]int32) {
+func (s *IngestLimits) onPartitionsRevoked(_ context.Context, _ *kgo.Client, partitions map[string][]int32) {
 	s.removePartitions(partitions)
 }